2 Kafka 的安装与使用(单机版)
2.1 安装Kafka
2.1.1 官网下载一个需要的(最新的)版本
2.1.2 解压
tar -zxvf kafka_2.11-2.1.1.tgz
2.1.3 修改配置文件
- vim config/server.properties
- 将 broker.id 设置为1
- 修改 log.dirs 路径
2.1.4 使用(进入到 kafka 的根目录下)
启动 zookeeper
bin/zookeeper-server-start.sh -daemon config/zookeeper.properties
说明 zk 启动成功
启动 kafka
bin/kafka-server-start.sh config/server.properties
创建 topic
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic javaedge_ad_test_x
显示已有 topic
bin/kafka-topics.sh --list --zookeeper localhost:2181
写消息,开启生产者
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic javaedge_ad_test_x
另启一个终端
- 读消息,开启消费者
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic javaedge_ad_test_x --from-beginning
生产者端生成消息
生产者端收到消息
查看 topic 详情
