토픽 생성

./bin/kafka-topics.sh --bootstrap-server 127.0.0.1:9092 --create --topic test --replication-factor 2 --partitions 3

토픽 목록 / 상세정보 확인

./bin/kafka-topics.sh --bootstrap-server 127.0.0.1:9092 --list
# __consumer_offsets
# test
 
./bin/kafka-topics.sh --bootstrap-server 127.0.0.1:9092 --describe --topic test
# Topic: test   PartitionCount: 1   ReplicationFactor: 1    Configs: segment.bytes=1073741824
#   Topic: test Partition: 0    Leader: 0   Replicas: 0 Isr: 0

토픽 파티션 수 추가

./bin/kafka-topics.sh --bootstrap-server 127.0.0.1:9092 --alter --topic test --partitions 5

파티션 옵션 추가/삭제

# test 토픽의 retention.ms 옵션 추가
./bin/kafka-configs.sh --bootstrap-server 127.0.0.1:9092 --alter --entity-type topics --entity-name tset --add-config retention.ms=3600000
 
 
# test 토픽의 retention.ms 옵션 삭제
./bin/kafka-configs.sh --bootstrap-server 127.0.0.1:9092 --alter --entity-type topics --entity-name tset --ㅇ딛ㅅㄷ-config retention.ms

메시지 생산

./bin/kafka-console-producer.sh --broker-list 127.0.0.1:9092 --topic test
# > test1
# > test2

메시지 소비

./bin/kafka-console-consumer.sh --bootstrap-server 127.0.0.1:9092 --topic test --from-beginning
# test1
# test2

컨슈머 그룹 상태 확인 / 오프셋 확인

./bin/kafka-consumer-groups.sh --bootstrap-server 127.0.0.1:9092 --list
# console-consumer-59286
# console-consumer-64621
 
 
./bin/kafka-consumer-groups.sh --bootstrap-server 127.0.0.1:9092 --describe --group console-consumer-81132
 
# Consumer group 'console-consumer-81132' has no active members.
#
# GROUP                  TOPIC           PARTITION  CURRENT-OFFSET  LOG-END-OFFSET  LAG             CONSUMER-ID     HOST            CLIENT-ID
# console-consumer-81132 test            1          42222           42222           0               -               -               -
# console-consumer-81132 test            0          97139           97139           0               -               -               -
# console-consumer-81132 test            2          41123           41123           0               -               -               -