前言
在之前的篇章中，我们探讨了关于kafka的生产端的相关理论知识，本篇结合代码来演示下，在java代码中，如何消费某个topic的数据
环境准备
1、提前安装好kafka服务（单机或集群均可）
2、提前创建一个测试使用的topic，本例创建了一个3分区3副本的 名称为“zcy234”的一个topic
代码演示
1、引入依赖
<dependency>
<groupId>org.apache.kafka</groupId>
<artifactId>kafka-clients</artifactId>
<version>3.0.0</version>
</dependency>2、生产端代码
创建一个生产者类，可以之直接使用之前的生产者发送的代码逻辑即可
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 举报，一经查实，本站将立刻删除。
文章由极客之音整理，本文链接：https://www.bmabk.com/index.php/post/143305.html
