kafka console 명령어 모음

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


bin/kafka-console-producer.sh --topic test5 --bootstrap-server localhost:9092

# 토픽 생성
bin/kafka-topics.sh --create --topic test4 --partitions 2 --bootstrap-server localhost:9092 --replication-factor 2

 

# 오프셋 변경
./kafka-consumer-groups --bootstrap-server localhost:9092 --group test3 --topic foo --reset-offsets --to-current --execute

./bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --group 0 --describe

 

4. topic
// 토픽 생성
bin/kafka-topics.sh --create --topic test3 --partitions 4 --bootstrap-server localhost:9092 --replication-factor 2

// topic 목록
bin/kafka-topics.sh --list --bootstrap-server localhost:9092 

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

bin/kafka-console-producer.sh --topic TEST01 --bootstrap-server localhost:9092


// 토픽 삭제
bin/kafka-topics.sh --delete --topic test --bootstrap-server localhost:9092

auto.create.topics.enable=false

# 토픽 파티션 수 변경. 증가만 가능
bin/kafka-topics.sh --bootstrap-server localhost:9092 --alter --topic test3 -partitions 4

#레플리카 증가
{"version":1,
  "partitions":[{"topic":"foo","partition":0,"replicas":[5,6,7]}]}

# 그룹 정보
./bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --group foo  --describe