mirror of
https://github.com/tldr-pages/tldr.git
synced 2025-04-29 23:24:55 +02:00
37 lines
1,005 B
Markdown
37 lines
1,005 B
Markdown
|
# 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 {{브로커}}`
|