Skip to content
This repository was archived by the owner on Nov 24, 2020. It is now read-only.

Release v4.0.1

Choose a tag to compare

@nick-zh nick-zh released this 05 Oct 09:50
3e436a5

Description

Add all the capabilities of ext-rdkafka:4.0 and minor consumer / producer improvements

Features

  • add new functions to consumers (offsetsForTimes, getFirstOffsetForTopicPartition, getLastOffsetForTopicPartition)
  • add logCallback support to consumer builder
  • add KafkaHighLevelConsumer::close
  • add KafkaHighLevelConsumer::getOffsetPositions
  • add KafkaProducer::flush
  • add KafkaProducer::purge

Improvements

  • improve commit behaviour by setting enable.auto.commit to false for high level consumer
  • block producer on full queue by adding RD_KAFKA_MSG_F_BLOCK

General

  • add dependency to ext-rdkafka:4.0