Apache 폭풍과 RabbitMQ Spout on Clojure

Question

이전에 Kafka를 데이터 소스로 사용하고 있었지만 매우 강력했지만 다소 가파른 학습 곡선을 사용하여 부분적으로 작동하도록 관리했지만 여기 저기에 약간의 발목이 있었지만하지 않았습니다. 생산에서 그것을 유지하는 것이 편안함을 느낀다.

Rabbitmq로 전환하기로 결정 했으므로 좀 더 익숙해졌지만 약간의 문제가있었습니다.

Rabbitmq에서 Apache Storm Spouting 용 Clojure 라이브러리를 찾을 수 없습니다. BaseRichSpout을 확장해야합니까? 아니면 누군가 유용한 라이브러리를 가르쳐 줄 수 있습니까?

Answer 1

명확한 컷 라이브러리가 없으므로 "BaseRichSpout"을 Java 코드로 확장하고 jar 파일로 컴파일 한 다음 코드를 가져 와서 코드를 가져 왔습니다.

스톰 클러스터가 백 타이프 버전 (예 : 이전 버전의 폭풍우)을 실행하고 있었기 때문에 주변에서 약간의 비방이있었습니다.

그러나 this은 내가 사용한 샘플 코드입니다.