Message Hub에서 Kafka 해보기

처음으로 Watson IoT Platform을 사용해 보자는 분들을 위한 가이드입니다.
Watson IoT Platform 사용하기 에서 IoT 앱을 준비했습니다.
잠깐 가는 길에 Bluemix의 Message Hub에서 Kafka를 사용해보십시오.

1. MessageHub를 준비합니다.


  • Bluiemix 카탈로그의 애플리케이션 서비스에서 "Message Hub"를 인스턴스화합니다.

  • 2. 클라이언트 준비



  • htps : // 이런. 응 g. b 에미 x. 네 t/도 cs/세 rゔぃせ s/메사게후 b/그리고 x. HTML의 절차를 따르십시오.
  • git에서 클라이언트 코드 등을 얻습니다. Java, python, JS(node)의 클라이언트가 준비되어 있습니다. 여기에서는 Java 클라이언트를 사용한 순서를 소개합니다. git clone https://github.com/ibm-messaging/message-hub-samples.git
  • cd message-hub-samples/kafka-java-console-sample 로 이동하고 gradle clean && gradle build 로 빌드합니다.
    gradle이 도입되어 있지 않은 경우, brew install gradle (MacOS)등에서 도입합니다.
  • 이전 섹션에서 제공한 Message Hub 서비스의 서비스 자격 증명 탭을 열고 자격 증명 보기 메뉴에서 api_key , kafka_admin_url , kafka_brokers_sasl kafka_brokers_sasl 는 복수행이므로 ホスト1:ポート1,ホスト2:ポート2,... 의 형식으로 한 줄에 계속해서 준비합니다.

  • 3. 클라이언트를 실행하여 결과를 확인합니다.


  • 여러 Consumer를 시작하십시오
  • java -jar build/libs/kafka-java-console-sample-2.0.jar kafka_brokers_sasl kafka_admin_url api_key -consumer
  • Producer를 시작하고 작동을 확인합니다.
    java -jar build/libs/kafka-java-console-sample-2.0.jar kafka_brokers_sasl kafka_admin_url api_key -producer
  • Producer의 출력
  • 첫 번째 Consumer의 출력
  • 두 번째 Consumer의 출력

  • 4. 참고 정보


  • Getting started with Message Hub
  • ibm-messaging/message-hub-samples
  • Apache Kafka - Documentation
  • Managing IoT devices with Kafka and MQTT
  • Apache Kafka Connect MQTT Source Tutorial
  • 아파치 카프카 입문
  • 좋은 웹페이지 즐겨찾기