Page History
Versions Compared
Key
- This line was added.
- This line was removed.
- Formatting was changed.
Info |
---|
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. |
Info | ||
---|---|---|
| ||
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:
Multiexcerpt include | ||||||
---|---|---|---|---|---|---|
|
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.
Multiexcerpt include | ||||||
---|---|---|---|---|---|---|
|
The Kafka Producer returns some meta data about the processing of the message.
Multiexcerpt include | ||||||
---|---|---|---|---|---|---|
|
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.
Panel | ||
---|---|---|
| ||
|
Panel | ||
---|---|---|
|
Otp | ||
---|---|---|
|
Panel | ||
---|---|---|
| ||