单机版kafka起到
时间: 2023-09-03 09:11:46 浏览: 106
kubernetes 部署单机版Kafka、zookeeper
单机版kafka的启动和配置步骤如下:
1. 下载并安装JDK1.8和kafka3.5。
2. 配置Java环境。
3. 部署kafka:下载kafka并解压,在解压后的kafka目录下进行以下操作。
4. 修改zookeeper配置:使用文本编辑器打开`config/zookeeper.properties`文件,根据需要进行配置修改。
5. 修改kafka配置:使用文本编辑器打开`config/server.properties`文件,根据需要进行配置修改。
6. 启动zookeeper:在终端中运行命令`/root/kafka/bin/zookeeper-server-start.sh /root/kafka/config/zookeeper.properties`。
7. 启动kafka:在终端中运行命令`/root/kafka/bin/kafka-server-start.sh /root/kafka/config/server.properties`。
8. 新建一个Topic:在终端中运行命令`/root/kafka/bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --topic test --partitions 1 --replication-factor 1`,其中`test`为Topic的名称。
9. 启动生产者:在终端中运行命令`/root/kafka/bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test`。
10. 启动消费者:在终端中运行命令`/root/kafka/bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test`。
11. 在生产者终端进行输入,即可测试单机版kafka的功能。 [1 [2 [3<span class="em">1</span><span class="em">2</span><span class="em">3</span>
#### 引用[.reference_title]
- *1* [linux部署单机kafka(使用kafka自带zookeeper)](https://blog.csdn.net/baidu_28551237/article/details/130291225)[target="_blank" data-report-click={"spm":"1018.2226.3001.9630","extra":{"utm_source":"vip_chatgpt_common_search_pc_result","utm_medium":"distribute.pc_search_result.none-task-cask-2~all~insert_cask~default-1-null.142^v93^chatsearchT3_2"}}] [.reference_item style="max-width: 50%"]
- *2* *3* [Kafka3.5单机部署与测试](https://blog.csdn.net/m0_57949886/article/details/131470919)[target="_blank" data-report-click={"spm":"1018.2226.3001.9630","extra":{"utm_source":"vip_chatgpt_common_search_pc_result","utm_medium":"distribute.pc_search_result.none-task-cask-2~all~insert_cask~default-1-null.142^v93^chatsearchT3_2"}}] [.reference_item style="max-width: 50%"]
[ .reference_list ]
阅读全文