Appian Community and Appian Academy are being upgraded. As a part of the upgrade, Appian Community is currently in read-only mode, and user registration is disabled until August 3. We apologize for any inconvenience this may cause, but a more secure, stable, and performant Community experience is coming soon!

The new Appian Community launches August 3, followed by Appian Academy on August 7. During the migration, Appian Community Edition, Appian Academy, Documentation, Certifications, Instructor-led Customer Training, Partner Sales Training & Accreditation, and Forum (for Appian Partners and Customers only) will remain available.

Kafka Tools

Overview

KafkaTools provides the following functionality that allows publishing to and consuming from topics on Kafka Servers.

Smart Services

  • Publish To Kafka
  • Consume From Kafka
  • Consume From Kafka JWT Auth Grant

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.

Anonymous
Parents Comment
  • I just looked into the source code and found the below constructor is used to instantiate an object of ProducerRecord class which does not take 'Header' as parameter:
    ProducerRecord(String topic, V value)

    Create a record with no key

    If the headers are required to be passed then another constructor of this class is required to be used as shown below:

    ProducerRecord(String topic, Integer partition, K key, V value, Iterable<Header> headers)

    Creates a record to be sent to a specified topic and partition

    Please 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

Children
No Data