스트롬 - 신뢰할 수있는 스파우트는

스트롬를 설정하는 방법

는 신뢰할 수있는
이
을 설정하는 모든 속성이 kafkaSpout이스트롬 - 신뢰할 수있는 스파우트는

카프카는 기본적으로 신뢰할 수 kafkaSpout의 reliablity를 변경하는 방법 기본적
하여 믿을 수 있습니다 오르네. 여기 카프카 주제에서 메시지를 읽고에 대한 책임 PartitionManager와 클래스의 코드는 다음과 같습니다

collector.emit(tup, new KafkaMessageId(_partition, toEmit.offset()));

당신이 방출 메서드의 두 번째 매개 변수는 KafkaMessageId입니다 볼 수 있듯이. 유사한 방법으로 스파우트에서 메시지 ID를 전달할 수 있습니다. 메시지 id는 일반 정수일 수 있습니다.

2016-06-12 18:43:27

감사합니다. btw, 내 kafkaSpout을 신뢰할 수 없게 설정하는 방법 및 일반 스파우트의 설정 방법도 신뢰할 수 있거나 신뢰할 수없는 것으로 설정하는 방법입니다. – user1942574

답변