По требованию выполнения, я могу программно (с помощью Java) Создания/удаления раздела из Кафки ТемыProgramatically (JAVA) Создание/удаление раздела из Кафки Темы
Я использую клиентый Java Apache Кафки (0.10) и установку Apache Кафки (0.10)
По требованию выполнения, я могу программно (с помощью Java) Создания/удаления раздела из Кафки ТемыProgramatically (JAVA) Создание/удаление раздела из Кафки Темы
Я использую клиентый Java Apache Кафки (0.10) и установку Apache Кафки (0.10)
Invoke AdminUtils.createTopic и AdminUtils.deleteTopic для создания и удаления тем соответственно.
EDIT:
Используйте AdminUtils.addPartitions для добавления разделов для темы. В настоящее время Kafka не поддерживает уменьшение номера раздела.
Мой запрос о создании/удалении "PARTITIONS" темы, а не темы. –
a) что вы ** пробовали самостоятельно ** до сих пор? б) вам не помешало бы писать ваши вопросы с некоторыми вопросительными знаками, не так ли? –
Согласен. Определенно последует за ним со следующего раза. –
Вы можете изменить свой вопрос –