ubuntu 安装 kafka

下载

点击
自己可以自选版本

下载好了，解压即可

启动服务

Kafka使用Zookeeper，我已经安装启动起来了
没有安装的点击
目录切换到bin目录，已经习惯这一层了

./kafka-server-start.sh ../config/server.properties

启动不报错即成功

创建topic

为了测试方便，此时我新开一个窗口，切换到kafka这一级目录

创建队列

bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

创建好之后，可以通过运行以下命令，查看已创建的topic信息：

 bin/kafka-topics.sh --list --zookeeper localhost:2181

发送消息

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

为了看直观的效果，我们在起一个窗口，还是切换到这一级目录
作为消费者

订阅消息

bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

效果如下图

管理工具

下载 KafkaOffsetMonitor-assembly-0.2.0 包

执行以下命令

java -cp KafkaOffsetMonitor-assembly-0.2.0.jar com.quantifind.kafka.offsetapp.OffsetGetterWeb --zk 127.0.0.1:2181 --port 8086 --refresh 10.seconds --retain 2.days

参考 http://orchome.com/6