kcat

Apache Kafka 생산자 및 소비자 도구. 더 많은 정보: https://github.com/edenhill/kcat.

• 최신 오프셋부터 메시지 소비:

kcat -C -t 토픽 -b 브로커

• 가장 오래된 오프셋부터 메시지를 소비하고 마지막 메시지를 받은 후 종료:

kcat -C -t 토픽 -b 브로커 -o beginning -e

• Kafka 소비자 그룹으로 메시지 소비:

kcat -G 그룹_ID 토픽 -b 브로커

• stdin에서 읽어 메시지 게시:

echo 메시지 | kcat -P -t 토픽 -b 브로커

• 파일에서 읽어 메시지 게시:

kcat -P -t 토픽 -b 브로커 경로/대상/파일

• 모든 토픽 및 브로커의 메타데이터 나열:

kcat -L -b 브로커

• 특정 토픽의 메타데이터 나열:

kcat -L -t 토픽 -b 브로커

• 특정 시간에 대한 토픽/파티션의 오프셋 가져오기:

kcat -Q -t 토픽:파티션:유닉스_타임스탬프 -b 브로커