1.kafka1，下载官网地址：http://kafka.apache.org/downloads下载：wgethttp://mirrors.hust.edu.cn/apache/kafka/0.11.0.2/kafka_2.11-0.11.0.2.tgz2，解压：tar-zxvfkafka_2.11-0.11.0.2.tgz3，修改配置文件在config目录下，可以看到很多配置文件，修改server.propertiesbroker。id=0#每个kafka节点的唯一标识listeners=PLAINTEXT://192.168.5.28:9092#监听端口log.dirs=/data/kafka-logs#日志地址zookeeper.connect=192.168.5.28:2181,192.168。5.29:2181,192.168.5.30:2181/kafka#zookeeper地址提示：zookeeper.connect=host:port默认存在zookeeper根目录，如果有特殊目录需要添加chroot，比如/kafka其他都是使用--zookeeper4，启动：。/bin/kafka-server-start.shconfig/server.properties1>/dev/null2>&1&5,测试命令5.1新建Topic./bin/kafka-topics.sh--create--zookeeper192.168。5.29:2181--replication-factor3--partitions1--topic30test5.2查看已有的Topic列表./bin/kafka-topics.sh--list--zookeeper192.168.5.28:2181,192.168.5.29:2181,192.168.5.30:21815.3查看指定Topic的状态./bin/kafka-topics.sh--describe--zookeeper192.168.5.28:2181,192.168.5.29:2181,192.168.5.30:2181--topic247test5.4查看所有主题状态./bin/kafka-topics.sh--describe--zookeeper192.168.5.28:2181,192.168.5.29:2181,192.168.5.30:21815.5启动消费者读取消息并输出到标准输出。/bin/kafka-console-consumer.sh--zookeeper192.168.5.28:2181,192.168.5.29:2181,192.168.5.30:2181--from-beginning--topic247test5.6Writedata(--broker-list不需要使用/kafka路径)./bin/kafka-console-producer.sh--broker-list192.168.5.28:9092--topic247test5.7删除主题(设置delete.topic.enable=true)./bin/kafka-topics.sh--delete--zookeeper192.168.5.28:2181,192.168.5.29:2181,192.168.5.30:2181--topic247test2.Kafka监控工具KafkaOffsetMonitor1。下载：wgethttps://github.com/quantifind...2.新建执行脚本：vimstart.sh脚本内容：（注意zk路径）#!/bin/bashjava-cpKafkaOffsetMonitor-assembly-0.2。1.jar\com.quantifind.kafka.offsetapp.OffsetGetterWeb\--zk192.168.5.28:2181,192.168.5.29:2181,192.168.5.30:2181/kafka\--port8088\--refresh10.seconds\--保留2.days3，执行权限chmod+xstart.sh4，启动./start.sh1>/dev/null2>&1&注意：页面默认使用ajax.googleapis.com的js库源，可能会下载失败。可以修改index.html文件，将库源改为国产库源vimKafkaOffsetMonitor-assembly-0.2.1.jar#进入jar包?offsetapp/index.html#找到index.html文件Enter#进入进入文件，修改为http://apps.bdimg.com/libs/angular.js/1.2。9/angular.js#编辑html文件，修改后保存退出。
