Kafka生产者始终将消息发送到相同的分区（Kafka+Python）

这种情况通常是因为使用固定的分区键，导致所有消息都被分配到同一个分区。为了解决这个问题，可以使用哈希函数来产生随机的分区键，从而使得消息能够分散到不同的分区。

下面是一个使用哈希函数的Python示例：

from kafka import KafkaProducer
import hashlib

def get_partition(key, num_partitions):
    '''使用哈希函数获取分区数'''
    return int(hashlib.sha256(key.encode('utf-8')).hexdigest(), 16) % num_partitions

producer = KafkaProducer(bootstrap_servers=['localhost:9092'])

for i in range(10):
    # 将i作为分区键
    partition = get_partition(str(i), 3)
    producer.send('my_topic', key=str(i).encode('utf-8'), value=b'my_message', partition=partition)

producer.flush()

在上面的示例中，我们定义了一个名为get_partition的函数，它使用哈希函数来计算分区键。然后，在生产者发送消息时，将使用该分区键来发送到相应的分区。这将使得每个消息都被发送到不同的分区，从而避免了所有消息都被发送到同一个分区的问题。