Как создать разделы Kafka с помощью Java-кода

Question

Я пытаюсь создать Kafka Partition , используя JAVA. Но не удалось.

Может кто-нибудь дать мне пример, как создать раздел в kafkaиспользуя код Java.

Answer 1

Не очень понятно, что вы имеете в виду.Если вы пытаетесь увеличить количество разделов существующей темы, используйте метод AdminClient. createPartitions .

Если тема еще не существует, вы можете использовать AdminClient. createTopics , который принимает количество разделов в качестве поля в NewTopic объекте.