小编not*_*x0x的帖子

Kafka Consumer收不到消息

我是卡夫卡的新手。我在网上看了很多制作Kafka Producer和Kafka Consumer的说明。我成功地完成了前者,它可以向 Kafka 集群发送消息。然而,我没有完成后一项。请帮助我解决这个问题。我看到我的问题就像 StackOverflow 上的一些帖子一样,但我想描述得更清楚。我在 Virtual Box 上的 Ubuntu 服务器上运行 Kafka 和 Zookeeper。使用最简单的配置(几乎默认),即 1 个 Kafka 集群和 1 个 Zookeeper 集群。

1.当我使用Kafka的命令行作为生产者和消费者时,例如:

* Case 1: It works. I can see the word: Hello, World on the screen

$~/kafka/bin/kafka-topics.sh --zookeeper localhost:2181 --create --topic helloKafka --partitions 1 --replication-factor 1.
$echo "Hello, World" | ~/kafka/bin/kafka-console-producer.sh --broker-list localhost:9092 --topic TutorialTopic > /dev/null.
$~/kafka/bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic TutorialTopic --from-beginning.
Run Code Online (Sandbox Code Playgroud)

2.当我使用Kafka的Producer和命令行作为consumer时,例如:

* Case 2: It works. I can see the messages which sent from …
Run Code Online (Sandbox Code Playgroud)

kafka-consumer-api

4
推荐指数
1
解决办法
2万
查看次数

标签 统计

kafka-consumer-api ×1