티스토리 뷰

Infra

Kafka 명령어 정리

zeroco2 2024. 3. 19. 14:13 
[root@server2 bin]# ./kafka-topics.sh --list --bootstrap-server <broker-hostname:port>

# topic 조회
./kafka-topics.sh --bootstrap-server=119.207.76.29:9092 --list

# topic 추가
./kafka-topics.sh --create --topic ma-prop --bootstrap-server=119.207.76.29:9092 --replication-factor 3 --partitions 20

# cosumer 실시간 보기 
./bin/kafka-console-consumer.sh --bootstrap-server 119.207.76.29:9092 --topic ma-evt --from-beginning

 

 

저작자표시 비영리 변경금지 (새창열림)