반응형
1. kinaction_helloworld 토픽 만들기
bin/kafka-topics.sh --create --bootstrap-server localhost:9094 --topic kinaction_helloword --partitions 3 --replication-factor 3
2. 토픽 확인하기
bin/kafka-topics.sh --list --bootstrap-server localhost:9094
3. 토픽 세부 정보 조회
bin/kafka-topics.sh --bootstrap-server localhost:9094 --describe --topic kinaction_helloword
4. kafka 프로듀서 콘솔 명령
bin/kafka-console-producer.sh --bootstrap-server localhost:9094 --topic kinaction_helloword
5. kafka 컨슈머 명령
bin/kafka-console-consumer.sh --bootstrap-server localhost:9094 --topic kinaction_helloword --from-beginning
producer창에 메시지 치면 consumer창에서 노출되는 것을 볼 수 있다.
kafka 설치 ▼
https://ddoance.tistory.com/289
[kafka] kafka, zookeeper, server 시작하기 (mac m1)
1. kafka 파일 다운로드 https://kafka.apache.org/quickstart Apache KafkaApache Kafka: A Distributed Streaming Platform.kafka.apache.org 2. 카프카 바이너리 압축 풀기tar -xzf kafka_2.13-3.9.0.tgzmv kafka_2.13-3.9.0 ~/cd ~/kafka_2.13-3.9.
ddoance.tistory.com
반응형
'개발 > kafka' 카테고리의 다른 글
| [kafka] 소비자 그룹 (Consumer Group) (0) | 2025.01.05 |
|---|---|
| [kafka] log compaction | log tail | log head (1) | 2025.01.04 |
| [kafka] producer message key = 메시지 코디네이트(Message Coordinate) (1) | 2025.01.04 |
| [kafka] Kafka Connect High-Level Overview + Cluster and Distributed Architecture (1) | 2025.01.03 |
| [kafka] kafka, zookeeper, server 시작하기 (mac m1) (0) | 2024.12.14 |