1. 安装:

tar -zxvf kafka_2.9.2-0.8.1.1.tgz -C ~/training/

2. 修改配置文件:/root/training/kafka_2.9.2-0.8.1.1/config/server.properties

# The id of the broker. This must be set to a unique integer for each broker.
broker.id=0

############################# Socket Server Settings #############################

# The port the socket server listens on
port=9092
                        
log.dirs=/root/training/kafka_2.9.2-0.8.1.1/logs  #日志
zookeeper.connect=BigData11:2181

3. 启动kafka (默认.前提zookeeper 您已经启动)

bin/kafka-server-start.sh config/server.properties &

 3.1 创建topic

bin/kafka-topics.sh --create --zookeeper BigData11:2181 -replication-factor 1 --partitions 3 --topic mydemo1

3.2 接收消息

bin/kafka-console-consumer.sh --zookeeper BigData11:2181 --topic mydemo1

3.3 发送消息

bin/kafka-console-producer.sh --broker-list BigData11:9092 --topic mydemo1

 

 

 异常信息:

 Failed to acquire lock on file .lock in /root/training/kafka_2.9.2-0.8.1.1/logs. A Kafka instance in another process or thread is using this directory.

一般是异常退出重启时的异常信息,

解决方案: 

[root@BigData11 config]# netstat -lnp|grep 9092
tcp6       0      0 :::9092                 :::*                    LISTEN      52727/java

或者 jps

[root@BigData11 config]# jps
53346 ConsoleProducer
52727 Kafka
53016 ConsoleConsumer
52650 QuorumPeerMain
53050 ConsoleConsumer
53084 ConsoleProducer
53389 Jps

kill -9 kafka进程号即可