728x90 반응형 BIG DATA/KAFKA6 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. c++ comsumper 개발환경 구축 참고 : 1. https://docs.confluent.io/clients-librdkafka/current/overview.html 개발환경 설정 1. 라이브러리 인스톨 sudo apt-get install librdkafka-dev 2. Makefile 설정 관련 헤더파일 위치 : /usr/include/librdkafka rdkafka.h rdkafkacpp.h 라이브러리파일 위치 : /usr/lib/x86_64-linux-gnu librdkafka++.a librdkafka++.so librdkafka++.so.1 librdkafka.a librdkafka.so librdkafka.so.1 MYSQLINCDIR = /usr/include/mysql KAFKAINCDIR = /usr/include/.. 2021. 6. 14. goLang consumer 예제 참조원문 : go 언어를 사용한 예제이다. 잘 봐둬야겠다. https://www.joinc.co.kr/w/man/12/Kafka/chatting 2021. 6. 14. 이전 1 2 다음 728x90 반응형