Skip to content

v2021.04.19

Compare
Choose a tag to compare
@kenneth-jia kenneth-jia released this 19 Apr 08:36
· 113 commits to main since this release

This release cooperates with librdkafka v1.6.0

  • Added transaction support

    • KafkaConsumer

      • Consumer::ConsumerGroupMetadata
    • KafkaProducer

      • void initTransactions(std::chrono::milliseconds timeout)

      • void beginTransaction()

      • void commitTransaction(std::chrono::milliseconds timeout)

      • void abortTransaction(std::chrono::milliseconds timeout)

      • void sendOffsetsToTransaction(const TopicPartitionOffsets& tpos, const Consumer::ConsumerGroupMetadata& groupMetadata, std::chrono::milliseconds timeout)

  • Added rich-info error type -- Error

  • Removed customized default properties