java——spring boot集成kafka——单节点示例

落日映苍穹つ 2023-09-30 21:03 80阅读 0赞

首先安装一个zk。然后再安装kafka：

![5ee1f19770a859bed303fb1c3fcfb96d.png][]

执⾏以下命令创建名为“test”的topic，这个topic只有⼀个partition，并且备份因⼦也设置为1：

然后在kafka节点下，执行如下命令：

**./kafka-topics.sh** **--create --zookeeper** **172****.16.253.35:2181** **--replicationfactor** **1** **--partitions** **1** **--topic** **test**

**含义：副本为1；分区为1；主题为test；**

**(1)、replicationfactor——副本；**

**(2)、partitions——分区；**

**(3)、topic——主题；**

\-------------------------------------------------------------------------------------------------------------------------------------------------

然后，查看当前kafka内有哪些topic，执行如下命令：

**./kafka-topics.sh** **--list --zookeeper** **172****.16.253.35:2181**

======================================================================================================

**发送消息**

kafka⾃带了⼀个producer命令客户端，可以从本地⽂件中读取内容，或者我们也可以以命令⾏中直接输⼊内容，并将这些内容以消息的形式发送到kafka集群中。

在默认情况下，每⼀个⾏会被当做成⼀个独⽴的消息。使⽤kafka的发送消息的客户端，指定发送到的kafka服务器地址和topic

**./kafka-console-producer.sh \--broker-list 172.16.253.38:9092 \--topic test**

=============================================================================================================================

**消费消息**

对于consumer， kafka同样也携带了⼀个命令⾏客户端，会将获取到内容在命令中进⾏输出， 默认是消费最新的消息。

使⽤kafka的消费者消息的客户端，从指定kafka服务器的指定topic中消费消息

\------------------------------------------------------------------------------------------------------------------------------------------------------------------

⽅式⼀：从最后⼀条消息的偏移量\+1开始消费

**./kafka-console-consumer.sh \--bootstrap-server 172.16.253.38:9092 \--topic test**

\----------------------------------------------------------------------------------------------------------------------------------------------------------------------

⽅式⼆：从头开始消费

**./kafka-console-consumer.sh \--bootstrap-serve*r 172.16.253.38:9092 \--**from-beginning --topic test***

===============================================================================================================

⼏个注意点：

(1)、消息会被存储  
(2)、消息是顺序存储  
(3)、消息是有偏移量的  
(4)、消费时可以指明偏移量进⾏消费

=====================================================================================================

![7282c73b042013e49ede0662b89b26be.png][]

![31661a3e0312a805bd7da1222d66b248.png][]

![98e50b86de8af724d86739e8a106c0f6.png][]

![ee990d8c4cb23caf8cda8e925327731d.png][]

[5ee1f19770a859bed303fb1c3fcfb96d.png]: https://img-blog.csdnimg.cn/img_convert/5ee1f19770a859bed303fb1c3fcfb96d.png
[7282c73b042013e49ede0662b89b26be.png]: https://img-blog.csdnimg.cn/img_convert/7282c73b042013e49ede0662b89b26be.png
[31661a3e0312a805bd7da1222d66b248.png]: https://img-blog.csdnimg.cn/img_convert/31661a3e0312a805bd7da1222d66b248.png
[98e50b86de8af724d86739e8a106c0f6.png]: https://img-blog.csdnimg.cn/img_convert/98e50b86de8af724d86739e8a106c0f6.png
[ee990d8c4cb23caf8cda8e925327731d.png]: https://img-blog.csdnimg.cn/img_convert/ee990d8c4cb23caf8cda8e925327731d.png