我们让kafka connect运行一个postgres连接器，它从数据库中提取更改并将它们放入主题中。我们得到一个错误 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) 我们已经验证了这个主题的存在，对这个主题做一个描述给我们这个

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