Skip to content

v2021.08.25

Compare
Choose a tag to compare
@kenneth-jia kenneth-jia released this 25 Aug 02:06
· 78 commits to main since this release

This release cooperates with librdkafka v1.7.0

  • Support windows platform

  • New interface for AdminClient

    • Admin::DeleteRecordsResult deleteRecords(const TopicPartitionOffsets& topicPartitionOffsets, std::chrono::milliseconds)
  • Incremental cooperative rebalancing support for KafkaConsumer

    • I.e. partition.assignment.strategy=cooperative-sticky
  • Unified Error type

    • No std::error_code (for interfaces) anymore

    • Type Error is convertible to std::error_code

  • New interface for error notification

    • KafkaClient::setErrorCallback(std::function<void(const Error&)> errorCb)
  • Fixed issue for KafkaConsumer

    • subscribe(...)/unsubscribe(...) returned too soon (before the "partition-rebalance events" being triggered)