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}'
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
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 |