设置KAFKA
Kafka 设置
2023-09-14 08:57:38 时间
让我们继续下载并设置Kafka,启动zookeeper,集群,生产者和消费者。
![](https://cdn-images-1.medium.com/max/1600/1*SoupHxblBS5FaAkibDX_Qg.png)
- 要下载Kafka,请参阅此链接
http://kafka.apache.org/downloads.html - 下载后,解压缩然后切换到目录
tar -xzf kafka_2.9.1-0.8.2.2.tgz
cd kafka_2.9.1-0.8.2.2
- 由于Kafka使用Zookeeper,所以首先需要启动它,请按照以下步骤操作:
sh bin/zookeeper-server-start.sh config/zookeeper.properties
- 现在启动Kafka服务器:
sh bin/kafka-server-start.sh config/server.properties
- 一旦服务器启动,我们现在需要创建一个主题,说“测试”
sh bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
- 要检查主题是否已成功创建,请使用list命令:
sh bin/kafka-topics.sh --list --zookeeper localhost:2181
- 现在让我们开始生产者和消费者,如下所述:
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test
- 现在通过在Producer控制台上键入它来发送一些消息,一旦按下输入,相同的消息应该是消费者控制台上的消费者。
生成器生成的消息在Consumer上消耗后,表明您正确设置了Kafka。
相关文章
- 修改kafka broker.id
- kafka学习之-雅虎开源管理工具Kafka Manager
- 使用shell读取文本文件发送到kafka
- KAFA 监测| Kafka监测的方法和工具
- Kafka工具教程 - Apache Kafka中的2个重要工具
- Kafka压测— 搞垮kafka的方法(转)
- kafka发送及消费消息示例
- kafka详解一、Kafka简介
- 云图说丨初识分布式消息服务Kafka版
- 华山论“件”:Kafka、RabbitMQ、RocketMQ技能大比拼
- KAFKA EAGLE 监控MRS kafka之操作实践
- Kafka Topic Partition Offset 这一长串都是啥?
- 来吧,1分钟带你玩转Kafka
- apache kafka监控系列-KafkaOffsetMonitor
- kafka技术要点
- kafka.common.KafkaException: Failed to acquire lock on file .lock in /tmp/kafka-logs. A Kafka instance in another process or thread is using this directory.
- docker-搭建 kafka+zookeeper集群
- 解开Kafka神秘的面纱(一):kafka架构与应用场景