Create new Kafka topic and Setting Partitions

bin/kafka-topics.sh

bin/kafka-topics.sh --create

bin/kafka-topics.sh --create --bootstrap-server localhost:9093

bin/kafka-topics.sh --create --bootstrap-server localhost:9093 --topic reviews

"The remote node is not a BROKER"

Broker의 listener는 9092번인데 9093번에 연결을 시도해서 발생한 문제였다.

bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --topic reviews

드디어 Topic(reviews)이 정상적으로 생성되었다.

---

위의 사진을 보면 하나의 reviews partition이 생성된 것을 볼 수 있다.
만약 --partition 3이라는 옵션을 지정한다면 3개의 partition이 생성될 것이다.
partition의 개수를 3개로 변경해보자.

bin/kafka-topics.sh \
--bootstrap-server localhost:9092 \
--alter \
--topic reviews \
--partitions 3

다시 위의 사진을 보면 reviews topic에 대한 partition이 3개로 늘어난 것을 확인할 수 있다.