일 | 월 | 화 | 수 | 목 | 금 | 토 |
---|---|---|---|---|---|---|
1 | 2 | 3 | 4 | 5 | 6 | 7 |
8 | 9 | 10 | 11 | 12 | 13 | 14 |
15 | 16 | 17 | 18 | 19 | 20 | 21 |
22 | 23 | 24 | 25 | 26 | 27 | 28 |
29 | 30 | 31 |
Tags
- flask
- license delete
- 900gle
- MySQL
- analyzer test
- docker
- Elasticsearch
- License
- TensorFlow
- token filter test
- API
- aggregation
- zip 암호화
- ELASTIC
- plugin
- zip 파일 암호화
- Java
- 차트
- springboot
- matplotlib
- Python
- 파이썬
- query
- Mac
- sort
- high level client
- Test
- licence delete curl
- aggs
- Kafka
Archives
- Today
- Total
개발잡부
[kafka] Mac OS kafka 3.5 본문
반응형
kafka 를 3.5로 올려보잣
https://ldh-6019.tistory.com/228
kafka를 설치 해보자
https://downloads.apache.org/kafka/3.5.0/kafka_2.13-3.5.0.tgz
#다운로드
wget https://downloads.apache.org/kafka/3.5.0/kafka_2.13-3.5.0.tgz
#압축해제
tar -xvzf kafka_2.13-3.5.0.tgz
zookeeper 실행
cd /Users/doo/kafka/kafka_2.13-3.5.0
bin/zookeeper-server-start.sh -daemon config/zookeeper.properties
kafka 실행
bin/kafka-server-start.sh -daemon config/server.properties
확인
netstat -an | grep 2181
실행 확인
토픽생성
#bin/kafka-topics.sh --create --topic quickstart-event --bootstrap-server localhost:9092
bin/kafka-topics.sh --create --topic 900gle --bootstrap-server localhost:9092
Network 에러 나면
주석제거
listeners=PLAINTEXT://:9092
토픽 확인
bin/kafka-topics.sh --describe --topic 900gle --bootstrap-server localhost:9092
producer 실행
bin/kafka-console-producer.sh --topic 900gle --bootstrap-server localhost:9092
consumer 실행
bin/kafka-console-consumer.sh --topic 900gle --from-beginning --bootstrap-server localhost:9092
producer 에서 메시지 입력하면 consumer 에서 보여진다
좌 : consumer, 우 : producer
반응형
'Kafka' 카테고리의 다른 글
[kafka] docker compose kafka (0) | 2022.10.22 |
---|---|
[kafka] kafka 버전 확인 (0) | 2022.10.13 |
[kafka] kafka-full (0) | 2022.08.27 |
Error response from daemon: Container 2c8318196be216b730907022eccaffc314fdd7e5d8e0286ea3f6b1d219acd5c0 is restarting, wait until the container is running (0) | 2022.08.27 |
[kafka] docker dompose multi broker kafka 3.6 (0) | 2022.08.27 |
Comments