按需运行时，我可以通过编程（使用java）从kafka主题创建/删除分区吗我正在使用java apache kafka客户端（0.10）和apache kafka安装（0.10）
lb3vh1jj1#
调用adminutils.createtopic和adminutils.deletetopic分别创建和删除主题。编辑：使用adminutils.addpartitions为主题添加分区。Kafka目前不支持减少分区号。
1条答案
按热度按时间lb3vh1jj1#
调用adminutils.createtopic和adminutils.deletetopic分别创建和删除主题。
编辑：
使用adminutils.addpartitions为主题添加分区。Kafka目前不支持减少分区号。