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

拼搏现实的明天。 2022-09-10 04:29 184阅读 0赞

参考官方文档，一步步执行  
[https://kafka.apache.org/documentation/\#quickstart][https_kafka.apache.org_documentation_quickstart]

（1）下载最新版Kafka

[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/

（2）启动Kafka环境  
先启动内置的Zookeeper

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

再打开一个终端创建，启动Kafka环境

[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

（3）创建一个topic  
重新打开一个终端窗口

[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]#

（4）启动生产者发送消息

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

（5）启动消费者消费消息

连接成功
    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

![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA56iL6KOV5by6_size_20_color_FFFFFF_t_70_g_se_x_16]

（6）测试完成，清理环境  
通过CTRL+C键即可停止环境，请注意先后顺序。

1.  停止生产者和消费者
2.  停止Kafka broker
3.  停止Zookeeper

最后再删除数据目录

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

[https_kafka.apache.org_documentation_quickstart]: https://kafka.apache.org/documentation/#quickstart
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA56iL6KOV5by6_size_20_color_FFFFFF_t_70_g_se_x_16]: /images/20220829/bfb1de96927647e9b69e5c321e875e95.png