728x90 반응형 Kafka3 도커를 이용한 kafka, zookeeper, kafka ui, zoonavigator 설치하기 zookeeper가 반드시 있어야 함.kafka UI와 ZooNavigator 는 클라이언트로 사용하면 됨docker run -d --name zookeeper --network elastic-net -p 2181:2181 -e "ZOO_MY_ID=1" -e "ZOO_PORT=2181" -e "ZOO_CLIENT_PORT=2181" -e "ALLOW_ANONYMOUS_LOGIN=yes" zookeeper:3.6.3docker run -d --name kafka --network elastic-net -p 9092:9092 \ -e "KAFKA_BROKER_ID=1" \ -e "KAFKA_CFG_ZOOKEEPER_CONNECT=zookeeper:2181" \ -e "KAFKA_CFG_LISTENER_.. 2025. 6. 26. kafka prosumer (Python), consumer(C++) 샘플소스 소스 # pip install confluent-kafkafrom confluent_kafka import Producerimport jsonproducer = Producer({'bootstrap.servers': '172.24.195.146:9092'})topic_name = "quickstart-events"message = { "code": "A005930", "code_name": "삼성전자", "price": 53700}# message를 JSON 문자열로 변환하고 UTF-8로 인코딩message_json = json.dumps(message).encode('utf-8')producer.produce(topic=topic_name, value=message_json)producer... 2024. 12. 26. WSL2 에서 KAFKA 설치및 테스트 설치과정이 모두 동일하기 때문에 WSL2가 특별히 중요한게 아니다.=======================================================================================01. 다운로드 https://kafka.apache.org/downloadsScala 2.13 - kafka_2.13-3.9.0.tgz (asc, sha512) 02. 압축풀기-> root 계정으로 해야 함 /home/goldencrab/kafka_2.13-3.9.0 03. 사용할 수 있는 언어들 https://cwiki.apache.org/confluence/display/KAFKA/Clients04. kafka 기동 ===> 한글이 깨지지 않도록 하려고 하는데....kafka에.. 2024. 12. 24. 이전 1 다음 728x90 반응형