Kafka Connect - Ошибка при получении метаданных с идентификатором корреляции UNKNOWN_TOPIC_OR_PARTITION - PullRequest
Новая
       80

Kafka Connect - Ошибка при получении метаданных с идентификатором корреляции UNKNOWN_TOPIC_OR_PARTITION

0 голосов
/ 30 января 2020

У нас есть Kafka Connect с postgres соединителем, который извлекает изменения из БД и помещает их в топи c. Мы получаем ошибку

ERROR WorkerSourceTask{id=wem-postgres-source-0} Failed to flush, timed out while waiting for producer to flush outstanding 1 messages

, за которой следует

ERROR WorkerSourceTask{id=wem-postgres-source-0} Failed to commit offsets (org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter)

, за которой следует

[2020-01-30 09:51:52,219] WARN [Producer clientId=producer-8] Error while fetching metadata with correlation id 606994 : {topicname=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient)

Мы проверили, что топи c существует, выполнив описание топи c, дайте нам 

zookeeper-1 [root@XX /bin]# ./kafka-topics --describe --zookeeper <zookeeper>:2181 --topic topicname

Topic:topicname PartitionCount:1    ReplicationFactor:3 Configs:
    Topic: topicname    Partition: 0    Leader: 2   Replicas: 2,3,1 Isr: 3,2,1
...