You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@kafka.apache.org by Behroz Sikander <be...@gmail.com> on 2020/04/03 08:46:21 UTC

Kafka connect didn't reach end of config log quickly enough error

Hello,
I have a distributed Kafka Connect installation running. At startup phase, I am getting the following error. I am using Kafka 2.2.1.

I have 2 questions:
1- What does this error mean and how to prevent this?
2- What happens with the REST requests? Will they faill? Or only the requests that come to this worker will fail?

[2020-04-02 17:18:16,439] WARN Catching up to assignment's config offset. (org.apache.kafka.connect.runtime.distributed.DistributedHerder:775)
[2020-04-02 17:18:16,439] INFO Current config state offset -1 is behind group assignment 111, reading to end of config log (org.apache.kafka.connect.runtime.distributed.DistributedHerder:820)
[2020-04-02 17:18:19,440] WARN Didn't reach end of config log quickly enough (org.apache.kafka.connect.runtime.distributed.DistributedHerder:829)
java.util.concurrent.TimeoutException: Timed out waiting for future
        at org.apache.kafka.connect.util.ConvertingFutureCallback.get(ConvertingFutureCallback.java:73)
        at org.apache.kafka.connect.storage.KafkaConfigBackingStore.refresh(KafkaConfigBackingStore.java:397)
        at org.apache.kafka.connect.runtime.distributed.DistributedHerder.readConfigToEnd(DistributedHerder.java:822)
        at org.apache.kafka.connect.runtime.distributed.DistributedHerder.handleRebalanceCompleted(DistributedHerder.java:785)
        at org.apache.kafka.connect.runtime.distributed.DistributedHerder.tick(DistributedHerder.java:247)
        at org.apache.kafka.connect.runtime.distributed.DistributedHerder.run(DistributedHerder.java:219)
        at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
        at java.util.concurrent.FutureTask.run(FutureTask.java:266)
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
        at java.lang.Thread.run(Thread.java:805)


Regards