先自我介绍一下，小编浙江大学毕业，去过华为、字节跳动等大厂，目前阿里P7
深知大多数程序员，想要提升技能，往往是自己摸索成长，但自己不成体系的自学效果低效又漫长，而且极易碰到天花板技术停滞不前！
既有适合小白学习的零基础资料，也有适合3年以上经验的小伙伴深入学习提升的进阶课程，涵盖了95%以上大数据知识点，真正体系化！
由于文件比较多，这里只是将部分目录截图出来，全套包含大厂面经、学习笔记、源码讲义、实战项目、大纲路线、讲解视频，并且后续会持续更新
正文
- 配置生产者客户端参数：生产者需要指定broker的地址清单（bootstrap.servers），用于与Kafka集群建立连接。
- 创建生产者实例：根据配置参数，创建生产者实例。
- 构建待发送的消息：将要发送的消息封装为ProducerRecord对象，并指定要发送到的主题。
- 发送消息：使用生产者实例将消息发送到Kafka集群。
- 关闭生产者实例：在完成消息发送后，关闭生产者实例以释放资源。
Kafka生产者支持异步发送消息，允许应用程序继续执行其他任务而无需等待消息发送完成。如果发送消息失败，生产者会尝试重新发送消息几次，或者可以选择将错误传递给应用程序进行进一步处理。
2.1.1 连接Kafka
- 输入Bootstrap Servers、UserName、Password即可连接kafka服务端。
- 如果服务端未指定Passord，则不用输入Password。
- 连接时将在Message中显示连接结果。
2.1.2 生产消息
连接成功后，即可生产消息，其中Topic、Message为必填项，Key可为空，Type指定消息内容的格式，可为文本或JSON格式数据。
以下为示例消息：
2.2 消费者
Kafka消费者是负责从Kafka主题（topic）中读取消息的应用程序组件。消费者订阅感兴趣的主题，并从该主题中拉取消息进行处理。
在Kafka中，消费者通过消费者组（Consumer Group）进行管理，消费者组是一组共享相同消费者组名的消费者实例。消费者组负责将主题中的消息分配给组内的各个消费者实例进行消费。当主题中的消息量较大时，通过消费者组的扩展，可以实现消息的分布式消费，提高系统的吞吐量和可用性。
消费者客户端开发包括以下步骤：
- 配置消费者客户端参数：指定broker的地址清单（bootstrap.servers），用于与Kafka集群建立连接。此外，还需要指定消费者的组名、自动提交偏移量（auto.commit.enable）等参数。
- 创建消费者实例：根据配置参数，创建消费者实例。
- 订阅主题：使用subscribe（）方法订阅感兴趣的主题。消费者可以订阅一个或多个主题，也可以使用正则表达式订阅特定模式的主题。
- 处理消息：在消息拉取时，消费者从broker中读取消息，并进行处理。消费者可以使用pull模式或push模式来接收消息，其中pull模式允许消费者根据自身消费能力以适当速率消费消息，而push模式则由broker主动将消息推送给消费者。
- 提交偏移量：在处理完每条消息后，消费者需要提交偏移量（offset），以便在下次消费时从正确的位置继续读取。提交偏移量可以保证消息被可靠地处理且只被处理一次。
- 关闭消费者实例：在完成消息处理后，关闭消费者实例以释放资源。
2.2.1 连接Kafka
- 输入Bootstrap Servers、UserName、Password即可连接kafka服务端。
- 如果服务端未指定Passord，则不用输入Password。
- 如果未指定GroupId，将会默认设置为default-consumer。
- 连接时将在Message中显示连接结果。
2.2.2 消费消息
连接成功后，即可消费消息，其中Topic必填项。
以下为示例消息：
Kafka生产者和消费者工具是专门为处理Apache Kafka消息队列而设计的强大工具。这两个工具共同协作，一个用于将信息发送到Kafka集群，另一个用于从集群中接收信息。
网上学习资料一大堆，但如果学到的知识不成体系，遇到问题时只是浅尝辄止，不再深入研究，那么很难做到真正的技术提升。
一个人可以走的很快，但一群人才能走的更远！不论你是正从事IT行业的老鸟或是对IT行业感兴趣的新人，都欢迎加入我们的的圈子（技术交流、学习资源、职场吐槽、大厂内推、面试辅导），让我们一起学习成长！
308103)]