[Kafka] 자주 사용하는 콘솔 명령어 (2) - Producer / Consumer

■ Producer (메세지 송신)

1) 메세지 송신 

$ ./kafka-console-producer.sh --broker-list 192.168.145.131:9191,192.168.145.132:9192 --topic TEST_TOPIC

 

 

2) 대량 메세지 송신 (500 byte메세지를 초당 만건씩, 100만건 송신) 

$ ./kafka-producer-perf-test.sh --topic TEST_TOPIC --throughput 1000 --record-size 500 --num-records 10000 --producer-propsbootstrap.servers=192.168.145.131:9191,192.168.145.132:9192

 

---

■ Consumer(메세지 수신)

1) 메세지 수신

$ ./kafka-console-consumer.sh -bootstrap-server 192.168.145.131:9191,192.168.145.132:9192 --topic TEST_TOPIC 

 

 

2) 첫 오프셋부터 메세지 읽기

$ ./kafka-console-consumer.sh -bootstrap-server 192.168.145.131:9191,192.168.145.132:9192 --from-beginning --topic TEST_TOPIC 

 

 

3) 특정 파티션의 메세지 수신

$ ./kafka-console-consumer.sh -bootstrap-server 192.168.145.131:9191,192.168.145.132:9192 --partition 1 --topic TEST_TOPIC 

 

 

4) 대량 메세지 수신 (100만건)

$ ./kafka-consumer-perf-test.sh --zookeeper 192.168.145.131:2181,192.168.145.132:2182 --messages 1000000 --topic TEST_TOPIC --threads 1 --group test.group --show-detailed-stats