Kafka(官网地址)专为分布式高吞吐量系统而设计。 Kafka每每工做得很好,做为一个更传统的消息代理的替代品。 与其余消息传递系统相比,Kafka具备更好的吞吐量,内置分区,复制和固有的容错能力,这使得它很是适合大规模消息处理应用程序。html
一、java运行环境安装,网上不少教程,这里就不作具体介绍了java
二、下载kafka(地址)apache
三、解压到指定路劲,如:E:\kafka(注意路劲不能包含空格)bootstrap
四、启动zookeeper:运行cmd命令行,定位到E:\kafka,运行命令:.\bin\windows\zookeeper-server-start.bat .\config\zookeeper.propertieswindows
五、启动kafka:运行cmd命令行,定位到E:\kafka,运行命令:.\bin\windows\kafka-server-start.bat .\config\server.properties分布式
六、建立topic:运行cmd命令行,定位到E:\kafka\bin\windows,运行命令:kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test工具
七、建立producer:运行cmd命令行,定位到E:\kafka\bin\windows,运行命令:kafka-console-producer.bat --broker-list localhost:9092 --topic test测试
八、建立consumer:运行cmd命令行,定位到E:\kafka\bin\windows,运行命令:kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginningspa
九、在producer窗口下输入信息进行测试,每输入一行回车后消息立刻就会出如今consumer中,代表kafka已经安装测试成功命令行
借助可视化客户端工具 kafka tool,下载地址