RE: kafka 0.8 producer issue

2015-11-25 Thread Kudumula, Surender
m the stacktrace:- at com.hpe.ssmamp.kafka.KafkaPDFAProducer$1.onCompletion( KafkaPDFAProducer.java:62) Please provide more information like a code snippet etc, so that we can tell more Thanks, Prabhjot On Wed, Nov 25, 2015 at 9:24 PM, Kudumula, Surender < surender.kudum...@hpe.com> wrote

kafka 0.8 producer issue

2015-11-25 Thread Kudumula, Surender
Hi all I am trying to get the producer working. It was working before but now getting the following issue. I have created a new topic as well just in case if it was the issue with topic but still no luck. I have increased the message size in broker as iam trying to send atleast 3mb message here

kafka producer and client use same groupid

2015-11-24 Thread Kudumula, Surender
Hi all Is there anyway we can ensure in 0.8 that kafka remote producer and remote consumer work on the same groupId as my java consumer cannot consume messages from remote producer. Thanks

kafka java consumer not consuming messsages produced by remote client

2015-11-23 Thread Kudumula, Surender
Hi all I have a remote java producer producing messages to the same topic where my local kafka java client is subscribed to but it doesn't consume any messages whereas if I ran the consumer from command line I can consume the messages produced by remote client. The following command line consume

issue with javaapi consumer

2015-11-17 Thread Kudumula, Surender
Hi all Iam currently using kafka 0.8.2.1 consumer which has kafka java api consumer but I had to upgrade to kafka 0.8.2.3 and when I add the jars for kafka 0.8.2.3 my consumer code doesn't compile. consumerConnector = ConsumerConfig.createJavaConsumerConnector(consumerConfig); Do I have to rewri