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
 
Signature of Consume Service Template
The input signature contains the following parameters:
Parameter
Description/Action
topic
Specifies the topic(s) from which the messages is consumed.
partition(optional)
Specifies the partition from which the messages are consumed.
pollTime
Specifies the polling interval in milliseconds. Default value is 10000.
offset(optional)
Specifies the offset of the partition from where the consumer needs to start consuming the messages.
The output signature contains the following parameters:
Parameter
Description/Action
topic
Specifies the topic(s) from which the messages are consumed.
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 key of the consumed message
value
Specifies the value of the consumed message
header
Specifies the list of headers
Note:
This parameter appears when the Kafka version of the consumer connection is v11+.