로컬에서 카프카 사용시 자주 쓰는 콘솔 명령어 모음


서버 시작

./bin/zookeeper-server-start.sh -daemon config/zookeeper.properties ./bin/kafka-server-start.sh -daemon config/server.properties



토픽 조회

./bin/kafka-topics.sh --list --zookeeper localhost:2181



Producer

./bin/kafka-console-producer.sh --broker-list localhost:9092 --topic topicname



Consumer

./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic topicname --from-beginning



Topic 생성

./bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic topicname



kafka-console-consumer.sh 상세

https://gerardnico.com/dit/kafka/kafka-console-consumer



kafka-consumer-offset-reste 상세

https://www.letmecompile.com/kafka-consumer-offset-reset/



카프카 오프셋 리셋하고 다시 받기

kafka-consumer-groups.sh --bootstrap-server kafka-domain:port --group kafkalocaltestatin --topic topicname --reset-offsets --to-datetime 2018-12-12T00:00:00.000 --execute kafka-console-consumer.sh --bootstrap-server kafka-domain:port --topic topicname --consumer-property group.id=kafkalocaltestatin


'Infra > NoSQL&Cache' 카테고리의 다른 글

[KAFKA] 콘솔 명령어 모음  (0) 2018.10.15
Redis 설치 및 커맨드 정리  (0) 2018.08.12
MongoDB 명령어  (0) 2014.03.09
JBoss - Infini Span  (0) 2013.11.20
분산 캐시 Memcached  (0) 2013.11.19

Leave a Comment


to Top