Mailing-List: contact user-help@flink.apache.org; run by ezmlm
Precedence: bulk
Reply-To: user@flink.apache.org
From: Tanguy Racinet <tanracinet@gmail.com>
Content-Type: multipart/alternative;
 boundary="Apple-Mail=_04C77A66-4546-4807-B5B8-D57509B8193E"
Subject: consume kafka stream with flink
Message-Id: <A41E8C5B-1FDF-4E07-93CF-E34EE12AE54D@gmail.com>
Date: Fri, 12 Feb 2016 12:07:47 +0100
To: user@flink.apache.org
Mime-Version: 1.0 (Mac OS X Mail 7.3 \(1878.6\))


--Apple-Mail=_04C77A66-4546-4807-B5B8-D57509B8193E
Content-Transfer-Encoding: quoted-printable
Content-Type: text/plain;
	charset=windows-1252

Hello,

I am currently trying to develop am algorithm mining frequent item sets =
over a data stream.
I am using kafka to generate the stream, however I cannot manage to link =
Flink to Kafka.

The code presented here is working but only using Flink version 0.9.1
=
https://github.com/dataArtisans/kafka-example/blob/master/src/main/java/co=
m/dataartisans/ReadFromKafka.java
It doesn=92t work for me when using FLink 10-SNAPSHOT or the latest =
release.

I tried several other things and was hoping someone could help me =
understand the differences between kafkaSource, FlinkKafkaConsummer, =
FlinkKafkaConsummer081 and FlinkKafkaConsummer082.

Which one is the latest API ? Is there another way to consume Kafka =
steam with Flink that is even more up to date ? Or should I use =
FlinkKafkaConsummer082 and stay with Flink version 9 ?

Thank you for your help.
Regards,
Tanguy R.=

--Apple-Mail=_04C77A66-4546-4807-B5B8-D57509B8193E
Content-Transfer-Encoding: quoted-printable
Content-Type: text/html;
	charset=windows-1252

<html><head><meta http-equiv=3D"Content-Type" content=3D"text/html =
charset=3Dwindows-1252"></head><body style=3D"word-wrap: break-word; =
-webkit-nbsp-mode: space; -webkit-line-break: =
after-white-space;">Hello,<div><br></div><div>I am currently trying to =
develop am algorithm mining frequent item sets over a data =
stream.</div><div>I am using kafka to generate the stream, however I =
cannot manage to link Flink to Kafka.</div><div><br></div><div>The code =
presented here is working but only using Flink version =
0.9.1</div><div><a =
href=3D"https://github.com/dataArtisans/kafka-example/blob/master/src/main=
/java/com/dataartisans/ReadFromKafka.java">https://github.com/dataArtisans=
/kafka-example/blob/master/src/main/java/com/dataartisans/ReadFromKafka.ja=
va</a></div><div>It doesn=92t work for me when using FLink 10-SNAPSHOT =
or the latest release.</div><div><br></div><div style=3D"widows: 1;">I =
tried several other things and was hoping someone could help me =
understand the differences between kafkaSource, FlinkKafkaConsummer, =
FlinkKafkaConsummer081 and FlinkKafkaConsummer082.</div><div =
style=3D"widows: 1;"><br></div><div style=3D"widows: 1;">Which one is =
the latest API ? Is there another way to consume Kafka steam with Flink =
that is even more up to date ? Or should I use FlinkKafkaConsummer082 =
and stay with Flink version 9 ?</div><div style=3D"widows: =
1;"><br></div><div style=3D"widows: 1;">Thank you for your =
help.</div><div style=3D"widows: 1;">Regards,</div><div style=3D"widows: =
1;">Tanguy R.</div></body></html>=

--Apple-Mail=_04C77A66-4546-4807-B5B8-D57509B8193E--