Overview
KafkaTools provides the following functionality that allows publishing to and consuming from topics on Kafka Servers.
Smart Services
In order to process the messages consumed from Kafka, it is recommended to use the Transaction Manager application. The models designed to process messages will be configured an assigned through the transaction manager job types. See documentation for Transaction Manager
Key Features & Functionality
Please refer to the README for additional details.
Our client uses the Confluent tool, which encompasses Kafka.From Appian, with this plugin, we can publish & consume messages in a topic, but, as is being done through Confluent, the messages negotiate with a scheme, where the message format is AVRO (Json with headers) and each message published and consumed have to go through serialization / deserialization. Therefore, consumed messages arrive at Appian in an unreadable format.
This is a message to the author of the "Kafka Tools" plugin: Is there an update in progress for this Appian plugin that would allow for the necessary Java libraries for Confluent, as well as the necessary classes to allow the message to be serialized/deserialized?
And please, if anyone has had a situation similar to what I am talking about, please contact me, I will greatly appreciate it.
Thank you so much,I am looking forward to your response
We are also having the same issue? Have you been able to solve this problem?
We try to connect to kafka to consume but get an error message "Failed to load SSL keystore"We replaced the keystore parameter with another keystore document and tried to remove kafka plugin and added the plugin again but the message refers still to the same document. How can we force appian to use the new keystore document ?Looks like once the keystore is set there is no way to replace it. Or do you know a way how to do it ?
Has anyone experienced this issue on your cloud environment? From what we can see, appian is able to connect to kafka but unable to consume the records.
How's is the keystore configured/created for the cloud/SaaS environment?