[KAFKA] Consumer CLI


[KAFKA] Consumer CLI

토픽 생성 kafka-topics.sh --bootstrap-server localhost:9092 --topic second_topic --create --partitions 3 Consumer CLI kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic second_topic 위 명령어로 생성된 second_topic을 Consume 하기 시작한다. 위가 Consumer 아래가 Producer이다. kafka-console-producer.sh --bootstrap-server localhost:9092 --producer-property partitioner.class=org.apache.kafka.clients.producer.RoundRobinPartitioner --topic second_topic 라운드 로빈 방식을 적용한 코드이다. 이 방식을 적용하지 않으면 계속 동일한 파티션에 데이터가 쌓이게 된다....


#CLI #카프카

원문링크 : [KAFKA] Consumer CLI