카프카에서 오프셋 읽기

나는 카프카에서 수동 오프셋 커밋을 할 것입니다. consumer.commitOffsets() 할 때마다 커밋 된 오프셋 목록을 가져 오는 방법이 있습니까? 오후 8시 30 분 P.S. 나는 높은 수준의 소비자를 사용하고있다.카프카에서 오프셋 읽기

2016-08-10 Try1

사용중인 Kafka 버전 또는 클라이언트 (즉, 언어)를 잘 모릅니다. 자바 높은 수준의 소비자는 파티션 오프셋 최선을 다하고 최신을받을 수

KafkaConsumer#committed(TopicPartition partition);

을 제공합니다. 따라서 커밋을 한 후에 이것을 호출 할 수 있습니다. 당신이 커밋하기 전에 오프셋을 알고 싶다면

, 당신은 마지막 poll()의 파티션 당 각각 마지막 메시지를 상쇄하는 데 필요한. 레코드를 처리 할 때 따라서, poll() 후에는

ConsumerRecord#offset()

를 통해이 정보를 얻을 필요

2016-08-10 08:23:32

답변