인프런 커뮤니티 질문&답변

안녕하세요! 빅디 입니다.

질문 주신 offset 실행이 안된다는게 무슨 의미인지 정학히 이해가 되진 않지만..우선 아래와 같이 답변 드려봅니다. ^^;; 

위에서 실행하신 카프카 컨슈머 명령은 offset 옵션을 따로 주지 않았기 때문에, 해당 토픽에 프로바이더가 보낸 실시간 메시지 확인만 가능 한 옵션 입니다.

해당 컨슈머 명령을 실행과 동시에 특정 offset부터 데이터를 볼려면 추가 옵션들이 들어가야 합니다.

간단하게 컨슈머 실행과 동시에, 최근 하나의 데이터를 출력 하려면 다음과 같은 옵션을 주고 컨슈머를 실행 하면 됩니다.

--reset-offsets --to-latest --execute

외에도 다양한 offset 옵션들이 있습니다.
관련해 kafka offset 이라는 키워드로 구글링 해보시면 많은 자료를 참고해 보실 수 있습니다.

- 빅디 드림 

kafka-consumer-groups --bootstrap-server <host:port> --group <group> --topic <topic> --reset-offsets --to-earliest --execute

kafka-consumer-groups --bootstrap-server <host:port> --group <group> --topic <topic> --reset-offsets --to-earliest --execute