Hi Ashutosh,
I used the same connector to read from the Kafka, it is working fine. but
writing has the mentioned issue!
On Wed, Jun 1, 2016 at 12:37 PM, Ashutosh Kumar
wrote:
> How are you packaging and deploying your jar ? I have tested with flink
> and kafka .9 . It works fine for me .
>
> Th
I run it in Eclipse IDE,
On Wed, Jun 1, 2016 at 12:37 PM, Ashutosh Kumar
wrote:
> How are you packaging and deploying your jar ? I have tested with flink
> and kafka .9 . It works fine for me .
>
> Thanks
> Ashutosh
>
> On Wed, Jun 1, 2016 at 3:37 PM, ahmad Sa P wrote:
>
>> I did test it with K
How are you packaging and deploying your jar ? I have tested with flink and
kafka .9 . It works fine for me .
Thanks
Ashutosh
On Wed, Jun 1, 2016 at 3:37 PM, ahmad Sa P wrote:
> I did test it with Kafka 0.9.0.1, still the problem exists!
>
> On Wed, Jun 1, 2016 at 11:50 AM, Aljoscha Krettek
>
I did test it with Kafka 0.9.0.1, still the problem exists!
On Wed, Jun 1, 2016 at 11:50 AM, Aljoscha Krettek
wrote:
> The Flink Kafka Consumer was never tested with Kafka 0.10, could you try
> it with 0.9. The 0.10 release is still very new and we have yet to provide
> a consumer for that.
>
>
The Flink Kafka Consumer was never tested with Kafka 0.10, could you try it
with 0.9. The 0.10 release is still very new and we have yet to provide a
consumer for that.
On Wed, 1 Jun 2016 at 10:47 ahmad Sa P wrote:
> Hi Aljoscha,
> I have tried different version of Flink V 1.0.0 and 1.0.3 and K
Hi Aljoscha,
I have tried different version of Flink V 1.0.0 and 1.0.3 and Kafka
version 0.10.0.0.
Ahmad
On Wed, Jun 1, 2016 at 10:39 AM, Aljoscha Krettek
wrote:
> This is unrelated to joda time or Kryo, that's just an info message in the
> log.
>
> What version of Flink and Kafka are you usi
This is unrelated to joda time or Kryo, that's just an info message in the
log.
What version of Flink and Kafka are you using?
On Wed, 1 Jun 2016 at 07:02 arpit srivastava wrote:
> Flink uses kryo serialization which doesn't support joda time object
> serialization.
>
> Use java.util.date or
Flink uses kryo serialization which doesn't support joda time object
serialization.
Use java.util.date or you have to change kryo.
Thanks,
Arpit
On Tue, May 31, 2016 at 11:18 PM, ahmad Sa P wrote:
> Hi
> I have a problem at running a sample code from the hands-in examples of
> Apache Flink,
>
Hi
I have a problem at running a sample code from the hands-in examples of
Apache Flink,
I used the following code to send output of a stream to already running
Apache Kafka, and get the below error. Could anyone tell me what is going
wrong?
Best regards
Ahmad
public class RideCleansing {
p
