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
