kafka connect api

preview_player
Показать описание
Kafka Connect API using a local file as a source and an existing 'MySecondTopic' topic to stream this data to.

Any changes in the file are committed to the topic (*MySecondTopic")

change these:
file=text2
topic=MySecondTopic

and create a file called 'text2' in the kafka directory
and enter some text and save (use nano or similar)
Then execute the following

Now check using a console consumer as before and the file contents should be added:

Next we look at using Postman to play with the REST API starting with:
Change IP address to match your server. No authentication needed for this demo.
Рекомендации по теме
Комментарии
Автор

Very helpful contents - thanks for sharing

soumyamukherjee
Автор

I have a general question regarding Kafka-Connect. I went through documentation, blogs but couldn't find a straight answer.
If there are two workers, running single Connector(instance) then
How does a Connector(instance) decide when to spawn a new task, if eg. tasks.max = 10? Also, how does a Connector(instance) decide how many tasks to spawn, if eg. tasks.max = 10?
Does it depend upon underlying hardware configuration? eg. number of cores or memory or cpu utilization?

My kafka-connector is always creating only one task even though my tasks.max=10

hamidjawaid
Автор

Hi
How can I update kafka connect config properties via api

manojsadhu