How to consume message from Kafka Topic in OIC
In this example, I have configured a scheduled orchestrated integration to read records using the Apache Kafka Adapter and publish them to a file location using the FTP write operation.
Drag and drop the kafka adapter into the flow.
Configuring kafka adapter connection is shown in my previous post.
Select Consume records.
Select the topic and partition.
And specify the option for consuming
messages as “Read latest”.
Specify Message structure as
“Yes”
Select the message structure.
Next and finish.
Below is the map activity between kafka response and FTP input.
No comments:
Post a Comment