# kafka-test **Repository Path**: crazywolf/kafka-test ## Basic Information - **Project Name**: kafka-test - **Description**: kafka-test - **Primary Language**: Java - **License**: Not specified - **Default Branch**: master - **Homepage**: None - **GVP Project**: No ## Statistics - **Stars**: 0 - **Forks**: 0 - **Created**: 2016-02-02 - **Last Updated**: 2020-12-19 ## Categories & Tags **Categories**: Uncategorized **Tags**: None ## README #kafka入门篇(安装) ##安装zookeeper 加压后进入 conf目录中,修改 zoo_sample.cfg 为zoo.cfg 然后进入bin 目录 执行 ./zkServer.sh --config ../conf start ##安装 kafka 解压后进入根conf目录 修改 server.properties ,**打开host.name的注释** 然后回到gen目录执行后面命令,启动kafka bin/kafka-server-start.sh config/server.properties & ##测试producer bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test ##测试consumer bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning 在producer窗口输入任意文字回车,如果consumer窗口能展示文字 则表示kafka启动成功 **生产着给kafka发送消息必须使用主机名,不能直接使用ip发送**