Я использую kafka_2.11-2.1.1 и Производитель использует пружину 2.1.0.RELEASE. Я использую Spring,...

Я использую проект Jhipster kafka с этими предложениями Greting.java package com.nunsys.lupetime

У меня есть набор микросервисов, взаимодействующих через события на Кафке. Иногда случается, что у...

У меня есть следующие настройки: Конечная точка Rest для принятия запроса JSON POST: я анализирую...

Я пытаюсь выполнить модульное тестирование кода Кафки в Spring-Stream. При выполнении модульного...

Я изучаю способы разработки сканера в масштабе Google и, следовательно, изучаю возможное решение с...

Я обновил свой весенний поток с 1.3.0 до 2.1.2, и сериализатор по умолчанию был изменен с Kyro...

Я пытаюсь написать потребитель kafka, используя библиотеку spring-kafka версии 2.3.0.M2.Для...

Я обновил свой kafka с версии 0.10.2.0 до версии 2.1.0, и теперь kafka не может принимать сообщения

Мы используем Spring Kafka 2.2.2 Release для извлечения записей из Kafka, используя @KafkaListener...

Мы только что обновили нашу Spring до: Spring boot: 2.1.0.RELEASE Spring cloud: Greenwich.SR1...

У меня есть микросервис с несколькими конечными точками, и он также подключается к Kafka для...

У меня проблемы с запуском Spring-Kafka версии 1.3.9 с клиентом Kafka 0.10.2.2 https://spring

Проблема: мне нужно узнать, как отправлено сообщение за последние, например, 24 часа.У меня есть...

Мне нужен SpringReatch ItemReader для приема сообщений Kafka, результаты которых будут обработаны и...

Я использую spring-kafka в приложении spring-boot для отправки темы данных.Мне нужно получить...

Я создал загрузочное приложение Spring, используя это https://github

Я пытаюсь получить пример работающего "действия" потока kafka в Spring-Boot, и я, кажется, в итоге...

Мы - мой ErrorHandler, регистрирующий и перебрасывающий любое исключение, которое не обрабатывается...

У меня есть подпрограммы Spring-boot Kafka pub sub, как показано на рисунке.Я хочу сделать...

Предположим, у меня есть тема Kafka с именем account с несколькими типами сообщений (каждый со...

В проекте моей новой работы я обнаружил, что вместо непосредственного выполнения API-вызовов post /...

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

Я прочитал документацию по spring-kafka, примеры, которые я нашел, и половину стека overoverflow,...

У меня есть несколько классов, помеченных как @KafkaListener. Цель состоит в том, чтобы установить...