我正在创建一个kafka生成器，我想在根据消息类型发送消息时指定partitionId . 我的Mysql表中有type-partitonId映射 . 在新消息类型的情况下，我必须创建新分区并将该id保存到Mysql，以便它可以在下次相同类型到来时直接向该Id发送消息 . 如何为主题创建新分区并获取创建的partitionId？我正在使用最新的kafka API .9和Java 1.8 .
查看AdminUtils类，特别是在addPartitions（）方法中 . 请注意，在实际发送消息之前，您可能需要等待一段时间才能将元数据传播到所有代理 .
1 回答
查看AdminUtils类，特别是在addPartitions（）方法中 . 请注意，在实际发送消息之前，您可能需要等待一段时间才能将元数据传播到所有代理 .