Page History
Versions Compared
compared with
Key
- This line was added.
- This line was removed.
- Formatting was changed.
Comment:
Published by Scroll Versions from space WBRIDGE and version 24.0
| 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 | ||
|---|---|---|
| ||
Overview
Content Tools