У меня есть потребитель Kafka, реализованный как: @KafkaListener(topics="...",...
У меня сейчас проблема с обработкой исключений, возникающих при обработке сообщений в Spring Cloud...
Я разрабатываю приложение с загрузочной пружиной, которое будет слушать ibm mq с...
Я использую spring-kafka 1.3.5, которая использует клиент 0.11.0.2.У меня есть 2 раздела.И мой max
Я использую потребитель Kafka Spring, который находится под управлением группы. У меня есть...
У меня есть 5-ти узловый кластер Kafka с Zookeeper, работающим на 3-х узлах.Мой потребитель не...
У меня есть потребительское приложение Kafka, написанное на Spring Boot 2.0.2.Когда я получаю...
В настоящее время я застрял в простом примере ручного управления смещениями и фиксациями Kafka.У...
поэтому я реализовал простой клиент kafka, следуя книге, я знаю, как использовать его в main методе...
Я использую пружинную кафку 1.2.2. ВЫПУСК.В настоящее время я настроил шаблон повтора для...
Использование Kafka Broker: 1.0.1 spring-kafka: 2.1.6. ВЫПУСК Я использую пакетный потребитель со...
Я использую Spring Cloud Stream 1.3.2.RELEASE , чтобы опубликовать строковое сообщение для Кафки....
У меня есть проект с spring-cloud-starter-bus-kafka, и я задаю URL-адрес kafka внутри application
Этот вопрос задавался и решался пару раз, но из-за моих очень ограниченных знаний я не могу найти...
Приложение My Spring Boot содержит несколько @KafkaListener с , и каждый слушатель выполняет одни и...
Мне нужно установить сериализатор пользовательских значений в KafkaTemplate Spring . Значение...
Я создаю приложение Kafka Consumer, которое принимает сообщения из темы Kafka и выполняет задачу...
Я не хочу фиксировать смещения для тех сообщений, обработка которых не удалась, и я хочу, чтобы они...
Я только начинаю использовать Kafka с Spring Boot и хочу отправлять и использовать объекты JSON....
Я пишу приложение Kafka Consumer на основе Java. Я использую kafka-клиенты, Spring Kafka и Spring...
Обращаясь к Spring kafka doc , я пытаюсь реализовать приложение весенней загрузки, которое...
У меня есть приложение с весенней загрузкой, в котором у меня есть один Kafka Consumer. Я использую...
Я не могу сказать, упускаю ли я что-то очевидное, или в spring-integration-kafka:3.0.1 есть ошибка,...
Журналы консоли перегружены журналами из библиотек 3-й части. Например, мой проект использует...
Я использую локальный сервер версии 1.3 для SCDF, и у меня запущена версия kafka kafka_2.11-0.10.1