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. |
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+. |