spring-kafka

0열

1답변

스프링 클라우드 스트림 MessageChannel send() 항상 true를 반환합니다.

저는 Spring 클라우드 스트림을 사용하고 있으며 카프카 서버가 사라졌지만 MessageChannel send() 메소드가 항상 리턴 할 때 메시지를 저장하고 주제에 게시하려고합니다. Kafka/Zookeeper 서버가 중지 된 경우에도 마찬가지입니다. 누군가 도울 수 있습니까? application.yml 내용 UPDATE : spring: c

spring spring-boot spring-cloud-stream spring-kafka 2017-12-06

---

0열

1답변

registerSeekCallback()을 사용하여 Spring Kafka에서 검색 작업 수행

org.springframework.kafka.listener.ConcurrentMessageListenerContainer에 N MessageListener가 있고 주제의 N 파티션을 수신합니다. 때로는 응용 프로그램이 마지막 커밋 된 오프셋과 다른 오프셋에서 시작해야합니다. 청취자를 ConsumerSeekAware으로 만들고 registerSeekCal

apache-kafka kafka-consumer-api spring-kafka 2017-12-06

---

1열

1답변

봄 통합 카프카의 ClassNotFoundException : KafkaHeaderMapper

, 나는 다음과 같은 오류를 얻고있다 봄 - 통합 - 카프카 라이브러리는 봄 부팅 응용 프로그램을 실행하는 동안 : 예외는 본문의 첫 번째 줄에서 발생합니다 Caused by: java.lang.ClassNotFoundException: org.springframework.kafka.support.KafkaHeaderMapper 다음과 같은 방법 @Serv

java spring apache-kafka spring-integration spring-kafka 2017-12-07

---

0열

1답변

스프링 클라우드 스트림 kafka 바인더가 'bindingService'라는 이름의 빈을 생성하는 중 오류가 발생했습니다.

카프카 (Kafka) 주제의 이벤트를 수신하는 애플리케이션을 생성했으며 참조 용으로 GitHub (https://github.com/meta-magic/Kafka-Example)에서 공유했습니다. 봄 부팅 1.5.9.RELEASE 봄 구름 Edgware.RELEASE 의 pom.xml 응용 프로그램은 부팅 실패 <project xmlns="http://ma

spring-cloud spring-cloud-stream spring-kafka 2017-12-12

---

0열

1답변

스프링 부트 및로드 밸런서를 사용하는 Kafka의 독립 제작자

나는 (나머지 API와 스키마 레지스트리가있는) Confluent에서 Apache Kafka를 설치했습니다. 나는 spring-boot와 spring-kafka를 사용하여 프로듀서를 구현했다. (각 이벤트는 데이터베이스 트리거에서 생성된다.) 이제는 여러 인스턴스로 실행하고 싶습니다.하지만 kafka에서 중복을 생략하는 적절한 방법은 무엇입니까? 로드 밸런

spring apache-kafka kafka-producer-api spring-kafka 2017-12-13

---

2열

1답변

가능한 Nullpointer 스프링 카프카

우리가 스프링 카프카-2.0.1.RELEASE를 사용하여 생산이 오류를 얻을 수 있습니다 : 예외 java.lang.NullPointerException이 java.lang.NullPointerException이를 : 널 (null) org.springframework.kafka.listener.KafkaMessageListenerContainer $ Li

spring apache-kafka spring-kafka 2017-12-13

---

0열

1답변

스프링 카프카 일괄 청취자 - 일괄 처리로 수동 커밋

카프카 주제에서 메시지 목록을 읽고 REST 서비스에 데이터를 게시하는 스프링 카프카 일괄 리스너를 구현 중입니다. REST 서비스가 중단 된 경우 오프셋 관리를 이해하고 싶습니다. 일괄 처리의 오프셋을 커밋해서는 안되고 다음 폴링을 위해 메시지를 처리해야합니다. Spring kafka 문서를 읽었지만 리스너 오류 처리기와 현재 컨테이너 오류 처리기를 일괄

spring spring-boot spring-kafka 2017-12-13

---

0열

1답변

스프링 카프카 (Spring Kafka) 글로벌 거래 ID는 프로그램이 끝난 후 계속 열어 둔다.

나는 카프카에게 데이터를 보내고 데이터베이스에 쓸 스프링 부트 아래 카프카 스프링 프로듀서를 만들고있다. 나는 그 모든 일을 하나의 거래로 원한다. 나는 카프카에 익숙하지 않고 봄에 대한 전문가도없고 어려움을 겪고 있습니다. 모든 포인터가 많이 감사합니다. 지금까지 나의 코드는 Kafka에 성공적으로 루프를 작성합니다. 나는 아직 DB 을 설정하지 않은,하

spring apache-kafka spring-transactions spring-kafka 2017-12-14

---

-1열

1답변

봄 카프카를 사용할 때 제작자 용 오류 처리기를 추가하는 방법

봄 카프카를 사용할 때 제작자 용 오류 처리기를 추가하는 방법은 무엇입니까? 나는 소비자를위한 오류 처리기를 추가하는 방법을 알고 있지만 제작자에 대해서는 확신하지 못한다.

spring-kafka 2017-12-14

---

0열

1답변

Spring Cloud Stream - 메시지 일괄 처리

일정한 간격으로 모든 일괄 처리 (10k 레코드를 한꺼번에 처리하는 대신)로 카프카 (Kafka) 주제에서 메시지 배치 (10000 메시지)를 가져 오려고합니다. 스프링 클라우드 스트림 프로세서에서이를 수행 할 수있는 방법이 있습니까? 그렇다면 어떤 스 니펫이나 제가 참조 할 수있는 예제가 있습니까? 감사

spring-cloud-stream spring-cloud-dataflow spring-kafka 2017-12-15

---