python - 在 Kafka Python 中设置分区键表达式配置

Question

我正在使用confluent 的 kafka python 包。我想在 Spring (Java) 中向 Producer 添加一个名为partition-key-expression的配置属性（有关更多信息，请参阅此参考）

我现在实例化生产者的方式如下：

producer = confluent_kafka.Producer({
            "bootstrap.servers": <KAFKA_SERVICE_URI>,
            "topic.acks": 1
        })

我想知道是否可以添加partition-key-expression配置属性，因为我在文档中找不到它。

score 1 · Accepted Answer

Spring 属性不是基本 Kafka 协议的一部分，因此它们不会被转移到 Python 库中。

听起来您在问如何定义分区器，例如

def calc_partition(key):
  """ Get the partition, based on the key """
  return 0

producer.produce(topic, value, key, partition=calc_partition(key))

1 回答 1