Skip to content

v2021.10.21

Compare
Choose a tag to compare
@kenneth-jia kenneth-jia released this 21 Oct 01:17
· 59 commits to main since this release

This release cooperates with librdkafka v1.7.0

  • Unify KafkaAsyncProducer & KafkaSyncProducer into KafkaProducer

    • New interface syncSend(...) for synchronous operation
  • Unified KafkaAutoCommitConsumer & KafkaManualCommitConsumer into KafkaConsumer

  • Refine the namespaces

    • Use lowercased namespace names

      • E.g. kafka, kafka::clients, kafka::utility, etc
    • New namespace kafka::clients for Kafka clients and related types

      • kafka::clients::KafkaProducer

      • kafka::clients::producer

        • Config

        • RecordMetadata

        • Callback

      • kafka::clients::KafkaConsumer

      • kafka::clients::consumer

        • Config

        • RebalanceCallback

        • OffsetCommitCallback

        • ConsumerGroupMetadata

        • UnorderedOffsetCommitQueue

      • kafka::clients::AdminClient

      • kafka::clients::admin

        • Config

        • CreateTopicsResult

        • DeleteTopicsResult

        • ListTopicsResult

        • DeleteRecordsResult

  • New addon: KafkaRecoverableProducer

    • A wrapper over KafkaProducer, which would internally re-initialize the underlying producer for fatal errors