我正在创建一个kafka生产者，并希望在根据消息类型发送消息时指定partitionid。我的mysql表中有类型partitonidMap。在新的消息类型的情况下，我必须创建新的分区，并将该id保存到mysql中，以便下次相同类型出现时它可以直接向该id发送消息。如何为主题创建新分区并获取创建的分区ID？我使用的是最新的kafkaapi.9和java1.8。
z2acfund1#
看看adminutils类，特别是addpartitions（）方法。请注意，在实际发送消息之前，您可能需要等待一段时间才能将元数据传播到所有代理。
1条答案
按热度按时间z2acfund1#
看看adminutils类，特别是addpartitions（）方法。请注意，在实际发送消息之前，您可能需要等待一段时间才能将元数据传播到所有代理。