콘솔 프로듀서 · 컨슈머로 브로커에 메시지가 오가는지 본다. 모든 도구는 --bootstrap-server 로 브로커를 가리킨다(--zookeeper · --broker-list 는 4.x 에 없다).
$KAFKA_HOME/bin/kafka-topics.sh --bootstrap-server 192.168.103.113:9092 --create --topic test-topic --partitions 3 --replication-factor 3
# Created topic test-topic.
$KAFKA_HOME/bin/kafka-topics.sh --bootstrap-server 192.168.103.113:9092 --describe --topic test-topic
토픽 이름에 . 과 _ 를 섞지 않는다. 메트릭 이름에서 둘이 같은 문자로 바뀌어 충돌할 수 있다는 경고가 뜬다.
$KAFKA_HOME/bin/kafka-console-producer.sh --bootstrap-server 브로커호스트:브로커포트 --topic 토픽명
>이렇게
>메시지를
>넣으면
>consumer 로
>확인할 수 있다.
$KAFKA_HOME/bin/kafka-console-consumer.sh --bootstrap-server 브로커호스트:브로커포트 --topic 토픽명 --from-beginning
이렇게
메시지를
넣으면
consumer 로
확인할 수 있다.
--from-beginning 이 없으면 컨슈머를 띄운 뒤 들어온 메시지만 보인다.
토픽 이름을 받아 컨슈머를 띄운다. 인증이 걸린 클러스터는 --consumer.config 로 SASL PLAIN 인증 의 클라이언트 설정을 준다.
#!/bin/bash
read -p "Enter topic name: " TOPIC
echo "Starting test consuming $TOPIC"
BROKERS=11.22.33.44:9092,11.22.33.43:9092,11.22.33.42:9092
$KAFKA_HOME/bin/kafka-console-consumer.sh --bootstrap-server $BROKERS --topic $TOPIC
# 인증이 있으면
#$KAFKA_HOME/bin/kafka-console-consumer.sh --bootstrap-server $BROKERS --topic $TOPIC --consumer.config $KAFKA_HOME/config/${USER}.properties
$KAFKA_HOME/bin/kafka-producer-perf-test.sh --topic test-topic --num-records 100000 --record-size 1024 --throughput -1 --producer-props bootstrap.servers=192.168.103.113:9092 acks=all
$KAFKA_HOME/bin/kafka-consumer-perf-test.sh --bootstrap-server 192.168.103.113:9092 --topic test-topic --messages 100000