kafka-topics.sh
#만들겠다. 브로커서버는 kafka1이고. 복제본갯수는 3이며. 파티션갯수는 1개다. 토픽이름은 test-topic02다
--create
--bootstrap-server kafka1:9092
--replication-factor 3 --partitions 1
--topic test-topic02
#지우겠다. 브로커서버는 kafka1이고. 토픽이름은 test-topic02다
--delete
--bootstrap-server kafka1:9092
--topic test-topic02
#확인하겠다. 브로커서버는 kafka1이고. 토픽이름은 test-topic02다
--bootstrap-server kafka1:9092
--topic test-topic02
--describe
#만들겠다. 주키퍼서버는 kafka1이고, 복제본갯수는 3이며, 파티션갯수는 2이다. 토픽이름은 test-topic03이다
--create
--zookeeper kafka1:2181
--replication-factor 3 --partitions 2
--topic test-topic03
#확인하겠다. 브로커 서버는 kafka1이고, hello토픽의 키가 kafka인것을 보겠다
--bootstrap-server kafka1:9092
--list hello.kafka
--describe
#설정을 추가하겠다. 브로커 서버는 kafka1이고, 객체타입은 토픽, 객체이름은 hello.kafka이고
#retention.ms옵션을 넣을건데 이건 86400000로 바꾼다
--bootstrap-server kafka1:9092 \
--entity-type topics \
--entity-name hello.kafka \
--alter --add-config retention.ms=86400000
kafka-console-producer.sh
/usr/local/kafka/bin/kafka-console-producer.sh
#토픽을 날릴거고, kafka1와 kafka2에 있는 토픽이름 test-topic02에 메세지를 날릴거다
--broker-list kafka1:9092, kafka2:9092
--topic test-topic02
#토픽을 날릴거고, kafka1와 kafka2에 있는 토픽이름 test-topic03에 메세지를 날릴건데
#구분하는 키를 설정해줄거고, 구분하는 단위는 " "다
--broker-list kafka1:9092, kafka2:9092
--topic test-topic03
--property parse.key=true
--property key.separator=" ",
kafka-console-consumer.sh
/usr/local/kafka/bin/kafka-console-consumer.sh
#토픽을 받을거고 kafka1, kafka2에 있는 토픽test-topic03의 0번파티션을 볼거다
--bootstrap-server kafka1:9092, kafka2:9092
--topic test-topic03 --partition 0
#토픽을 받을거고 kafka1, kafka2에 있는 토픽test-topic03의 0번파티션을 볼거고
#처음부터 보기를 원한다
--bootstrap-server kafka1:9092, kafka2:9092
--topic test-topic03 --partition 0
--from-beginning
kafka-consumer-groups.sh
/usr/local/kafka/bin/kafka-consumer-groups.sh
#kafka1번에 있는 hello-group이라는 컨슈머 그룹에 대한 컨슈머를 진행하겠다
--bootstrap-server kafka1:9092
--list hello-group
