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

Question

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

Answer 1

在 0.4 中，你可以使用 custom Kafka partitioner configuration .在 0.5 中，我们添加了将项目直接映射到 ProducerRecord 的功能。

例如:

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