spring-kafka

0зной

1ответ

Как гарантировать, что сообщения не потеряны с использованием пружины KafkaMessageListenerContainer.java

Как только я получаю сообщение от kafka, мне нужно запустить длительный процесс (который занимает не более 20 секунд), мне нужно считать сообщение успешным только в том случае, если этот процесс завер

kafka-consumer-api spring-kafka 2016-08-14

---

1зной

1ответ

Как вручную фиксировать смещения в исходном модуле Kafka при получении подтверждения от модуля приемника Kafka весной XD?

В потоке XD сообщения потребляются из темы Kafka через исходный модуль, а затем отправляются в модуль Kafka для раковины. Причиной развития пользовательских исходных и приемных модулей Kafka является

spring-integration spring-xd spring-kafka 2016-08-19

---

1зной

1ответ

Spring Kafka Прослушивание всех тем и настройка смещений разделов

Основываясь на документации по адресу spring-kafka, я использую основанную на аннотации @ KafkaListener для настройки моего потребителя. То, что я вижу, что - Если не указать смещение нуля, на старте,

spring-integration apache-kafka spring-kafka 2016-08-23

---

2зной

1ответ

spring-kafka (не интеграция) потребитель не потребляет сообщение

Я интегрирую свое приложение с spring-kafka (не spring-integration-kafka). Вот весенняя документация по проекту: http://docs.spring.io/spring-kafka/docs/1.0.1.RELEASE/reference/htmlsingle Мой продюсер

spring apache-kafka spring-kafka 2016-07-08

---

3зной

1ответ

Компонент раковины не получает правильные данные с кафкой в ​​потоке данных весеннего облака

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

spring-integration spring-cloud-stream spring-cloud-dataflow spring-kafka 2016-09-06

---

2зной

1ответ

Получить метаданные для темы от KafkaTemplate

Я видел из реализации KafkaTemplate, что нет доступа к фактическому продюсеру Kafka. Хотя упаковка этого производителя может быть хорошей, есть некоторые методы от Kafka Producer, которые необходимы,

spring-kafka 2016-09-07

---

1зной

1ответ

Весна Кафка, Испытание с помощью встроенного Kafka

Мы наблюдаем странное поведение с нашим Servicetest и встроенным Kafka. Тест представляет собой тест Спок, мы используем JUnit Правило KafkaEmbedded и распространяются brokersAsString следующим образо

spring spring-boot apache-kafka spring-kafka 2016-07-29

---

0зной

1ответ

Autowired KafkaTemplate в SpringBoot/spring-kafka application throws null pointer

Я пытаюсь использовать KafkaTemplate spring-kafka в приложении Spring Boot для написания сообщений в теме Kafka. Я создал класс KafkaConfig: @Configuration @EnableKafka public class KafkaConfig {

java spring spring-boot spring-kafka 2016-08-08

---