CDD property - be.channel.kafka.auto.offset.reset
Article ID: KB0071643
Updated On:
| Products | Versions |
|---|---|
| TIBCO BusinessEvents Enterprise Edition | 5.x/6.x |
Description
Description and usage of CDD property "be.channel.kafka.auto.offset.reset"
Issue/Introduction
CDD property - be.channel.kafka.auto.offset.reset, when applied and usage
Environment
All Operating Systems
Resolution
Kafka maintains an offset for each record in a partition for each connected client with a given group ID.
The consumer position specifies the offset of the next message the client receives.
The CDD property "be.channel.kafka.auto.offset.reset" is applied only if the offset of the group ID of the Kafka input destination has not yet been initialized.
You can check this with the following command.
If the groupID is not listed in the output for the configured Kafka topic, the offset is initialized with the configured value of the CDD property:
The consumer position specifies the offset of the next message the client receives.
The CDD property "be.channel.kafka.auto.offset.reset" is applied only if the offset of the group ID of the Kafka input destination has not yet been initialized.
You can check this with the following command.
kafka-consumer-groups.{bat|sh} --bootstrap-server <bootstrap_ServerURL> --all-groups --describe --verbose
If the groupID is not listed in the output for the configured Kafka topic, the offset is initialized with the configured value of the CDD property:
be.channel.kafka.auto.offset.reset={earliest|latest}
earliest : Resets the offset to the earliest offset. All messages of the topic will be delivered and processed by the agent.
latest (default) : Resets the offset to the latest offset. Only new messages are delivered and processed by the agent.
latest (default) : Resets the offset to the latest offset. Only new messages are delivered and processed by the agent.
Feedback
Yes
No
Powered by
