Я создаю общую конфигурацию spring-kafka для команд, чтобы использовать их в своих проектах. Я...

Каков рекомендуемый способ перезагрузить контекст SSL в Spring Kafka? У меня есть требование...

Я использую Spring Kafka с SPEL и пытаюсь слушать разные темы на основе значения, представленного в...

Я новичок в весенней интеграции Kafka и весеннем облачном потоке данных.поэтому моя проблема...

Я использую Spring Boot 2.1.3 и пытаюсь настроить Spring SeekToCurrentErrorHandler с...

Я хочу получать сообщения от моего брокера Kafka с помощью настроенного потребителя весенней...

Я использую Spring KafkaListener для получения некоторых сообщений из темы Kafka.Просматривая...

У меня возникла техническая проблема при попытке развернуть приложение весенней загрузки приложения...

Сообщение под темой Кафки также называется log? log разделы = разделы сообщения темы? # The default...

Я пытаюсь отфильтровать сообщения ConsumerRecord перед использованием, основываясь на содержимом...

Мне нужно включить / выключить потребителя Kafka на основе некоторого свойства, управляемого базой...

У меня есть функции A, B & C. Когда я вызываю функцию A (), она отправляет уведомление kafka, и...

У меня есть приложение весенней загрузки, которое будет принимать и выводить сообщения на разные...

Кажется, что пружина Spring Kafka игнорирует примечание @Payload(required = false) во время...

Я пытаюсь выяснить, есть ли способ использовать функцию транзакции Kafka для записи в две темы...

У меня есть Stream Listener как @StreamListener(target = "requesti")...

Я использую версию весенней загрузки 2.0.3-RELEASE.Это мой конфигурационный файл.Когда я запускаю...

Spring Kafka - Как повторить попытку с @ KafkaListener spring-kafka SeekToCurrentErrorHandler, если...

Мой потребитель привязан к анонимной группе потребителей вместо указанной мной группы потребителей....

Я пишу интеграционный тест с использованием spring-kaka-2.2.0 в приложении весенней загрузки, мне...

Я создал тему с 5 разделами с 3 коэффициентами репликации. У меня запущены два потребительских...

Я не могу перейти на Spring 5, поэтому я застрял с spring-kafka 1.3 и его ограниченной обработкой...

Я использую Spring Boot 1.5.6.RELEASE для подключения к Kafka 0.11 с использованием аутентификации...

У меня есть объект модели, который заполняется после нескольких преобразований и разбора.Теперь мне...

Я пытаюсь провести интеграционное тестирование с использованием spring-boot и встроенного в пружину...