标签：tst rop span kafka集群 bsp event long pre events
1、获取Kafka
2、解压Kafka
$ tar -xzf kafka_2.13-2.7.0.tgz $ cd kafka_2.13-2.7.0
3、启动zk（Kafka包中自带zk程序和配置文件）
配置ZK的日志路径
# Start the ZooKeeper service # Note: Soon, ZooKeeper will no longer be required by Apache Kafka. $ bin/zookeeper-server-start.sh config/zookeeper.properties
4、启动Kafka
配置ZK的日志路径：分区持久化位置
# Start the Kafka broker service $ bin/kafka-server-start.sh config/server.properties
5、创建topic（未指定分区数和副本数）
$ bin/kafka-topics.sh --create --topic quickstart-events --bootstrap-server localhost:9092
6、查看topic分区
$ bin/kafka-topics.sh --describe --topic quickstart-events --bootstrap-server localhost:9092 Topic:quickstart-events PartitionCount:1 ReplicationFactor:1 Configs: Topic: quickstart-events Partition: 0 Leader: 0 Replicas: 0 Isr: 0
7、发送消息（生产者）
$ bin/kafka-console-producer.sh --topic quickstart-events --bootstrap-server localhost:9092 This is my first event This is my second event
8、接收消息（消费者）
$ bin/kafka-console-consumer.sh --topic quickstart-events --from-beginning --bootstrap-server localhost:9092 This is my first event This is my second event
标签：tst rop span kafka集群 bsp event long pre events
原文地址：https://www.cnblogs.com/clarino/p/14370471.html
