Adapter for Apache Kafka 9.6 | webMethods Adapter for Apache Kafka Documentation | webMethods Adapter for Apache Kafka Installation and User’s Documentation | Adapter Services | Signature of Consume Service Template for Confluent Kafka
 
Signature of Consume Service Template for Confluent Kafka
The input signature contains the following parameters:
Parameter
Description/Action
$topic
Specifies the name of the topic(s), that overrides the configured value in the Consume with Schema tab.
pollTime
Specifies the polling interval in milliseconds. Default value is 10000.
The output signature contains the following parameters:
Parameter
Description/Action
topic
Overrides the topic(s) that is configured in Consume with Schema tab.
offset
Specifies the position of the message in the corresponding Kafka partition.
partition
Specifies the partition from which the messages are consumed.
Key
Specifies the input type as a document, if it's an avro schema file.
value
Specifies the input type as a document, if it's an avro schema file.
header
Specifies the list of headers of the consumed message.