[
https://issues.apache.org/jira/browse/KAFKA-8485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
kaushik srinivas updated KAFKA-8485:
------------------------------------
Summary: Kafka connect worker does not respond/function when kafka broker
goes down. (was: Kafka connect worker does not respond when kafka broker goes
down with data streaming in progress)
> Kafka connect worker does not respond/function when kafka broker goes down.
> ---------------------------------------------------------------------------
>
> Key: KAFKA-8485
> URL: https://issues.apache.org/jira/browse/KAFKA-8485
> Project: Kafka
> Issue Type: Bug
> Components: KafkaConnect
> Affects Versions: 2.2.1
> Reporter: kaushik srinivas
> Priority: Blocker
> Labels: performance
>
> Below is the scenario
> 3 kafka brokers are up and running.
> Kafka connect worker is installed and a hdfs sink connector is added.
> Data streaming started, data being flushed out of kafka into hdfs.
> Topic is created with 3 partitons, one leader on all the three brokers.
> Now, 2 kafka brokers are restarted. Partition re balance happens.
> Now we observe, kafka connect does not respond. REST API keeps timing out.
> Nothing useful is being logged at the connect logs as well.
> Only way to get out of this situation currently is to restart the kafka
> connect worker and things gets normal.
>
> The same scenario when tried without data being in progress, works fine.
> Meaning REST API does not get into timing out state.
> making this issue a blocker, because of the impact due to kafka broker
> restart.
>
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)