kafka-topics --create --bootstrap-server kafka-1:9092,kafka-2:9093,kafka-3:9094 --replication-factor 3 --partitions 1 --topic mytopic-3-1
kafka-topics --create --bootstrap-server kafka-1:9092,kafka-2:9093,kafka-3:9094 --replication-factor 3 --partitions 3 --topic mytopic-3-3
kafka-topics --list --bootstrap-server kafka-1:9092,kafka-2:9093,kafka-3:9094
kafka-console-producer --broker-list kafka-1:9092,kafka-2:9093,kafka-3:9094 --topic mytopic-3-1
1
2
3
4
5
6
7
8
9
10
kafka-console-producer --broker-list kafka-1:9092,kafka-2:9093,kafka-3:9094 --topic mytopic-3-3
1
2
3
4
5
6
7
8
9
10
kafka-console-consumer --bootstrap-server kafka-1:9092,kafka-2:9093,kafka-3:9094 --topic mytopic-3-1 --from-beginning
kafka-console-consumer --bootstrap-server kafka-1:9092,kafka-2:9093,kafka-3:9094 --topic mytopic-3-3 --from-beginning
'Data Engineering > Kafka' 카테고리의 다른 글
[kafka] 카프카 실행 전후 주키퍼의 znode 확인하기 (0) | 2022.06.17 |
---|---|
[kafka] 주키퍼와 카프카의 모든 볼륨 마운트하기 (0) | 2022.06.17 |
[kafka] 토픽 생성시 --replication-factor --partitions 확인하기 (0) | 2022.06.12 |
[kafka] Error while executing topic command : Replication factor: 4 larger than available brokers: 3. (0) | 2022.06.12 |
[kafka] kafka cluster 구성 후 토픽 생성시의 현상 확인해보기 (2) | 2022.06.12 |