Re: Getting java.lang.Exception when try to fetch data from Kafka

gt;>>> >>>>> org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:225) >>>>> at org.apache.flink.runtime.taskmanager.Task.run(Task.java:559) >>>>> at java.lang.Thread.run(Thread.java:745) >>>>> Caused by: java

Re: Getting java.lang.Exception when try to fetch data from Kafka

nedByte(DataInputDeserializer.java:298) >>>> at >>>> org.apache.flink.types.StringValue.readString(StringValue.java:771) >>>> at >>>> >>>> org.apache.flink.api.common.typeutils.base.StringSerializer.deserialize(StringSerializer.java

Re: Getting java.lang.Exception when try to fetch data from Kafka

Hi Robert , Hi I have java program to send data into kafka topic. below is code for this : private Producer producer = null Serializer keySerializer = new StringSerializer(); Serializer valueSerializer = new ByteArraySerializer(); producer = new KafkaProducer

Re: Getting java.lang.Exception when try to fetch data from Kafka

Hi I have java program to send data into kafka topic. below is code for this : private Producer producer = null Serializer keySerializer = new StringSerializer(); Serializer valueSerializer = new ByteArraySerializer(); producer = new KafkaProducer(props,

Re: Getting java.lang.Exception when try to fetch data from Kafka

Hi I have java program that sending data into kafka topic using kafa client API (0.8.2) here is sample to code using to send data in kafka topic : import org.apache.kafka.clients.producer.Producer; import org.apache.kafka.clients.producer.ProducerConfig; import

Re: Getting java.lang.Exception when try to fetch data from Kafka

Hi Prateek, were the messages written to the Kafka topic by Flink, using the TypeInformationKeyValueSerializationSchema ? If not, maybe the Flink deserializers expect a different data format of the messages in the topic. How are the messages written into the topic? On Fri, Apr 22, 2016 at

Getting java.lang.Exception when try to fetch data from Kafka

Hi I am sending data using kafkaProducer API imageRecord = new ProducerRecord(topic,messageKey, imageData); producer.send(imageRecord); And in flink program try to fect data using FlinkKafkaConsumer08 . below are the sample code