日期:2020年5月20日

2020-05-20 0 By admin

Kafka 消息队列中主题和分区

主题和分区是 Kafka 的两个核心概念。 主题作为消息的归类,下面可以在细分一个或多个分区,为消息提供了二次分类。分区的划分提高了消息的可扩展性和伸缩性,还可以通过多副本机制为kafka做数据冗余以提高数据可靠性。 对kafka底层来说,主题和分区只是逻辑上的概念,分区可以有一至多个副本,每个副本…

2020-05-20 0 By admin

Kafka 服务中消费者创建详解

与生产者对应的是消费者,应用程序可以通过 KafkaConsumer 来订阅主题,并从订阅的主题拉取消息。不过在使用 KafkaConsumer 之前需要了解消费者与消费组的概念,否则无法理解如何使用 KafkaConsumer。 一、消费者与消费组 消费者(Consumer)负责订阅主题(Topi…

2020-05-20 0 By admin

Kafka 服务中生产者创建详解

简单地说:生产者就是负责向 Kafka 发送消息的应用程序;但是其中包含了很多的操作。 一、生产者客户端开发 一个正常的生产者逻辑需要具备以下几个步骤: 配置生产者客户端参数及创建相应的生产者实例。 构建待发送的消息。 发送消息。 关闭生产者实例。 1.1、创建生产者实例 在创建真正的生产者实例前需…