Kafka extension changelog

Core features

From version 3.1.4 onwards, version numbers are aligned with C4I Core

Kafka extension versionC4I Core version
3.1.13.1.1
3.0.13.0.2
2.1.02.1.0
2.0.02.0.0
1.4.01.8.0
1.3.01.7.0
1.2.21.6.2
1.1.01.5.0
1.0.01.4.1

3.22.1

Released on 2026-07-02

  • Fix NullPointerException when client.id is not set

3.21.5

Released on 2026-03-17

  • Breaking change : The separator which was previously used to separate the output queue name and the optional path to write the data to ("😕/") is now replaced with "#"

3.20.4

Released on 2025-11-13

3.18.2

Released on 2025-06-12

  • Improve performances of the first send request by instantiating the Producer early

3.17.3

Released on 2025-03-03

  • Add logging for OAuth Token Supplier
  • Fix asynchronous message sending

3.16.2

Released on 2025-01-28

  • Fix exception when retrieving stored token after a first error has occurred
  • Add performance indicators for message generation and sending

3.14.2

Released on 2024-08-07

  • Add ability to extract topic names from YAML configuration file
  • Store the OAuth token on the disk to reuse the same token between runs
  • Add parameter to disable topics auto-create
  • When an exception is raised, the ID of the message is logged

3.13.3

Released on 2024-07-11

  • Add "maxRequestSize" ("max.request.size") parameter
  • Add "bufferMemory" ("buffer.memory) parameter

3.11.0

Released on 2024-06-11

  • The Kafka connector can now send XML messages

3.10.4

Released on 2024-05-16

  • Add ability to specify JAAS extensions for OAuth2 authentification
  • Fix some ClassLoading exceptions when running from STEP

3.9.3

Released on 2024-05-13

  • Fix typo in compression mode ZSTD

3.8.3

Released on 2024-01-09

  • Send messages to specific partitions of the topics
  • Add OAuth2 authentication
  • Add compression, linger and batchSize parameters

3.6.7

Released on 2023-06-28

  • Send the Client ID in the requests (it was previously unused)

3.6.0

Released on 2023-04-17

  • Kafka driver updated to 3.3.2

3.3.0

Released on 2022-10-27

  • Kafka driver updated to 3.3.1
  • Add Avro and Protobuf serialization with a Schema Registry
  • Add SASL Authentication support
  • Add SSL support
  • Remove parameter deleteMessageTemplate. Deletions should be mapped as any other events

3.0.1

Released on 2022-05-24

  • Kafka driver updated to 3.1.0

1.3.0

Released on 2021-07-08

  • Kafka driver updated to 2.7.1
Last Updated: