kafka的使用

Kafka的安装

1. wget https://archive.apache.org/dist/kafka/2.5.1/kafka_2.12-2.5.1.tgz下载安装包
2. tar -zxvf kafka_2.12-2.5.1.tgz解压
3. sh bin/zookeeper-server-start.sh config/zookeeper.properties > zookeeper.out 2>&1 &后台启动zookeeper
4. sh bin/kafka-server-start.sh config/server.properties > logs/kafka.log 2>&1 &后台启动kafka server
5. jps查看进程

Kafka的使用

• sh bin/kafka-topics.sh --list --zookeeper localhost:2181查看kafka中的topic信息
• sh bin/kafka-topics.sh --create --zookeeper localhost:2181 --topic test-kafka --partitions 2 --replication-factor 1新建topic
• sh bin/kafka-topics.sh --list --zookeeper localhost:2181查看topic列表
• sh bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic test-kafka查看topic信息
• sh bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test-kafka启动produce控制台
• sh bin/kafka-console-consumer.sh -bootstrap-server localhost:9092 --topic test-kafka --from-beginning启动consumer控制台