centos kafka單包單機部署
阿新 • • 發佈：2017-06-08
centos kafka單包單機部署
kafka下載地址
http://kafka.apache.org/downloads.html
在這裏下載kafka_2.11-0.10.0.0.tgz，kafka和zookeeper都用同一個包裏的
安裝和配置jdk(略過)
JAVA_HOME=/opt/jdk1.8.0_131 CLASSPATH=.:$JAVA_HOME/lib.tools.jar PATH=$JAVA_HOME/bin:$PATH export JAVA_HOME CLASSPATH PATH $ java -version java version "1.8.0_131" Java(TM) SE Runtime Environment (build 1.8.0_131-b11) Java HotSpot(TM) Server VM (build 25.131-b11, mixed mode)
解壓後kafka_2.11-0.10.0.0.tgz，
先配置zookeeper
$cd kafka_2.11-0.10.0.0 $vi config/zookeeper.properties dataDir=/data/programs/kafka_2.11-0.10.0.0/data dataLogDir=/data/programs/kafka_2.11-0.10.0.0/logs clientPort=2181 maxClientCnxns=100 tickTime=2000 initLimit=10 配置後直接啟動zookeeper $bin/zookeeper-server-start.sh config/zookeeper.properties 如果沒有報錯,可以轉後臺啟動 $nohup bin/zookeeper-server-start.sh config/zookeeper.properties &
再配置kafka
$ vi config/server.properties broker.id=0 port=9092 host.name=192.168.12.105 num.network.threads=3 num.io.threads=8 socket.send.buffer.bytes=102400 socket.receive.buffer.bytes=102400 socket.request.max.bytes=104857600 log.dirs=/data/logs/kafka num.partitions=2 num.recovery.threads.per.data.dir=1 log.retention.check.interval.ms=300000 zookeeper.connect=localhost:2181 zookeeper.connection.timeout.ms=6000 啟動kafka $ bin/kafka-server-start.sh config/server.properties 如果沒有報錯,可以轉後臺啟動 $nohup bin/kafka-server-start.sh config/server.properties &
測試kafka
1、創建topic $bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test 2、查看創建的topic $ bin/kafka-topics.sh -list -zookeeper localhost:2181 test 3、生產消息測試 $bin/kafka-console-producer.sh --broker-list 192.168.12.105:9092 --topic test this is test #輸入後回車 4、消費消息測試 $bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning this is test
完成以上代表kafka單包機安裝成功。
本文出自 “xiangcun168” 博客，請務必保留此出處http://xiangcun168.blog.51cto.com/4788340/1933375
centos kafka單包單機部署