如何为Confluent Kafka的Topic创建自定义名称/ID的分区，适配.NET开发场景

Kafka原生设计里不存在「自定义分区名称」的概念，所有分区默认使用从0开始的连续整数作为唯一ID，你创建100个分区的Topic后，分区ID自动就是0~99的连续值，完全满足你按唯一标识指定分区的需求。Confluent Control Center UI本身也没有提供自定义分区ID/名称的入口，因为Kafka原生不支持这个特性。

你直接使用官方Confluent.Kafka NuGet包即可实现明确指定分区发送消息，操作方式如下：

• 先确认你的100分区Topic已创建完成，可用分区ID范围固定为0~99
• 生产消息时不需要依赖默认分区器，直接在构造发送参数时指定Partition参数即可

using Confluent.Kafka;

// 生产者基础配置
var producerConfig = new ProducerConfig
{
    BootstrapServers = "你的Kafka集群地址",
    Acks = Acks.All
};

// 初始化生产者实例
using var producer = new ProducerBuilder<string, string>(producerConfig).Build();

// 构造待发送消息
var message = new Message<string, string>
{
    Key = "你的业务消息key",
    Value = "你的业务消息内容"
};

// 明确指定消息发送到ID为23的分区（可替换为你需要的0~99任意分区ID）
var deliveryResult = await producer.ProduceAsync(
    new TopicPartition("你的目标Topic名称", new Partition(23)), 
    message
);

Console.WriteLine($"消息已成功发送到分区：{deliveryResult.Partition.Value}，对应偏移量：{deliveryResult.Offset.Value}");

如果你希望按业务逻辑自动映射分区（比如同用户ID的消息固定发送到同一个分区），可以自定义分区器实现，不需要每次手动指定分区ID：

var producerConfig = new ProducerConfig
{
    BootstrapServers = "你的Kafka集群地址",
    Acks = Acks.All
};

// 自定义分区器逻辑，按消息key的哈希值取模映射到对应分区
var producer = new ProducerBuilder<string, string>(producerConfig)
    .SetPartitioner("你的目标Topic名称", (topic, key, partitionCount) =>
    {
        // 自行实现分区计算逻辑，返回值必须在0~partitionCount-1范围内
        return Math.Abs(key.GetHashCode()) % partitionCount;
    })
    .Build();

注意：手动指定的分区ID必须在0到「分区总数-1」的范围内，否则会抛出分区不存在的异常。

内容的提问来源于stack exchange，提问作者Learn AspNet