Apache Flume 사용하기 Cygnus의 Kafka sink

Question

Apache Flume과 함께 제공되는 Kafka 싱크대를 사용하고 싶습니다. 그러나 고구마 공통 패키지는 Apache Flume 1.4를 기반으로하는 반면 Kafka 싱크는 Apache Flume 1.7을 기반으로 추가 된 것으로 보입니다. cygnus-common 라이브러리에 Kafka jar 파일을 추가하면 cygnus 공통 코어가 구식이기 때문에 실패합니다.

그래서 cygnus-ngsi 라이브러리와 함께 cygnus-common 대신 최신 flume 버전 (1.8)을 사용할 수 있습니까? 이 경우 나는 Apache Flume Kafka sink와 NGSIKafkaSink 사이를 전환 할 수 있습니까?

Answer 1

저는 UPM Fiware Team의 André입니다. 여러분은 Fiware Cygnus가 Apache Flume 1.4를 기반으로하고 있음을 지적하고 있습니다. 질문에 답하면 Flume의 구형 버전에서 사용 된 싱크가 Cygnus와 호환되지 않을 가능성이 높습니다. 우리는 flume의 최신 릴리즈를 사용하고 원래 방식으로 NGSIV2 통지를 관리하기 위해 Cygnus의 업데이트를 진행하고 있지만 진행중인 작업이며 시간이 걸립니다. 현재 Cygnus 및 kafka 싱크와 함께 작업하는 유일한 방법은 해당 버전에서 FIWARE가 제공 한 GE를 사용하는 것입니다.