Breadcrumbs

Apache Kafka Producer Adapter


This page explains the Apache Kafka Producer Adapter in Bridge context. If you were looking for the same information regarding the PAS Designer, refer to Apache Kafka Producer Adapter in the Designer guide.

You can use the Apache Kafka Producer Adapter to write synchronous messages to an Apache Kafka event topic. The access to Kafka can be configured statically by an alias - dynamic access is not available. The Kafka Producer supports SSL but no Kerberos authentication.


To use the Apache Kafka Producer adapter, you need basic knowledge of Apache Kafka. Refer to the Apache Kafka Documentation for any deeper insights.

Writing a Message to a Kafka Topic

You can use the Apache Kafka Producer adapter to write a message to a Kafka topic. Create an action node and assign stereotype KafkaProducerAdapter. This action node has got the following parameters:

Error rendering macro 'multiexcerpt-include' : Page loading failed

producerRecord is a complex structure that defines the message and target.The topic you want to write the message to is the only mandatory parameter.

Error rendering macro 'multiexcerpt-include' : Page loading failed

The Kafka Producer returns some meta data about the processing of the message.

Error rendering macro 'multiexcerpt-include' : Page loading failed

Transaction Handling

The xUML Runtime handles Apache Kafka Producer calls like is specified in the Runtime transaction concept. All producer calls within a session are wrapped into a dedicated transaction with a random unique transaction ID. These transactions can be rolled back until they have been committed.
You cannot set a custom transaction ID (transactional.id), therefore there will be no fencing.

Related Pages:


Related Documentation: