Я столкнулся с исключением тайм-аута 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
