Kafka学习之（二）Centos下安装Kafka详解程序员

# wget https://archive.apache.org/dist/kafka/0.10.1.0/kafka_2.10-0.10.1.0.tgz 
# tar zxvf kafka_2.10-0.10.1.0.tgz 
# mv ./kafka_2.10-0.10.1.0 /usr/local/kafka 
# cd /usr/local/kafka/config/

# vim zookeeper.properties   #编辑zookeeper配置文件 
#---------------------------------------------------------# 
dataDir=/tmp/zookeeper 
# the port at which the clients will connect 
#客户端端口2181，也就是通过zookeeper启动kafka的时候，指定端口号 
clientPort=2181 
# disable the per-ip limit on the number of connections since this is a non-production config 
maxClientCnxns=0

# vim server.properties   #编辑kafka配置文件 
#------------------------------------------------------# 
listeners=PLAINTEXT://127.0.0.1:9092

# ./bin/zookeeper-server-start.sh ./config/zookeeper.properties   #启动zookeeper 
# ./bin/kafka-server-start.sh config/server.properties            #打开新终端启动kafka

[[email protected] ~]# netstat -tunlp | grep 9092 
tcp        0      0 ::ffff:127.0.0.1:9092       :::*                        LISTEN      3092/java 

# bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic mytest --from-beginning  //消费的集群--zookeeper  localhost:2181 zookeeper端口地址  --topic mytest   监听的主题 
#--from-beginning   从开头监听 

Using the ConsoleConsumer with old consumer is deprecated and will be removed in a future major release. Consider using the new consumer by passing [bootstrap-server] instead of [zookeeper].

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