KAFKA控制台消费者未从控制台生产商那里接收消息

Question

i最近使用docker image和设置kafka parcel设置了Cloudera QuickStartVM。成功安装后，我看到所有服务都处于绿色状态(包括Kafka和Zookeeper(。但是，当我遵循Kafka CLI的以下命令时，我看不到消费者收到消息。

任何帮助将受到极大的赞赏CDHV 5.13CDK 4.0(Kafka 2.1( - 通过包裹。

kafka-topics --create quickstart.cloudera:9092 --replication-factor 1 --partitions 1 --topic test3 --zookeeper quickstart.cloudera:2181

主题在控制台上成功创建。

Console Consumer (CLI terminal 1):
kafka-console-consumer --bootstrap-server quickstart.cloudera:9092 --topic test3

消费者在终端1

的控制台上启动

Console Producer:
kafka-console-producer --broker-list  quickstart.cloudera:9092 --topic test3

在终端2中创建的生产商。现在，当我在终端2(生产者(控制台中键入任何内容时，消费者终端不会显示任何内容。

请建议这里缺少什么。我不确定如何调试这种情况。

我在/var/log/kafka/kafka-broker-quickstart.cloudera.log file

中没有看到任何例外

19/05/07 09:18:28 INFO zookeeper.ClientCnxn: Socket connection established, initiating session, client: /172.17.0.2:60968, server: quickstart.cloudera/172.17.0.2:2181
19/05/07 09:18:28 INFO zookeeper.ClientCnxn: Session establishment complete on server quickstart.cloudera/172.17.0.2:2181, sessionid = 0x16a915bca140112, negotiated timeout = 30000
19/05/07 09:18:28 INFO zookeeper.ZooKeeperClient: [ZooKeeperClient] Connected.
Topic:test4     PartitionCount:1        ReplicationFactor:1     Configs:
        Topic: test4    Partition: 0    Leader: 37      Replicas: 37    Isr: 37
19/05/07 09:18:28 INFO zookeeper.ZooKeeperClient: [ZooKeeperClient] Closing.
19/05/07 09:18:28 INFO zookeeper.ClientCnxn: EventThread shut down
19/05/07 09:18:28 INFO zookeeper.ZooKeeper: Session: 0x16a915bca140112 closed
19/05/07 09:18:28 INFO zookeeper.ZooKeeperClient: [ZooKeeperClient] Closed.

这是

的输出

kafka-topics --zookeeper quickstart.cloudera:2181 --describe --topic test3

Answer 1

iff使用Cloudera Quickstart VM，在Cloudera Manager-> Kafka配置中，更改偏移量提交commit主题复制因子(offsets.topic.replication.factor.factor(到1

Answer 2

我卸下了CDK4.0包裹，而是添加了CDK 3.1包裹。现在，控制台消费者正在工作。不确定CDK 4.0有什么问题。CDK 3.1带有Kafka 1.0.1