Apache NiFi-0.50 이후 니피-kafka-nar 미묘한 손상(수정 중)

1858 단어 KafkaNiFi
지아오 창가 엔지니어 옥리입니다.
현재 맥에 구축된 카프카와 아파치 니피가 시스템 개발을 진행하고 있지만 get 카프카는 이동이 불가능한 문제에 직면해 이번 주 완전히 빠져들었다.
안 마시면 못 마셔. 집에 가서 확인해 봤는데 마시면 해결돼.
슈퍼 의역
I've upgraded from Nifi 0.4.1 to 0.5.0 and I am no longer able to use the GetKafka processor.
0.4.1에서 0.5.0으로 올라가면 Get Kafka가 움직이지 않아요.
Any chance to attache the app-log or relevant stack trace?
app-log 아니면 창고 추적?
The only change that ’s went and relevant to your issue is the fact that we’ve upgraded client libraries to Kafka 0.9 and between 0.8 and 0.9 Kafka introduced wire protocol changes that break compatibility.
I am still digging so stay tuned.
카프카의 클라이언트 라이브러리를 0.9로 올렸지만 프로토콜 호환성이 없어진 것 같습니다.제가 파올게요. 잠시만요.
상세 내용 때문에 생략
I replaced my 0.5.0 kafka nar with the 0.4.1 kakfa nar and it fixed my kafka issue. I renamed the 0.4.1 nar to be 0.5.0.nar and restart nifi and my kafka processor started reading my 0.8.2.1 stream. Not elegant but glad it worked.
0.4.1의 카프카.nar의 이름을 0.5.0으로 복사한 후kafka 0.8.2.1의 흐름을 읽습니다.우아하지는 않지만 움직일 수 있어서 다행이다.
All just as a point of reference we now have a live system running that is on NiFi 0.5.0 and feeding three versions of Kafka at once:
- 0.8.1
- 0.8.2.0
- 0.9.0.1
(중략) Kafka 버전 + NiFi 0.5.0입니다.
brew의 카프카 버전은...완전히 반하다.
[btamari@MBP-15UAC-072 ~]$ brew list kafka
/usr/local/Cellar/kafka/0.8.2.2/bin/kafka-console-consumer.sh
/usr/local/Cellar/kafka/0.8.2.2/bin/kafka-console-producer.sh
어쨌든 복사하고 움직였어!
죄송합니다. 덮어썼습니다.
$ cp nifi-kafka-nar-0.5.1.nar nifi-kafka-nar-0.5.1.nar.org
$ cp ../../nifi-0.4.1/lib/nifi-kafka-nar-0.4.1.nar ./nifi-kafka-nar-0.5.1.nar

인주가 되다.모두 조심하세요...

좋은 웹페이지 즐겨찾기