[카프카 프로그래밍] kafka-topics.sh

• 토픽생성
  • bin/kafka-topics.sh --create --bootstrap-server my_kafka:9092 --topic hello.kafka
    
• 상세 (파티션이나 rf등이 보고싶다!)
  • bin/kafka-topics.sh --bootstrap-server my_kafka:9092 --topic hello.kafka --describe
    
• 내가 상세한 설정을 다르게 만들고 싶어 (파티션은 10으로, rf는 1로, retention도 바꿔서)
  • bin/kafka-topics.sh --create --bootstrap-server my_kafka:9092 --partitions 10 --replication-factor 1 --topic hello.kafka2 --config retention.ms=1728000000
    
• bin/kafka-topics.sh --bootstrap-server my_kafka:9092 --topic hello.kafka2 --describe
  
  
• 이거를 파티션 11개로 만들고 싶어!
  • bin/kafka-topics.sh --bootstrap-server my_kafka:9092 --topic hello.kafka2 --alter --partitions 11
    
    describe 해보면, 11개 파티션 생성 완료.
    
• 퀴즈! 파티션 5개로 줄이기 가능?
  • 못함. 에러남(InvalidPartitionsException) 줄이는 거 안됨.