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 就能夠找到了

生產者不能發送消息