spring-kafka

1열

2답변

카프카와 통합하기 위해 스프링 클라우드 스트림을 사용하려고합니다. 작성된 메시지는 Java POJO이고 예상대로 작동하지만 (메시지가 주제에 쓰여지고 소비자 응용 프로그램으로 읽을 수 있음) 메시지의 시작 부분에 알 수없는 문자가 추가되어 발생합니다 화제에서 메시지를 가라 앉히기 위하여 Kafka 연결을 통합 할 것을 시도 할 경우의 말썽. 이 메시지는 카

0열

1답변

1 파티션을 사용하여 카프카 토픽에 대한 동시 메시지 수신기를 만드는 방법

Uusing Spring 카프카 org.springframework.kafka.listener.ConcurrentMessageListenerContainer은 토픽의 파티션 수와 ContainerProperties를 기반으로 다중 리스너를 만듭니다. 그리고 javadoc은 "같은 파티션 내에서 메시지가 순차적으로 처리됩니다"라고 말합니다. 따라서 단 하나의

1열

1답변

카프카 스프링 통합 흐름에 널 포인터가 있음

카프카를 사용하여 스프링 통합 플로우를 구현하려고합니다. 그러나 나는 그 실수에 매달렸다. 디버깅 할 때 "HandlerAdapter handlerMethod"가 null 인 것으로 나타납니다. MessagingMessageListenerAdapter입니다. 내가 여기서하고 있는지, 아니면 더 많은 설정이 필요하다는 것을 확신하지 못한다. 그러나 이것은 문

2열

2답변

수동 커밋을위한 spring kafka의 현재 오프셋을 확인하는 방법

Spring Kafka를 처음 사용하고 있으며, 소비자 코드에서 Acknowledgement.acknowledge() 메소드를 수동 커밋에 사용할 수 없습니다. 내 소비자 구성이나 청취자 코드에 누락 된 것이 있으면 알려주십시오. 그렇지 않으면 조건에 따라 수신 확인 오프셋을 처리하는 다른 방법이 있습니다. 오프셋을 커밋하지 않은 경우/수동으로 승인, 같은

1열

1답변

는 카프카 도커 내가 받는다는 고정 표시기 플러그인 <a href="https://dmp.fabric8.io/" rel="nofollow noreferrer">https://dmp.fabric8.io/</a>을 통해 카프카 + 사육사를 구성한 9092에서 9093

에 포트 포워딩 :이 구성에 <image> <name>wurstmeister/zookeeper:latest</name> <alias>zookeeper</alias> <run> <ports> <port>2181:2181</port> </ports> </run> </image> <ima

0열

1답변

카프카를 사용하여 스프링 클라우드 스트림에 멱등 원 제작자를 어떻게 설정할 수 있습니까?

카프카 0.11에서 소개 된 멱등갑 제작자를 활용하고 싶습니다. 멱등 : 정확히-번 파티션 당 주문 의미에서 을 당 정확히 한 번만 의미를이 기능을 켜고 얻으려면 파티션 의미없는이 Confluent blog post에 따르면 새로운 속성은이를 지원하기 위해 추가되었다 중복, 데이터 손실 없음 및 순서대로 의미 - 제작자를 구성하여 "enable.idempo

0열

1답변

카프카에 맞춤 데이터를 반환하는 것이 가능합니다. 생산자

카프카를 배우고 있으며 2 개의 마이크로 서비스로 나누고 싶습니다. 먼저 KafkaConsumer의 모든 수신 메시지를 데이터베이스에 저장하고 지정된 ID로 엔터티를 선택합니다. 둘째 엔티티를 저장하고 가져 오기 위해 REST API를 제공합니다. kafka와 함께 제공된 상호 작용. kafka를 사용하여 REST API의 저장된 ID를 db로부터 어떻게받

1열

1답변

@KafkaListener, @StreamListener 및 @ServiceActivator의 차이점은 무엇입니까?

스프링 부트와 아프로 스키마가있는 카프카를 사용하고 싶습니다. 하지만 나는 '이 3 명의 청취자의 차이점은 무엇입니까?'라고 물었습니다. 리스너를 만들 수있는 방법은 세 가지가 있습니다. - @KafkaListener, @StreamListener 또는 @ServiceActivator과 함께 메서드에 주석을 추가하십시오. 모두가 들어오는 이벤트를 듣고있는

0열

1답변

MaplStream with spring integration 카프카 제작자 문제

저는 스프링 통합으로 mapr-stream을 사용하고 maprstream 주제에 메시지를 보내기 위해 게시자를 만들려고합니다. here을 언급 한 아래 Jar 버전 호환성 매트릭스를 사용하고 있습니다. 봄 - 통합 - 카프카 - 2.0.1.RELEASE 봄 - 카프카 - 1.0.3.RELEASE 카프카 - 클라이언트 - 0.9.0.0 - mapr - 160

0열

1답변

kafka 클러스터가 다운 된 후 @KafkaListener가 무한 루프에 빠진다.

나는 3 개의 노드를 가진 kafka 클러스터를 가지고 있으며, debezium (kafka-mysql 커넥터)을 사용한다. 주제 소비자로 @KafkaListener과 함께 메소드를 작성합니다. 그런 다음 kafka 클러스터를 수동으로 종료합니다 (kill -15). 그러면 청취자가 갑자기 무한 루프가됩니다. 최고 명령 jstack을 그리고 소비자 로그 (