tKafkaBulkInput – Talend Custom Components

• Kafka home
• Kafka Java API Documentation

• tKafkaBulkInput version 0.93 – Direct download
• tKafkaBulkInput version 0.94 – Direct download
• tKafkaBulkInput version 0 – Direct download

Download this artifact.
Extract component files from zip file of that.
Copy extracted files to component directory of TOS plugin or custom component directory.
Restart TOS.
And dive into it.

You can be using stored stream service of kafka.
You can be setting multiple broker of kafka server.
You can be extracting data with interval time of your needs.

This component provide interval time opertation to process kafka bulk with users.
Basically you can be setting start date and end date on UI input form from component tap. Also if you are needed to set polling timeout and polling count, you can do it.
Normally You have only to input interval of time value. If you need to be set detail configuration of polling, you can configurate that. polling timeout is timeout value per one polling. polling count is polling count. In case of huge data polling process, data could’t be fetched at once with single polling and sometimes could be empty. because of this, you can setting this value properly.

Release version: 0.93 – 2020-02-10 00:25:04
First draft of this component.
Release version: 0.94 – 2020-03-24 00:49:13
To improve consumer configuration detail setting.
You can set configuration with key/value.
Release version: v1.01 – 2020-05-08 02:27:37
To able to select partition, you can set partitions with comma seperated number.
To improve component inner logic.

• 6.0 (obsolete)
• 6.1 (obsolete)
• 6.2 (obsolete)
• 6.3 (obsolete)
• 6.4 (obsolete)
• 6.5 (retired)
• 7.0 (retired)
• 7.1 (retired)
• 7.2
• 7.3