Cloudkarafka
클라우드에서 관리되는 apache kafka 서버로, 카프카의 설정, 실행 및 확장 등을 자동화시킨 서비스를 제공한다.
cloud에 대한 자세한 내용은 아래 아파치 카프카의 공식 홈페이지에서 확인할 수 있다.
https://www.cloudkarafka.com/docs/index.html
Documentation - CloudKarafka, Apache Kafka Message streaming as a Service
Documentation Getting started CloudKarafka are managed Apache Kafka servers in the cloud. Kafka is a distributed publish-subscribe messaging systems that is designed to be fast, scalable, and durable. It's an open-source message broker written in Scala and
www.cloudkarafka.com
cloudkarafka getting start - python
툴은 Visual Studio를 사용
1. 원하는 디렉터리 경로에서 아래 명령어를 입력
git clone https://github.com/CloudKarafka/python-kafka-example.git
2. visual studio에서 해당 프로젝트 오픈
3. 환경변수 설정을 위해서 cloudkarafka의 왼쪽 메뉴바의 [Detail] 클릭
Connection details의 Download를 클릭하여 instance 정보가 담긴 txt 파일을 다운로드
4. 3번의 txt파일의 정보를 가지고, 터미널로 환경변수 설정
~ export CLOUDKARAFKA_BROKERS="rocket-01.srvs.cloudkafka.com:9094,rocket-02.srvs.cloudkafka.com:9094,rocket-03.srvs.cloudkafka.com:9094"
~ export CLOUDKARAFKA_USERNAME="it5v25et"
~ export CLOUDKARAFKA_PASSWORD="xDjmU_mpuzRcoux8pjFkPJAmgutBU0ar"
~ export CLOUDKARAFKA_TOPIC="it5v25et-testTopic"
// TOPIC은 "username-내가정한인스턴스이름"
5. 환경변수 설정을 끝내고 터미널로 consumer.py 실행
~ python consumer.py
6. 또 다른 Terminal을 열고 producer.py 실행
~ python producer.py
7. cloudkarafka에서 producer에서 메시지 적재
메시지 적재가 된 것을 Terminal에서 확인할 수 있다.
'Database > Kafka' 카테고리의 다른 글
| Kafka message(data) 보관주기 설정 (0) | 2020.07.30 |
|---|---|
| Kafka QuickStart (0) | 2020.07.30 |
| centOS 8에 Kafka 설치 (0) | 2020.07.28 |
| [MacOS] Cloudkarafka로 kafka 맛보기 (1) | 2020.07.24 |