【Kafka】2-启动Kafka集群
时间:2021-02-04 12:16:31
收藏:0
阅读:0
单机启动
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
集群场景的配置
评论(0)