Apache Kafka是一个开源的分布式事件流处理系统。它基本上是一个事件流平台,可以发布、订阅、存储和处理记录流。
Kafka为实时数据处理提供了一个高吞吐量和低延迟的平台。基本上,Kafka实现了发布-订阅模型,生产者应用程序将事件发布到Kafka,而消费者应用程序订阅这些事件。
在本教程中,我们将学习如何使用Kafka消费者API从Kafka主题的开始读取数据。
2. 设置
在我们开始之前,让我们首先设置依赖项,初始化Kafka集群连接,并在Kafka中发布一些消息。
Kafka提供了一个方便的Java客户端库,我们可以使用它来执行Kafka集群的各种操作。
大约 5 分钟