tKafkaCommit Standard properties
These properties are used to configure tKafkaCommit running in the Standard Job framework.
The Standard tKafkaCommit component belongs to the Internet family.
The component in this framework is available in all Talend products with Big Data and in Talend Data Fabric.
Basic settings
Commit offsets from |
Select the tKafkaInput component from which the consumed messages are committed. |
Advanced settings
tStatCatcher Statistics |
Select this check box to gather the processing metadata at the Job level as well as at each component level. |
Global Variables
ERROR_MESSAGE |
The error message generated by the component when an error occurs. This is an After variable and it returns a string. |
Global Variables
ERROR_MESSAGE |
The error message generated by the component when an error occurs. This is an After variable and it returns a string. |
Usage
Usage rule |
Although tKafkaCommit can be used as an end component in a subJob flow or can be called independently as its own subJob, it is typically used standalone to commit a batch of offsets in one go. If you need to commit offsets regularly, it is recommended to use the Auto-commit feature in tKafkaInput. |