kafka学习笔记

配置kafka

服务器环境

Ubuntu 17.10

启动kafka服务器

nohup作为后台进程执行独立的shell session

nohup bin/kafka-server-start.sh config/server.properties > kafka.log 2>&1 &

tail -f kafka.log

 测试：

创建一个kafka生产者

echo "Hello,World" | bin/kafka-console-producer.sh --broker-list localhost:9092 --topic Topic_1 > producer

创建一个kafka消费者

sh bin/kafka-console-consumer.s h --zookeeper localhost:2181 --topic Topic_1 --from-beginning