What's new in version 1.6.0

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

  • The KafkaProducer exposes many performance metrics of the producer client as operator metrics
  • The most important producer configs have default values, which result in higher reliability and throughput. These are retries, compression.type, linger.ms, batch.size, and max.in.flight.requests.per.connection.

  • New operator parameter guaranteeOrdering for the KafkaProducer, which guarantees that the sequence in a topic partition is the same as the order of tuples in case of retries.

  • Queue control for the KafkaProducer operator to stabilize the maximum queue time and to avoid timeouts sending records

  • The KafkaConsumer operator exposes some performance metrics of the consumer client as operator metrics, like the lag for each topic partition.