Kafka 基本操作
下载：
- zookeeper:
wget https://mirrors.tuna.tsinghua.edu.cn/apache/zookeeper/zookeeper-3.4.14/zookeeper-3.4.14.tar.gz
|
- kafka:
wget http://mirrors.tuna.tsinghua.edu.cn/apache/kafka/2.2.0/kafka_2.11-2.2.0.tgz
|
解压:
tar -zxvf zookeeper-3.4.14.tar.gz
tar -zxvf kafka_2.11-2.2.0.tgz
|
配置：
1. zookeeper
配置
cd zookeeper-3.4.14/config
cp zoo_sample.cfg zoo.cfg
|
启动
连接测试，zookeeper 默认启动端口2181
./bin/zkCli.sh -server 127.0.0.1:2181
|
2.kafka
创建日志目录 替换临时日志目录
cd ../kafka_2.11-2.2.0/
mkdir logs
|
修改配置文件
vim config/server.properties
|
修改配置文件中21、31、36和60行如下
broker.id=1
listeners=PLAINTEXT://:9092
advertised.listeners=PLAINTEXT://127.0.0.1:9092
log.dirs=/opt/soft/kafka_2.11-2.2.0/logs
|
后台启动kafka
nohup ./bin/kafka-server-start.sh config/server.properties 1>/dev/null 2>&1 &
|
操作
./bin/kafka-topics.sh --create --zookeeper 127.0.0.1:2181 --replication-factor 1 --partitions 1 --topic weibo
|
./bin/kafka-topics.sh --list --zookeeper 127.0.0.1:2181
|
./bin/kafka-console-producer.sh --broker-list 127.0.0.1:9092 --topic weibo
|
./bin/kafka-console-consumer.sh --bootstrap-server 127.0.0.1:9092 --topic weibo
|
./bin/kafka-topics.sh --describe --zookeeper 127.0.0.1:2181 --topic weibo
|
./bin/kafka-topics.sh --delete --zookeeper 127.0.0.1:2181 --topic weibo
|
实例
可以开启两个窗口，一个用作生产者生产消息，一个用作消费者监听topic消费消息
若你觉得我的文章对你有帮助，欢迎点击上方按钮对我打赏
