Kafka除了具备消息队列MQ的特性和使用场景外，它还有一个重要用途，就是做存储层。 用kafka做存储层，为什么呢？一大堆可以做数据存储的 M...

KafkaConsumer(消费者)每次调用 poll()方法，它总是返回由生产者写入 Kafka但还没有被消费者读取过的记录， 我们因 此可以...

应用程序使用 KafkaConsumer向 Kafka 订阅主题，并从订阅的主题上接收消息 。 从 Kafka 读取数据不同于从其他悄息系统读取...

在之前的例子里(Kafka生产者——向 Kafka写入数据)， ProducerRecord 对象包含了目标主题、键和值。 Kafka 的消息是...

不管是把 Kafka 作为消息队列、消息、总线还是数据存储平台来使用 ，总是需要有一个可以往 Kafka 写入数据的生产者和一个可以从 Kafk...

发布与订阅消息系统 在正式讨论Apache Kafka (以下简称Kafka)之前，先来了解发布与订阅消息系统的概念， 并认识这个系统的重要性。...