Не могу определить, что не так с моей конфигурацией слушателя kafka.Изначально у меня есть непустая...
Мы использовали Spring Kafka 2.1 в наших проектах. Существует вариант использования для отправки...
У меня есть файл toml, используемый для настройки приложения, которое использует аннотацию Spring...
В приложении Spring Boot, использующем Spring Cloud Stream для подключения к Kafka, я пытаюсь...
Мы используем spring-kafka (1.3.2.RELEASE) в нашем приложении.Прямо сейчас мы используем...
У меня проблема с производителем кафки.На самом деле я использую Spring Kafka, и отправка сообщений...
Попытка выяснить, могу ли я написать модульный тест для @KafkaListener, используя spring-kafka и...
PersonDeserializer настроен как value-deserializer в application.yml, а в методе deserialize оба...
Моя текущая настройка имеет следующую конфигурацию: @Bean public...
Мы используем версию Spring Kafka 2.1.4.RELEASE в нашем проекте, и у нас есть следующая...
Мой потребитель Kafka должен слушать несколько тем.Каждая тема определяет приоритет, скажем -...
У меня есть следующий application.yml: service: kafka: groupId: 345 consumer: topics: - name:...
Хотите создать homogeneous kafka consumers в разных кластерах из загрузочного приложения Spring,...
Попытка обновить службу spring-boot для использования spring-boot 2.0.5 и spring-kafka 2.1.10 (из...
Я использую spring-kafka 3.1.6 и hazelcast 3.7.4. При закрытии моего приложения кажется, что...
В документации kafka я пытаюсь понять это свойство max.poll.interval.ms Максимальная задержка между...
Я хотел бы знать, есть ли какая-либо опция в spring-kafka, которая будет захватывать все новые...
У меня недавно были некоторые проблемы с некоторыми моими потребителями Kafka, не устанавливавшими...
Я использую spring-kafka и использую пакетные записи из раздела kafka и отправляю смещение на...
Рассмотрим следующий код: @Test(singleThreaded = true) public class KafkaConsumerTest { private...
Я использую Spring Kafka и Spring Boot и просто задаюсь вопросом, как настроить моего потребителя,...
У меня проблема с использованием KafkaEmbedded от https://mvnrepository.com/artifact/org
Я пытаюсь настроить службу, которая имеет как конечную точку REST (POST), так и конечную точку...
У меня следующая проблема: мне нужно отправить следы Зипкину через Кафку с помощью Sleuth.Исходя из...
Некоторые из моих потребителей Kafka (но не все) демонстрируют интересную картину, касающуюся их...