최신 버전의 IBM Message Bus는 Kafka Streams (여기에 설명 됨 .. http://www.confluent.io/blog/introducing-kafka-streams-stream-processing-made-simple/)을 지원합니까? 이 작업을 수행하는 방법에 대한 예제/샘플은 무엇입니까? 2 - 예, 이것은 내가 (베타 서비스를 커넥터 서비스가 bluemix에 존재)는 카프카 스트림에 소스 데이터베이스 (Cloudant)에서 1. 스트림 데이터를하려고 노력하고 무엇 Node.js를Bluemix Kafka 스트림
수행 할 수 있습니다합니다. 카프카 스트림을 사용하여 데이터 (요약, 카운트 등)를 집계합니다. 3. 웹 대시 보드 app -frontend (Node.JS, D3.JS)는 스트림을 소비하고 대시 보드를 실시간으로 업데이트합니다.
당신을 감사당신은 확실히 게시하고 Node.js를를 사용 카프카 (일명 IBM MessageHub)에 가입하고 대시 보드의 모든 종류의 카프카 데이터를 시각화 할 수 있습니다. 요즘 나는 노드 - 레드와 노드 - 레드 - 대시 보드와 노드 - 레드 - 기여 - 웹 - 월드 맵을 사용하여 좋은 결과를 얻었습니다.
nodejs의 Pub/sub는 Confluent REST Proxy (IBM MessageHub 사용) 또는 librdkafka 상단에 쓴 Blizzard (https://github.com/blizzard/node-rdkafka 참조)와 같은 기본 node.js 클라이언트를 통해 수행 할 수 있습니다. Confluent는 REST 프록시 (https://github.com/confluentinc/kafka-rest-node 참조)를보다 쉽게 사용할 수 있도록 nodejs 래퍼 함수를 작성했습니다.
Kafka Streams와 관련하여 현재 지원되는 주요 언어는 Java와 Scala입니다. Javascript의 노드 클라이언트와 Java의 Streams 애플리케이션을 아무런 문제없이 혼합 할 수 있습니다. Kafka Streams는 자바 라이브러리로 구현되어 스트림 프로그램이 가상 머신이나 컨테이너에서 Bluemix로 실행되며 추가 클러스터 관리자 나 타사 인프라가 필요하지 않습니다.
UPDATE : IBM 지금 MessageHub 발표
https://developer.ibm.com/messaging/2017/06/28/messagehub-now-runs-kafka-0-10-2-1-supports-streams/
한스 감사합니다. 나는 버전을 확인하고 Bluemix가 스트림 응용 프로그램 기능을 가진 Kafka v0,10을 지원하는 것처럼 보입니다. Java로 작성된 좋은 예제가 있습니까? Cloudant에 연결하는 Kafka 커넥터 베타 서비스는 버그가있는 것처럼 보입니다. –
Java의 일부 Kafka Streams 예제는 https://github.com/confluentinc/examples –
입니다.이 페이지의 예제에서는 합류 및 동물원 설치를 요청합니다. 궁금한 점이 bluemix에서 어떻게 작동 할 수 있습니까? bluemix는 이미 카프카 클러스터를 제공하며 합류 및 사육사 서비스는 제공되지 않습니다. –
당신이 IBM MessageHub을 의미합니까 카프카 스트림을 지원? –
안녕 한스, 네. IBM Message Hub (bluemix) –