2016-12-19 1 views
0

По требованию выполнения, я могу программно (с помощью Java) Создания/удаления раздела из Кафки ТемыProgramatically (JAVA) Создание/удаление раздела из Кафки Темы

Я использую клиентый Java Apache Кафки (0.10) и установку Apache Кафки (0.10)

+0

a) что вы ** пробовали самостоятельно ** до сих пор? б) вам не помешало бы писать ваши вопросы с некоторыми вопросительными знаками, не так ли? –

+0

Согласен. Определенно последует за ним со следующего раза. –

+0

Вы можете изменить свой вопрос –

ответ

1

Invoke AdminUtils.createTopic и AdminUtils.deleteTopic для создания и удаления тем соответственно.

EDIT:

Используйте AdminUtils.addPartitions для добавления разделов для темы. В настоящее время Kafka не поддерживает уменьшение номера раздела.

+0

Мой запрос о создании/удалении "PARTITIONS" темы, а не темы. –