Contact Free trial Login

Apache Kafka Connector Release Notes

Support Category: Select

The Anypoint Connector for Apache Kafka allows you to connect to the Apache Kafka messaging system over the Mule runtime, enabling seamless integration between your applications and an Apache Kafka cluster.

3.0.6

July 2, 2019

Compatibility

Software Version

Mule Runtime

Mule Runtime Enterprise Edition 4.0.0 and later

Apache Kafka

2.2.0

Fixed in this Release

  • Kafka connector overrides the user-defined security.protocol=SASL_SSL to use the security.protocol=SSL value. (SE-11947)

3.0.5

June 19, 2019

Compatibility

Software Version

Mule Runtime

Mule Runtime Enterprise Edition 4.0.0 and later

Apache Kafka

2.2.0

Fixed in this Release

  • Updated the Kafka Clients library to version 2.2.0.

  • Updated code to use the poll(java.time.Duration) method provided in the new library that replaces the deprecated poll(long) method. The deprecated method did not block beyond the timeout for waiting on a partition assignment. (KIP-266)

3.0.4

May 16, 2019

Compatibility

Software Version

Mule Runtime

Mule Runtime Enterprise Edition 4.0.0 and later

Apache Kafka

0.10.2.0

Fixed in this Release

  • Fixed a performance connection validation issue relating to the same issue as in v3.0.3. (SE-11817)

3.0.3

May 16, 2019

Compatibility

Software Version

Mule Runtime

Mule Runtime Enterprise Edition 4.0.0 and later

Apache Kafka

0.10.2.0

Fixed in this Release

  • The Test Connection button in Anypoint Studio for the Kafka connector did not work in Mule 4. (SE-11817)

3.0.2

April 30, 2019

Compatibility

Software Version

Mule Runtime

Mule Runtime Enterprise Edition 4.0.0 and later

Apache Kafka

0.10.2.0

Fixed in this Release

3.0.1

June 26, 2018

Compatibility

Software Version

Mule Runtime

Mule Runtime Enterprise Edition 4.0.0 and later

Apache Kafka

0.10.2.0

Features

  • No new features added

Fixed in this Release

  • Kafka connector was not serializing and deserializing properly the messages that were not plain text. Now the content of the messages can be sent as any type (plain, XML, JSON) as the value is serialized and deserialized properly.