Как динамически создавать и удалять Topics с помощью библиотеки spring-kafka? Спасибо.
Я пробовал AdminClient. Но мне нужна какая-то оболочка, которая может помочь мне достичь этого, используя spring-kafka без создания собственного класса и его тестирования.
spring-kafka уже есть один для создания Topic. Но для удаления я понятия не имею.
Для таких операций можно использовать AdminClient.
https://kafka.apache.org/27/javadoc/index.html?org/apache/kafka/clients/admin/AdminClient.html
Уже использовал его Гэри. Но я не смог найти ничего, кроме TopicBuilder в spring-kafka только для создания тем. Мне нужно что-то из библиотеки spring-kafka. если он недоступен, могу ли я как-то создать оболочку? Спасибо.
@nihar Пожалуйста, отредактируйте свой вопрос, чтобы показать, что вы пробовали.
spring-kafka предоставляет KafkaAdmin, который поддерживает только небольшое подмножество функций AdminClient — он используется для создания тем для @Bean типа NewTopic во время запуска приложения. docs.spring.io/spring-kafka/docs/current/reference/html/… Для всех других операций (например, динамическое добавление/удаление тем во время выполнения) вы должны использовать AdminClient напрямую.
Спасибо Гэри. Но согласно docs.spring.io/spring-kafka/docs/current/api/org/…. -> Вы можете создавать темы без брокера после инициализации контекста приложения. Но зачем тогда тема, если брокера не существует?
Если есть bean-компоненты NewTopic (и KafkaAdmin), платформа попытается проверить или создать темы во время инициализации. По умолчанию приложение не запускается, если брокер не работает. Если вы установите для этого логического значения значение false, приложение запустится, и вы сможете вручную вызвать initialize() для создания тем, определенных bean-компонентами. Вы также можете добавить bean-компоненты в контекст приложения позже, и вызов initializ() создаст их.
Весна позволяет
@Bean Topic. Но для удаления вам нужно будет «обернуть» AdminClient. Возможно, если вы добавите свой код, мы сможем предоставить больше информации