在 Kafka Python 中设置分区键表达式配置答案

【问题标题】：Set partition-key-expression config in Kafka Python在 Kafka Python 中设置分区键表达式配置
【发布时间】：2021-11-01 19:01:21
【问题描述】：

我正在使用confluent's kafka python package。我想在 spring (Java) (See this ref for more info) 中为 Producer 添加一个名为 partition-key-expression 的配置属性

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

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

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

【问题讨论】：

【解决方案1】：

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))

【讨论】：