使用 Spring Boot 自定义 kafka 主题分区

【问题标题】：Custom partition of kafka topics using Spring Boot使用 Spring Boot 自定义 kafka 主题分区
【发布时间】：2019-04-22 21:43:44
【问题描述】：

有没有办法根据使用 Spring Boot 的有效负载属性计算的哈希创建分区键。在 apache-kafka 中有一个名为Partition 的接口，但不知道如何使用 Spring boot 将消息分配到不同的分区中。

【问题讨论】：

标签： spring spring-boot spring-kafka

【解决方案1】：

见the kafka documentation。

将partitioner.class producer 属性设置为您的类名。

partitioner.class

实现org.apache.kafka.clients.producer.Partitioner interface的分区器类。

默认：org.apache.kafka.clients.producer.internals.DefaultPartitioner

【讨论】：