Получение исключения Timeout Kafka org.apache.kafka.common.errors.TimeoutException: Call(callName=deleteRecords(api=META ⇐ JAVA

[Anonymous]

Я столкнулся с исключением тайм-аута Kafka. Ошибка:
partition: B3-0 error: org.apache.kafka.common.errors.TimeoutException: Call(callName=deleteRecords(api=METADATA), deadlineMs=1721138713548, tries=721498, nextAllowedTryMs=1721138714452) timed out at 1721138713557 after 721498 attempt(s)

Мы используем cp-kafka-connect из dockerhub confluentinc/cp-kafka-connect:7.6.1
Используем версию Kafka Connect Maven, как показано ниже.
2.5.1
2.5.1

Мы не обновились до последней версии Kafka из-за некоторых проблем, но Zookeeper Maven обновлен до последней версии 3.7.2

org.apache.zookeeper
zookeeper
3.7.2
test


Также было обновлено приложение kafka-log4j.

org.apache.kafka
kafka-log4j-appender
3.7.0


Ниже приведены все зависимости, связанные с Kafka

io.confluent
kafka-connect-avro-converter
7.3.8


com.ibm.eventstreams.connect
kafka-connect-mq-sink
${connector.third.party.kafka-connect-mq.version-sink}
jar
system
${basedir}/${connector.third.party.jars}/kafka-connect-mq-sink-1.5.2-jar-with-dependencies.jar




com.ibm.eventstreams.connect
kafka-connect-mq-source
${connector.third.party.kafka-connect-mq.version-source}
jar
system

${basedir}/${connector.third.party.jars}/kafka-connect-mq-source-1.3.5-jar-with-dependencies.jar



org.apache.kafka
kafka_2.13
${kafka-connect.version}
test
test


org.scala-lang
scala-library


org.apache.zookeeper
zookeeper





org.apache.kafka
kafka_2.13
${kafka-connect.version}
test


org.scala-lang
scala-library


org.apache.zookeeper
zookeeper





org.apache.zookeeper
zookeeper
3.7.2
test


org.scala-lang
scala-library
2.13.12
test



org.apache.kafka
kafka-clients
${kafka.version}
test
test



org.apache.kafka
connect-runtime
${kafka-connect.version}
test
test



Подробнее здесь: https://stackoverflow.com/questions/787 ... texception