Kafka

一、概述

Kafka(官网地址)专为分布式高吞吐量系统而设计。 Kafka往往工作得很好,作为一个更传统的消息代理的替代品。 与其他消息传递系统相比,Kafka具有更好的吞吐量,内置分区,复制和固有的容错能力,这使得它非常适合大规模消息处理应用程序。

二、环境搭建(windows)

1、java运行环境安装,网上很多教程,这里就不做具体介绍了

2、下载kafka(地址

3、解压到指定路劲,如:E:kafka(注意路劲不能包含空格)

4、启动zookeeper:运行cmd命令行,定位到E:kafka,运行命令:.inwindowszookeeper-server-start.bat .configzookeeper.properties

5、启动kafka:运行cmd命令行,定位到E:kafka,运行命令:.inwindowskafka-server-start.bat .configserver.properties

6、创建topic:运行cmd命令行,定位到E:kafkainwindows,运行命令:kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

7、创建producer:运行cmd命令行,定位到E:kafkainwindows,运行命令:kafka-console-producer.bat --broker-list localhost:9092 --topic test

8、创建consumer:运行cmd命令行,定位到E:kafkainwindows,运行命令:kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning

9、在producer窗口下输入信息进行测试,每输入一行回车后消息马上就会出现在consumer中,表明kafka已经安装测试成功

 

三、可视化工具

借助可视化客户端工具 kafka tool,下载地址

原文地址:https://www.cnblogs.com/xxinwen/p/10683416.html