java - Kafka生产者从Java为主题创建分区

Question

我正在创建一个 kafka 生产者，并且我想在根据消息类型发送消息时指定 partitionId。我的 Mysql 表中有 type-partitonId 映射。如果是新消息类型，我必须创建新分区并将该 ID 保存到 Mysql，以便下次相同类型出现时它可以直接向该 ID 发送消息。如何为主题创建新分区并获取创建的 partitionId ？我正在使用最新的 kafka API .9 和 Java 1.8。

Answer 1

查看 AdminUtils 类，特别是 addPartitions() 方法。请注意，在实际发送消息之前，您可能需要等待一段时间才能将元数据传播到所有代理。