1.2.4 Released!!

In this release, the schema name of the Apache Avro Record is populated into the Synapse message context as schemaName, which can be retrieved in the mediation in the following way.

<property expression="get-property('schemaName')" name="kafka_avro_schema_name" xmlns:ns="http://org.apache.synapse/xsd"/>

1.2.3 Released!!

This release changes the default behavior of the failure.retry.count parameter to retry indefinitely by setting its default value to -1.

1.2.2 Released!!

This release adds the following Kafka configuration property

avro.use.logical.type.converters - This property enables the use of logical type converters in Avro.

1.2.1 Released!!

This release adds the following Kafka configuration properties.

• sasl.client.callback.handler.class - The fully qualified name of a SASL client callback handler class that implements the AuthenticateCallbackHandler interface.

• sasl.login.class - The fully qualified name of a class that implements the Login interface. For brokers, login-config must be prefixed with listener prefix and SASL mechanism name in lower-case.

Also, fixes an NPE - wso2/product-micro-integrator#2998

1.2.0 Released!!

This release adds the following features.

• Handle poison pills.
• Trigger the 'onError' sequence upon retry exhaustion.
• Introduce a property to configure failure retry interval.
• Introduce a property to configure a header prefix when setting Kafka headers to message context.
• Enable SASL_SSL security protocol with the OAUTHBEARER mechanism.

1.1.1 Released!

Implement Schema Registry Basic Authentication support for Kafka Inbound Endpoint.

1.1.0 Released!

Add support (upgraded) to the latest Kafka client version 3.3.1

1.0.12 Released!

Fix NPE issue when a record with null value is consumed

1.0.11 Released!

Add support for Kafka Avro inbound endpoint.

1.0.10 Released!

Support to configure the topic name dynamically by not having to append them in the custom header.