kafka需要java环境，以前的kafka需要zookeeper，现在的版本中内置了zookeeper环境，可直接使用，以下是使用独立的zookeeper进行部署
一、下载zookeeper
wget https://mirrors.bfsu.edu.cn/apache/zookeeper/zookeeper-3.6.2/apache-zookeeper-3.6.2-bin.tar.gz
tar -zxvf apache-zookeeper-3.6.2-bin.tar.gz
cp zoo_sample.cfg zoo.cfg
vim zoo.cfg
二、启动zookeeper
./zkServer.sh start #启动命令
./zkServer.sh stop #停止命令
三、下载kafka
wget https://mirror.bit.edu.cn/apache/kafka/2.6.0/kafka_2.13-2.6.0.tgz
tar -xzf kafka_2.13-2.6.0.tgz
vim server.properties
注：listeners和advertised.listeners的端口需要配置内网IP，java连接时，需要开通9092端口，否则连接不成功。修改后重新启动zookeeper，再重启kafka
四、启动
./kafka-server-start.sh -daemon ../config/server.properties
五、测试kafka是否正常
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
创建一个名为test的topic
在创建topic后可以通过输入
bin/kafka-topics.sh --list --zookeeper localhost:2181
来查看已经创建的topic
打开终端，输入bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test在执行完毕后会进入的编辑器页面，进行发送消息
再打开一个终端，输入
bin/kafka-console-consumer.sh --bootstrap-server 127.0.0.1:9092 --topic test --from-beginning
可以创建一个用于消费topic为test的消费者
五、创建生产者和消费者进行测试
参考文档API
http://kafka.apache.org/26/javadoc/index.html?org/apache/kafka/streams/KafkaStreams.html
生产者类KafkaProducer
消费者类KafkaConsumer
六、java 生产者
六、java 消费者
在测试过程中，若消费者提示错误，可用内置的zookeeper启动来进行测试
bin/zookeeper-server-start.sh config/zookeeper.properties &
bin/kafka-server-start.sh config/server.properties &
网友评论