1
ответ
Метод с аннотацией @KafkaListener не вызывается, если нет сообщений
Я использую spring-kafka, и метод, аннотированный @KafkaListener, не вызывается, если метод consumer.poll () не возвращает никакого сообщения. Можно ли принудить вызов метода, даже если ...
вопрос задан: 28 March 2019 12:34
1
ответ
Spring Boot внедряет ObjectMapper в Kafka JsonDeserializer
Я хотел бы добавить ObjectMapper Джексона в JsonDeserializer для ConsumerFactory Кафки. Я сделал то, что упоминается в этом посте: Внедрить ObjectMapper в сериализатор Spring Kafka / ...
вопрос задан: 6 March 2019 05:00
1
ответ
Как закрыть KStream, если все брокеры не доступны
Я использую Streams с Spring Boot Application. Если Kafka закрыт или недоступен, блокируется только следующее: Не удалось установить соединение с узлом -1. Брокер может быть недоступен ....
вопрос задан: 16 January 2019 10:13
0
ответов
Пользовательские ключевые последовательности для привязки в Spring Cloud Stream
Я пытаюсь понять, как использовать другой сериализатор / десериализатор ключей в Spring Cloud Stream. Я нашел способ указать глобальные serdes, но я не понимаю, как указать разные serdes ...
вопрос задан: 9 May 2019 09:43
0
ответов
Kafka multi thread Consumer miss Некоторые сообщения после некоторой цепочки ожидают ожидания
Я использую пружинный каркас и кафку с 6-ю потребительскими нитками. после того, как 2 потока одной группы потребителей заблокированы для вызова конечной точки мыла в течение более 30 минут (я знаю, что должен это исправить!) ...
вопрос задан: 23 March 2019 05:34
0
ответов
Как встроить или смоделировать kafka в Spring многомодульных тестах интеграции проекта
Уважаемые, мне нужно добавить некоторые интеграционные тесты ко многим ресурсам в проекте, над которым мы работаем, который использует Kafka, но до сих пор я не смог запустить только один экземпляр Embedded Kafka во всех тестах ...
вопрос задан: 11 March 2019 14:20
0
ответов
Вопрос об использовании @KafkaListener autoStartup = & ldquo; false & rdquo; для нескольких тем
Со следующим @KafkaListener (id = "id1", autoStartup = "false", themes = {"topic1", "topic2"} spring.kafka.consumer.auto-offset-reset = самые ранние Предположим, в каждом есть несколько сообщений. ..
вопрос задан: 16 January 2019 16:18
0
ответов
Kafka-Manager показывает неактивные группы потребителей и неправильную задержку
У меня есть кластер kafka из 3 отдельных физических узлов, каждый из которых состоит из 1 zk и 1 брокера. Мы используем Kafka 0.10.1.1. Темы создаются на ансамбле ZK, а брокеры подключаются к ZK ...
вопрос задан: 13 July 2018 10:00
0
ответов
Spring Kafka Producer не отправляет в Kafka 1.0.0 (Magic v1 не поддерживает заголовки записей)
Я использую эту настройку docker-compose для локальной настройки Kafka: https://github.com/wurstmeister/kafka-docker/ docker-compose up работает отлично, создание тем через shell работает нормально. Теперь я пытаюсь ...
вопрос задан: 26 December 2017 14:17