Я использую "программный" способ потребления сообщений из темы Кафки, используя org.springframework

Мое приложение успешно отправляет сообщения Kafka, но только после инициализации Kafka.Перед этим я...

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

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

используя нативную кафку Java Api в загрузочном приложении Spring, как развернуть это в web-logic...

Потребитель иногда не работает, а иногда и не может понять проблему. spring boot - 1.5.21.release...

Мой вопрос будет коротким и чистым.Я хотел бы проанализировать данные JSON, которые будут поступать...

Spring Kafka (2.2.2.RELEASE), при получении записей партиями мы видим проблему с...

Мой потребитель Kafka опрашивает быстрее, чем я ожидал. Есть ли какой-нибудь конфиг, который я могу...

Я пытаюсь создать ПРОЦЕССОР, который принимает на вход один параметр, и я хочу, чтобы он выдавал...

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

Я устанавливаю приложение весенней загрузки с kafka. Как я могу добиться «точно единовременной...

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

Когда я отправляю запись в тему kafka, потребитель получает «nativeHeaders» с некоторым ненужным...

У меня есть записи, поступающие в kafka с несколькими неуникальными полями, давайте назовем их...

Я создаю приложение Spring Boot с поддержкой Kafka.Я создал продюсера и потребителя, и все работает...

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

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

Я хочу создать одно приложение Spring Boot, которое одновременно выполняет несколько различных...

Используя пружинную интеграцию Kafka dsl, мне интересно, почему слушатель не получает сообщения?Но...

У меня есть проект Spring Kafka, и я написал для него несколько модульных тестов. Когда я выполняю...

Я изменяю тему Кафки, добавляю к ней раздел (от 3 до 4 разделов). На потребителя у меня уже есть 4...

Я использую встроенный Kafka для junit и хочу установить каталог состояния для встроенного Kafka. Я...

В настоящее время мы используем Spring Cloud Stream для предоставления SubscribableChannel для...

У меня есть поток событий Кафки объектов: KStream<String, VehicleEventTO> stream = builder