kafka安装

tar -zxvf /root/soft/kafka_2.11-1.1.1.tgz -C /app/

#broker.id=0 每台服务器的broker.id都不能相同

#hostname
host.name=1.2.3.251

#在log.retention.hours=168 下面新增下面三项
message.max.byte=5242880
default.replication.factor=2
replica.fetch.max.bytes=5242880

#设置zookeeper的链接端口
zookeeper.connect=1.2.3.251:2181,1.2.3.252:2181,1.2.3.253:2181

 

nohup /app/kafka_2.11-1.1.1/bin/kafka-server-start.sh /app/kafka_2.11-1.1.1/config/server.properties > /dev/null 2>&1 &

nohup /app/kafka_2.11-1.1.1/bin/kafka-server-start.sh /app/kafka_2.11-1.1.1/config/server.properties > /app/kafka_2.11-1.1.1/bin/aa.txt &

建立topic
kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test3

查看topic
kafka-topics.sh --list --zookeeper localhost:2181 --list
kafka-topics.sh --zookeeper localhost:2181 --describe

生产者建立
kafka-console-producer.sh --broker-list localhost:9092 --topic test3

消费者建立
kafka-console-consumer.sh --zookeeper localhost:2181 --topic test3 --from-beginning

删除topic: delete.topic.enable=true
kafka-topics --delete --zookeeper localhost:2181 --topic test

ln -s -f /usr/java/jdk1.7.0_67/bin/jps jps

 

须要修改中止脚本

如何一键启停全部机器进程：须要从一台机器ssh到其它机器，ssh hostother jps. 报错jps找不到
解决：在远程主机上加一个jps的连接 ln -s -f /usr/java/jdk1.8.0_45/bin/jps jps 就能够找到了

生产者不能发送消息