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

Posted by prateekarora on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Getting-java-lang-Exception-when-try-to-fetch-data-from-Kafka-tp6365p6415.html

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 org.apache.kafka.clients.producer.ProducerRecord;

ProducerRecord<String, byte[]> imageRecord;
imageRecord = new ProducerRecord<String, byte[]>(streamInfo.topic,
                        Integer.toString(messageKey), imageData);

producer.send(imageRecord);


Regrads
Prateek