Я пытаюсь использовать ReplyingKafkaTemplate и периодически вижу сообщение ниже. Нет ожидающего...

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

Я создал приложение, которое получает запросы данных через kfka и использует JPA для сохранения...

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

По сути, наше приложение имеет одну заключительную тему, к которой в конечном итоге приводят все...

У меня есть 4 слушателя ConsumerFactory, которые читают по 4 различным темам, подобным этому:...

Я пытаюсь зарегистрировать слушатель kafka вручную с помощью Spring Cloud Stream, однако у меня...

У меня есть продюсер, пишущий в тему Kafka с 100 разделами, и он выбирает раздел по идентификатору...

Как я могу установить для свойства spring-boot: spring.kafka.producer.retries значение Integer

Я использую пружину kafka 2.2.2.RELEASE Наш брокер имеет строгую проверку авторизации. Вот наша...

Я пытаюсь разработать / отладить приложение Spring KAfka.Я использую KafkaTemplate для сериализации...

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

Я использую Spring Boot 2.0.7 и Spring-Kafka для создания шаблона запроса / ответа.В основном...

Мы используем spring-kafka для приема сообщений, которые должны быть перенаправлены во внешний...

I am sending `List<Object>` from Kafka Producer to a topic. A consumer which listens to the...

Я строю простой проект с Spring Boot и Spring-Kafka, я не могу настроить его, чтобы он работал, это...

Мы используем spring-kafka 1.2.2.RELEASE. Что мы хотим 1. Как только сообщение успешно используется...

Я использую ConcurrentKafkaListenerContainerFactory следующим образом: @Bean...

Получение следующей ошибки (Kafka 2.1.0): 2018-12-03 21: 22: 37.873 ОШИБКА 37645 ---...

Вот мои настройки: Реализация ConsumerSeekAware: public class ReplayJobKafkaConsumer implements...

У меня есть 3 темы, и каждая тема имеет 50 разделов.Я хочу использовать @KafkaListener для указания...

Проблема : Как производитель, если бы я хотел использовать ReplyingKafkaTemplate , я бы настроил...

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

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

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