Re: Writing a Producer from Scratch

2016-03-03 Thread Péricé Robin
Oups didn't see your response. Sorry 2016-03-03 17:23 GMT+01:00 Péricé Robin : > Hi, > > Maybe you should look at this : https://github.com/edenhill/librdkafka > > Regards, > > Robin > > 2016-03-03 11:47 GMT+01:00 Hopson, Stephen : > >> Hi, >>

Re: Writing a Producer from Scratch

2016-03-03 Thread Péricé Robin
Hi, Maybe you should look at this : https://github.com/edenhill/librdkafka Regards, Robin 2016-03-03 11:47 GMT+01:00 Hopson, Stephen : > Hi, > > Not sure if this is the right forum for this question, but if it not I’m > sure someone will direct me to the proper one. > > Also, I am new to Kafka

Consumers doesn't always poll first messages

2016-03-02 Thread Péricé Robin
Hello everybody, I'm testing the new 0.9.0.1 API and I try to make a basic example working. *Java code* : *Consumer *: http://pastebin.com/YtvW0sz5 *Producer *: http://pastebin.com/anQay9YE *Test* : http://pastebin.com/nniYLsHL *Kafka configuration* : *Zookeeper propertie*s : http://pastebin.

Re: KafkaConsumer poll() problems

2016-03-01 Thread Péricé Robin
or Pastebin, > so > it's formatted and easier to read? > > On Tue, Mar 1, 2016 at 8:49 AM, Péricé Robin > wrote: > > > Hello everybody, > > > > I'm having troubles using KafkaConsumer 0.9.0.0 API. My Cons

KafkaConsumer poll() problems

2016-03-01 Thread Péricé Robin
Hello everybody, I'm having troubles using KafkaConsumer 0.9.0.0 API. My Consumer class doesn't consumer messages properly. - | *Consumer*.java | - public final void run() { try { *consumer.subscribe(Collections.singletonList(topicName));* boolean

Re: Consumer seek on 0.9.0 API

2016-02-22 Thread Péricé Robin
gt; partition > >> assignments. Try calling poll() before you call seek(), then poll() > again > >> and process the records from the latter poll(). > >> > >> There may be a better way to do this -- let's see if anyone else has a > >> suggestion. > &g

Re: Consumer seek on 0.9.0 API

2016-02-18 Thread Péricé Robin
> > Alex > > On Wed, Feb 17, 2016 at 9:13 AM, Péricé Robin > wrote: > > > Hi, > > > > I'm trying to use the new Consumer API with this example : > > > > > https://github.com/apache/kafka/tree/trunk/examples/src/main/java/kafka/examples >

Consumer seek on 0.9.0 API

2016-02-17 Thread Péricé Robin
Hi, I'm trying to use the new Consumer API with this example : https://github.com/apache/kafka/tree/trunk/examples/src/main/java/kafka/examples With a Producer I sent 1000 messages to my Kafka broker. I need to know if it's possible, for example, to read message from offset 500 to 1000. What I d