学习如何在本深入指南中构建简单有效的指南 Kafka Consumer,准备好释放 Kafka 强大的功能。消费者将从您在上一个教程中创建的 Kafka Producer 我们将引导您从检索消息中完成处理 Kafka 主题.
记录过程。了解同一组 Kafka 消费者如何分配和共享分区,确保每个分区消费者组收到相同数据的副本。
Cloudurable 专家 Jean-Paul Azar 提供 Kafka 培训课程、咨询服务、支持和在线课程 AWS 中设置 Kafka 帮助集群。本教程的先决条件
开始前请确保:
- 了解如何从命令行操作Kafka?
- 了解 Kafka 基础知识集群和故障转移
- 已经用 Java 创建了 Kafka Producer(查看我们以前的教程以获得分步指南)
这个教程是基于我们以前的教程 Kafka 教程:用 Java 创建 Kafka 在生产者的基础上,我们开发了一个简单的 Java 示例来创建 Kafka 生产者。我们还创建了一个名字 my-example-topic 的复制 Kafka 并使用主题 Kafka 生产者发送记录(同步和异步)。现在,你想要创建的消费者将使用这些信息。更多关于数据工程的信息,请访问我们的网站。
立即学习“Java免费学习笔记(深入);
构建 Kafka 消费者类似于生产者,您需要指定指导服务器并定义它 group.id,指定 Kafka 记录键反序列化器和记录值反序列化器,并为消费者订阅您在生产者教程中创建的主题。
以上是在几分钟内开始使用 Kafka:构建 Java 有关Consumer的详细信息,请关注图灵教育的其他相关文章!