v2023.01.05

This release cooperates with librdkafka v1.9.2

• Namespace changes

  • kafka::clients::producer::KafkaProducer (instead of kafka::clients::KafkaProducer)
  • kafka::clients::consumer::KafkaConsumer (instead of kafka::clients::KafkaConsumer)
  • kafka::clients::admin::AdminClient (instead of kafka::clients::AdminClient)

• Legacy interface removed

  • No setLogger(...)/setErrorCallback(...)/setStatsCallback(...)/setOauthbearerTokenRefreshCallback(...) any more.
  • No EventsPollingOption parameter for Kafka client initialization.
  • No Interceptor parameter for Kafka client initialization.

• New Properties

  • It contains all configuration info to initialize a Kafka client. The property value type could be
    • std::string: Most are from librdkafka configuration.
    • std::function<...>: Callbacks for log_cb, error_cb, stats_cb or oauthbearer_token_refresh_cb.
    • Interceptors
  • New configuration property: enable.manual.events.poll.

• Default behavior changed

  • enable.auto.commit=true for KafkaConsumer by default