+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 <[email protected]> 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 <[email protected]> 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 <[email protected]>: > >> +1 >> >> -------- Original message -------- >> From: Hai Zhou <[email protected]> >> Date: 9/20/17 12:44 AM (GMT-08:00) >> To: Aljoscha Krettek <[email protected]>, [email protected], user < >> [email protected]> >> Subject: Re: [DISCUSS] Dropping Scala 2.10 >> >> +1 >> >> > 在 2017年9月19日，17:56，Aljoscha Krettek <[email protected]> 写道： >> > >> > 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 > > >
