Ok, thank you all for the clarification. @Stephan: I'm using Kafka 0.10, I guess the problem I had then was actually unrelated to specific Kafka version
Federico D'Ambrosio Il 21 set 2017 16:30, "Stephan Ewen" <se...@apache.org> ha scritto: > +1 > > @ Frederico: I think Aljoscha is right - Flink only executes Kafka client > code, which is Scala independent from 0.9 on. Do you use Kafka 0.8 still? > > On Wed, Sep 20, 2017 at 10:00 PM, Aljoscha Krettek <aljos...@apache.org> > wrote: > >> Hi Federico, >> >> As far as I know, the Kafka client code has been rewritten in Java for >> version 0.9, meaning there is no more Scala dependency in there. Only the >> server (broker) code still contains Scala but it doesn't matter what Scala >> version a client uses, if any. >> >> Best, >> Aljoscha >> >> On 20. Sep 2017, at 14:32, Federico D'Ambrosio <fedex...@gmail.com> >> wrote: >> >> Hi, as far as I know some vendors like Hortonworks still use Kafka_2.10 >> as part of their hadoop distribution. >> Could the use of a different scala version cause issues with the Kafka >> connector? I'm asking because we are using HDP 2.6 and we once already had >> some issue with conflicting scala versions concerning Kafka (though, we >> were using Storm, I still haven't tested the Flink connector in this >> context). >> >> Regards, >> Federico >> >> 2017-09-20 14:19 GMT+02:00 Ted Yu <yuzhih...@gmail.com>: >> >>> +1 >>> >>> -------- Original message -------- >>> From: Hai Zhou <yew...@gmail.com> >>> Date: 9/20/17 12:44 AM (GMT-08:00) >>> To: Aljoscha Krettek <aljos...@apache.org>, d...@flink.apache.org, user < >>> user@flink.apache.org> >>> Subject: Re: [DISCUSS] Dropping Scala 2.10 >>> >>> +1 >>> >>> > 在 2017年9月19日，17:56，Aljoscha Krettek <aljos...@apache.org> 写道： >>> > >>> > Hi, >>> > >>> > Talking to some people I get the impression that Scala 2.10 is quite >>> outdated by now. I would like to drop support for Scala 2.10 and my main >>> motivation is that this would allow us to drop our custom Flakka build of >>> Akka that we use because newer Akka versions only support Scala 2.11/2.12 >>> and we need a backported feature. >>> > >>> > Are there any concerns about this? >>> > >>> > Best, >>> > Aljoscha >>> >>> >> >> >> -- >> Federico D'Ambrosio >> >> >> >
