What's new in version 1.7.1

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

  • operator metrics which got invalid for an operator are flagged with a value of -1, for example the metric for the partition related consumer lag after de-assignment of a partition from a consumer operator

  • when not in a consistent region, offsets are committed when partitions are re-balanced within a consumer group. After re-assignment, messages are fetched beginning with the previously committed offsets. The periodic commit controlled by the commitCount parameter is reset after rebalance.