java - 我可以在同一台服务器上运行kafka生产者和消费者吗

标签 java apache-kafka kafka-producer-api

我是 kafka 新手,正在尝试学习如何在同一台机器上实现 kafka 生产者和消费者,但无法理解如何继续进行。我希望生产者和消费者同时运行。有人可以帮我解决这个问题吗?

最佳答案

首先您需要下载 Kafka tar 文件并解压。 然后进入bin目录并执行以下命令。 注意:生产者和消费者命令必须在不同的选项卡中运行,以便在一个选项卡中您可以生成 json,而在其他选项卡中您可以在控制台上使用。

创建主题:

kafka_2.12-0.11.0.0/bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 3 --topic test_topic

在控制台上运行 Producer

kafka-console-producer.sh --broker-list localhost:9092 --topic test_topic

在控制台上运行消费者

kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test_topic --from-beginning

关于java - 我可以在同一台服务器上运行kafka生产者和消费者吗,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/57157051/

相关文章:

java - AsyncTask - 如何在 onPostExecute 之后将值传递回 Activity 类?

java - Aws Lambda 访问 META-INF/MANIFEST.MF?

apache-kafka - Kafka - 无法建立到节点 -1 的连接

apache-spark - 群组成员支持的协议(protocol)与现有成员的协议(protocol)不兼容

java - 使用出站适配器配置断路器以处理连接超时问题

java - Kafka Avro 序列化程序 : org. apache.avro.AvroRuntimeException:未打开

java - 如何理解java中的注释以及如何在java中实现我的注释?

java - 双倍乘法与加法速度

spring-boot - Camel 上下文在应用程序启动后立即启动关闭,没有明显的错误

apache-kafka - 信息客户端/127.0.0.1 :48452 which had sessionid 0x15698f5ac360001 (org. apache.zookeeper.server.NIOServerCnxn 的已关闭套接字连接)