[KAFKA] 콘솔 명령어 모음

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

서버 시작

./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