Kafka集群(2.8.0版本)快速入门

[root@node1 app]# tar -zxvf kafka_2.13-2.8.0.tgz
[root@node1 app]# mv kafka_2.13-2.8.0 kafka-2.8.0
[root@node1 app]# cd kafka-2.8.0/

[root@node1 kafka-2.8.0]# bin/zookeeper-server-start.sh config/zookeeper.properties

[root@node1 ~]# cd /app/kafka
kafka_2.13-2.8.0.tgz  kafka-2.8.0/          
[root@node1 ~]# cd /app/kafka-2.8.0/
[root@node1 kafka-2.8.0]# bin/kafka-server-start.sh config/server.properties

[root@node1 kafka-2.8.0]# bin/kafka-topics.sh --create --topic quickstart-events --bootstrap-server localhost:9092
Created topic quickstart-events.
[root@node1 kafka-2.8.0]# bin/kafka-topics.sh --describe --topic quickstart-events --bootstrap-server localhost:9092
Topic: quickstart-events        TopicId: E3JG3XNrTpapreJwaD4UdQ PartitionCount: 1       ReplicationFactor: 1    Configs: segment.bytes=1073741824
        Topic: quickstart-events        Partition: 0    Leader: 0       Replicas: 0     Isr: 0
[root@node1 kafka-2.8.0]# 

[root@node1 kafka-2.8.0]# bin/kafka-console-producer.sh --topic quickstart-events --bootstrap-server localhost:9092
>hi
>hello
>

连接成功
Last login: Sat Sep  4 10:44:11 2021 from 192.168.9.1
[root@node1 ~]# cd /app/kafka-2.8.0/
[root@node1 kafka-2.8.0]# bin/kafka-console-consumer.sh --topic quickstart-events --from-beginning --bootstrap-server localhost:9092
hi
hello

[root@node1 kafka-2.8.0]# rm -rf /tmp/kafka-logs /tmp/zookeeper