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.
How do you resolve the issue "Topic appianTopic not present in metadata after 60000 ms" when publishing to a kafka topicWe have configured the scs keyand then configured the smart service as follow
scs key: used the api key as username and api secret as password
topic: topic created on confluent kakfa
servers: bootstrap server provided by confluent kafka
security protocol: SASL_PLAINTEXT
sasl mechanism: PLAIN
Where do you use the cluster id?
I am trying to use this plugin using SASL_MECHANISM as SCRAM_SHA_512 but it is failing. I have created the trusted store using amazonca1.cer. I have downloaded this certificate from this URL https://www.amazontrust.com/repository/. In my secure credentials, I have configured username, password, and truststorepwd. In my process model on call of consume kafka I am passing my secure credential name. We are on Appian cloud and I am getting the error INVALID SASL_MECHANISM. I am able to consume Kafka directly on my machine but I am unable to get it on Appian environment. What could be the possible solution?
Hi borisb170, The Readme.pdf is now part of the deliverable.Please download the new version, you will find it inside the zip.
Hi Sylvain,
Thanks for providing this plug-in. In the description of the plug-in you refer to a README file for additional details but in the download I can only find the .jar file. Where can we find the README file for additional details?
Thanks!
Ketan - thank you for question. At this point, we do not have plans to enhance this plugin. However, I am happy to create an item in our backlog to do so in the future.
Would you be able to provide more information about your use case?
Hi Sylvain Furt
Request you to please let us know - if this enhancement will be taken in upcoming version
Hi Luciano,
Any solution to SSL Handshake error?
Thanks,
Manjunath
ProducerRecord(String topic, Integer partition, K key, V value, Iterable<Header> headers)Creates a record to be sent to a specified topic and partitionPlease let us know - if there is any plan to upgrade it in future to accept headers or we need to extend it for our custom need