Kafka 파티션의 전체 offset를 다시 구독하는 샘플과 특정 offset 을 구독하는 샘플
Kafka Consumer에서 전체 파티션의 offset을 처음부터 재구독하는 샘플과 특정 offset부터 구독하는 샘플 코드를 정리했습니다. 1. 전체 파티션의 오프셋 처음부터 재구독 (처음부터 다시 읽기) KafkaConsumer의 seekToBeginning() 메서드를 사용해, 구독한 파티션 전체 오프셋을 처음(earliest)으로 이동시켜 메시지를 다시 읽기 시작할 수 있습니다. java import org.apache.kafka.clients.consumer.KafkaConsumer; import org.apache.kafka.clients.consumer.ConsumerRecords; import org.apache.kafka.clients.consumer.ConsumerRecord; import org.apache.kafka.common.TopicPartition;import java.time.Duration; import java.util.Collections; import java.util.Properties; import java.util.Set; public class … 더 읽기