What's new in version 1.9.0

Kafka Toolkit > com.ibm.streamsx.kafka 2.2.1 > What's new and what has changed > What's new in version 1.9.0

  • Upgrade of kafka-clients from version 1.0 to 2.1.1

  • The KafkaProducer can now be flushed after a fixed number of tuples, new optional parameter flush.

  • Bug fix: KafkaConsumer can create invalid checkpoint when group management is active. When Kafka's group management is used in a consistent region, the maxConsecutiveResetAttempts should be increased (default value is 5).