Hi Guys,
I had a requirement that my Appian Application needs to consume data from Kafka.
For this i have added a Plug-in called (Kafka tool). It contains 2 smart services.
1. Consume from Kafka.
2. Publish To Kafka.
So, i used Consume from Kafka Node in my process model. In data tab there are following Node inputs and node outputs to configure.
Node Inputs:
Node Outputs:
Above Highlighted fields are mandatory fields.
My Doubts:
Discussion posts and replies are publicly visible
Did you try to download the plugin from the AppMarket and check for included documentation?
A smart service does not need another integration.
The boolean output is called "success" and will only tell whether a message was retrieved.
The data from the message will be written to a database table configured in the smart service.
Ohh!. Okay got it now. I haven't tried to download the plugin in AppMarket. Now I downloaded the Plugin. It has complete Documentation.
Thanks
Could we consume real-time stream without writing to DB ? For example: direct to PVs.
That depends on the actual implementation of the plugin. Please check its documentation.
Unfortunately till now it doesn't support that so I'm trying to workaround with the simplest possible solution.
Stafan, Dinesh - Can one of you pls point me to the documentation or help me in capturing the message/data from Kafka ? What values do we specify in the output section of the component so data can either get routed to database or store the stream in a local variable ? any help is greatly appreciated. thanks!
Dinesh - Were you able to capture the data in a transaction table ? If so, can you please provide details/screenshots of the declarative settings you used ? We are seeing the boolean value but unable to capture the actual message(here we are using a unstructured data file). Thanks!