flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Till Rohrmann <trohrm...@apache.org>
Subject Re: Flink Streaming API
Date Mon, 01 Aug 2016 13:41:30 GMT
Hi Siva,

in version 1.0.0 we’ve added the Scala binary version suffix to all Flink
dependencies which depend on Scala. Thus, you should look for
flink-streaming-scala_2.10 and flink-streaming-java_2.10. For these
artifacts you should be able to find a version 1.0.3 on maven central, for
example.

The easiest way to setup a project is to use the quickstarts [1]. It will
add the correct dependencies. But usually it should be enough to include
the flink-client_2.10 and the respective API dependency to your project
(e.g. flink-streaming-scala_2.10).

I think that you should be able to use the Flink Kafka connector 0.9 with
Kafka 0.10.0 as long as Kafka 0.10.0 still supports the consumer API
introduced with Kafka 0.9. But I might be wrong here. So best if you tried
it out.

[1]
https://ci.apache.org/projects/flink/flink-docs-master/quickstart/java_api_quickstart.html

Cheers,
Till
​

On Mon, Aug 1, 2016 at 3:48 PM, Siva <sbhavanari@gmail.com> wrote:

> Hello Everyone,
>
> I m new to Flink, wanted to try streaming API using flink-kafka connector
> in scala.
>
> But there are several versions of it. Please could some one help on below
> questions
>
> what are the differences between flink-streaming-core and
> flink-sreaming-scala[java]?
>
> Latest version of flink-streaming-scala of 0.10.2 version, does it mean
> that streaming development in scala can only use Flink 0.10.2 not the
> latest one 1.0.3?
>
> what is difference between flink-connector-kafka-base and
> flink-connector-kafka-0.x.x? Is
> flink-connector-kafka-0.9-2_11 compatible with Kafka 0.10.0?
>
> Thanks in advance.
>
> Thanks
> Siva
>

Mime
View raw message