Hi Robin,
Sorry for the late reply. I'm a little puzzled with your consumer code.
Once the "end" flag is set to true, you won't ever hit the poll() call
again, or am I missing something? Do you even need that inner loop?
-Jason
On Tue, Mar 1, 2016 at 6:06 AM, Péricé Robin wrote:
> Producer : h
Producer : https://gist.github.com/r0perice/9ce2bece76dd4113a44a
Consumer : https://gist.github.com/r0perice/8dcee160017ccd779d59
Console : https://gist.github.com/r0perice/5a8e2b2939651b1ac893
2016-03-01 14:50 GMT+01:00 craig w :
> Can you try posting your code into a Gist (gist.github.com) or P
Can you try posting your code into a Gist (gist.github.com) 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 Consumer class
> doesn't consumer messages properly.
>
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
