hazelcast-jet - 如何在 WriteKafkaP 中插入自定义分区逻辑？

Question

我WriteKafaP在 Jet 作业中使用顶点。发布到 Kafka 主题时，有没有办法插入自定义分区逻辑？

Answer 1

在 0.4 中，您可以使用自定义 Kafka 分区器配置。在 0.5 中，我们添加了将项目直接映射到 a 的功能ProducerRecord。

例如：

Vertex v = new Vertex("kafkaSink", KafkaProcessors.writeKafkaP(properties, o -> new ProducerRecord(topic, partition, key, value));