Любые идеи будут оценены, я пытаюсь написать тест как; @ExtendWith(SpringExtension.class)...

pom.xml <?xml version="1.0" encoding="UTF-8"?> <project...

Когда DLQ настроен для потребителя весеннего облачного потока Kafka, может ли раздел DLQ записать...

есть трудоемкая операция (около 10 мин), но кафка уходит в равновесие через 5 мин, даже я делаю...

В моем проекте у меня много компонентов с пружинным управлением, которые примерно одинаковы.Я хочу...

Я запускаю весеннюю загрузку и kafka с автоматической настройкой (только с помощью аннотаций) и с...

Я вижу, что до этого [*] было какое-то обсуждение этой темы, но я никак не могу понять, как...

У нас есть проблема, из-за которой перерыв в работе раздела Kafka (всего 3 минуты) заставил нашего...

Я использую Kafka в проекте Spring Boot. Есть много преимуществ, если у вас есть простой поток (для...

В дополнение к ранее заданным вопросам о транзакциях, я хотел бы спросить об управлении...

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

У меня довольно простой потребитель Кафки: MessageListener<String, T> messageListener =...

Сегодня у нас была проблема, когда потребитель Kakfa не смог подключиться ни к одному брокеру, и в...

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

Я хочу использовать API-интерфейс Spring Cloud Stream для агрегации событий из темы. Поэтому я...

Я пишу тестовый пример junit, используя встроенную kafka. У нас есть конвейер, в котором...

Я пытаюсь написать интеграционные тесты для приложения Spring Kafka (Spring Boot 2.0.6, Spring...

Документация для ReplyingKafkaTemplate, которая обеспечивает поддержку запроса-ответа (представлена...

Примечание к дублирующимся маркерам : I DID проверьте другой вопрос, но он не отвечает на мой...

Я новичок с кафкой. Я использую образ докера Landoop ... Я использовал консоль-производителя и...

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

Я использую EmbeddedKafka для проверки интеграции с Кафкой в ​​моем микросервисе. А также, я...

Я запускаю Кафку локально через: докер-compose.yml zookeeper: image:...

Отправка 4 записей: producer.send(new ProducerRecord<>("my-topic", 0,...

Я использую Spring и Spring Kafka для пакетной службы, которая собирает данные из Kafka до тех пор,...