spring-kafka

0열

1답변

SCS 카프카 소비자 처리 최신 메시지

SCS 1.3.0.RELEASE를 사용 중입니다. 나는 생산자와 소비자 어플리케이션을 가지고있다. 소비자 응용 프로그램을 시작하지 않고 나는 생산자 응용 프로그램을 사용하여 몇 가지 메시지를 보냈습니다. 그런 다음 소비자 응용 프로그램을 시작했지만 메시지는 소비되지 않았습니다. 둘 다 올라가면 소비자 응용 프로그램이 올바르게 처리됩니다.

java spring-cloud-stream spring-kafka 2017-10-26

---

1열

1답변

봄 카프카 소비자/리스너 그룹

@KafkaListener에서 지정 대 소비자 spring.kafka.consumer.group-id 에서 그룹을 지정의 차이는 무엇인가? @KafkaListener(topic="test", group = "test-grp")

apache-kafka spring-kafka 2017-10-27

---

1열

1답변

Apache Kafka Server와의 연결이 끊어진 경우 Spring Kafka Listener로 마이크로 서비스를 중지하는 방법은 무엇입니까?

현재 Apache Kafka 주제에서 데이터를 읽는 마이크로 서비스를 구현 중입니다. 나는 마이크로 서비스를위한 "spring-boot, version : 1.5.6.RELEASE"와 동일한 마이크로 서비스의 리스너를위한 "spring-kafka, version : 1.2.2.RELEASE"를 사용하고 있습니다. 나는 @KafkaListener 주석을 통해

spring spring-boot apache-kafka spring-kafka 2017-11-01

---

0열

1답변

봄 카프카 : 카프카 리스너 - 소비자. 독창적 인 문제

DB로 처리 한 후 각 레코드를 인정하는 Spring KafkaListener를 사용하고 있습니다. DB에 쓰는 데 문제가 있다면 우리는 오프셋을 소비자에게 저지하지 않도록 기록을 인정하지 않습니다. 이 잘 작동합니다. 이제 우리는 다음 폴링에서 실패한 메일을 다시 보내려합니다. 우리는 청취자에게 errorhandler를 추가하고 ConsumerAwareL

spring-kafka 2017-11-02

---

2열

1답변

bean kafkaListenerContainer를 시작하지 못했습니다 : java.lang.IllegalArgumentException

스프링 통합을 사용하여 파일을 읽는 예제로 this을 사용하고 있지만, kafka 제작자에게 파일을 보내려고하면 작동하지 않습니다. 인터넷에서이 문제를 조사하려했지만 도움을 찾을 수 없었습니다. 파일 : MessageProcessingIntegrationFlow.java : 여기 @Bean public IntegrationFlow writeToFile()

spring spring-boot apache-kafka spring-integration spring-kafka 2017-11-05

---

0열

1답변

예외에서 스프링 카프카 중지 컨테이너

자동 커밋을 false로 설정하고 ConcurrentMessageListenerContainer을 사용하여 주제에서 메시지를 소비하고 데이터베이스에 씁니다. 데이터베이스가 다운 된 경우 컨테이너가 설문 조사에서 현재 레코드를 처리하지 못하도록하고 다음에 수행하지 마십시오. poll(). DataSourceHealthIndicator을 구현했으며 데이터베이스

spring-kafka 2017-11-08

---

0열

1답변

EmbeddedKafka가 후속 테스트 지연 후 소비자에게 메시지 보내기

kafka-spring-test 버전 2.0.1.RELEASE (최신)에서 EmbeddedKafka을 사용하고 있습니다. 하나의 테스트 만 실행하면 올바르게 작동하는 매우 간단한 테스트를 수행 할 수 있습니다. 하지만 내가 하나씩 실행할 때마다 (따라서 전체 테스트 클래스를 실행하는 것) 두 번째 것은 실패합니다. - 소비자 doest는 메시지를받지 못합니

java apache-kafka spring-kafka 2017-11-15

---

0열

1답변

스프링 클라우드 스트림 앱 스타터가 10 초 후에 오류가 발생합니다. BinderException : 바인더를 초기화 할 수 없습니다.

트위터 소스 용 스프링 클라우드 스트림 앱을 실행 중입니다. docker 이미지가 성공적으로 시작되고 10 초 후에 org.apache.kafka.common.errors.TimeoutException을 throw하여 실패합니다. 60000 ms 후에 메타 데이터를 업데이트하지 못했습니다. 전체 스택 추적을 참조하십시오, 2017-11-16 06:41:33

java spring-cloud-stream spring-kafka 2017-11-16

---

0열

1답변

Kafka 오프셋 Kafka 주제 및 로컬 데이터베이스에 대한 오프셋 관리

카프카 주제뿐만 아니라 데이터베이스에서 오프셋을 관리하고 싶으므로 특정 지점 이후에 큐에서 재 처리 할 수 ​​있도록 할 수 있습니다. 어떻게해야합니까? 미리 감사드립니다.

java apache-kafka kafka-consumer-api spring-kafka 2017-11-16

---

0열

1답변

나머지 컨트롤러가 spring kafka를 통해 kafka의 레코드를 반환합니다.

데모 어플리케이션의 경우, kafka 큐에서 메시지를 반환하기 위해 나머지 컨트롤러를 만들어야합니다. 나는 스프링 카프카의 참조 설명서를 읽고 소비자 구성을 구현 만든 콩을 @Configuration @EnableKafka public class ConsumerConfiguration { @Value("${kafka.bootstrap-serv

spring-boot apache-kafka kafka-consumer-api spring-kafka spring-web 2017-11-20

---