Kafka ์ด์์ ์ ์ฉํ ๋ช ๋ น์ด
ํ ํฝ ๋ชฉ๋ก ์กฐํ
bin/kafka-topics.sh --zookeeper localhost:2181 --list
ํ ํฝ ์์ธ ์กฐํ
bin/kafka-topics.sh --zookeeper localhost:2181 --describe --topic mytopic
ํ ํฝ ์ญ์
bin/kafka-topics.sh --zookeeper localhost:2181 --delete --topic mytopic (JRE 7 ์ฌ์ฉ์ confluent-3.0.0 ์ฌ์ฉ)
ํ ํฝ ๋ด ๋ฉ์์ง ๊ฐ์ ์กฐํ ???
bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list localhost:9092 --topic mytopic --time -1 --offsets 1 | awk -F ":" '{sum += $3} END {print sum}'
ํ ํฝ ๋ด earliest ์คํ์ ์กฐํ
bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list localhost:9092 --topic mytopic --time -2
ํ ํฝ ๋ด ์ต์ ์คํ์ ์กฐํ
bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list localhost:9092 --topic mytopic --time -1
์ฝ์ ๋ช ๋ น์ด๋ก ๋ฉ์์ง ์ปจ์จํ๊ธฐ
bin/kafka-console-consumer.sh --new-consumer --bootstrap-server localhost:9092 --topic mytopic --from-beginning
์ํ์น ์นดํ์นด ์ปจ์๋จธ ๋ฉํฐ์ฐ๋ ๋๋ก ๋๋ฆฌ๊ธฐ ์ํ ํ
์ฐธ๊ณ ๋ฌธ์ : gist.github.com/ursuad/e5b8542024a15e4db601f34906b30bb5
'๐ป Programming' ์นดํ ๊ณ ๋ฆฌ์ ๋ค๋ฅธ ๊ธ
springboot 2.4 ์ ๊ทธ๋ ์ด๋ ์ gradle ๋ฒ์ ์ค๋ฅ (0) | 2020.11.22 |
---|---|
[MySQL] json ์ปฌ๋ผ ์ ๋ฐ์ดํธ ์๋๋ ํ์ (0) | 2020.10.20 |
์ ๊ท ํํ์ (Regular Expression) (0) | 2020.08.05 |
Eclipse์ lombok ์ค์นํ๊ธฐ (0) | 2020.08.02 |
Eclipse Version M1 M2 M3 R RC SR Difference (0) | 2020.08.02 |