Skip to content

Kafka Toolkit v2.1.0
Compare
Choose a tag to compare
released this 09 Aug 13:22
· 195 commits to develop since this release
v2.1.0
f8a5349

What's new in this toolkit release

Changes and enhancements

  • This toolkit version has been tested also with Kafka 2.3

  • #169 new optional operator parameter sslDebug. For debugging SSL issues see also the toolkit documentation

  • #167 changed default values for following consumer and producer configurations:

    • client.dns.lookup = use_all_dns_ips
    • reconnect.backoff.max.ms = 10000 (Kafka's default is 1000)
    • reconnect.backoff.ms = 250 (Kafka's default is 50)
    • retry.backoff.ms = 500 (Kafka's default is 100)

  • Changed exception handling for the KafkaProducer when not used in a consistent region: #163 (comment)

Bugs fixed in this release

  • #163 KafkaProducer's exception handling makes the operator lose tuples when in CR
  • #164 on reset() the KafkaProducerOperator should instantiate a new producer instance
  • #166 Resource leak in KafkaProducer when reset to initial state in a CR

You find the SPL documentation online at https://ibmstreams.github.io/streamsx.kafka/docs/user/SPLDoc/

Assets 4
Loading