Hi all,

We're using Apache Kafka 0.9, and in our 0.8.2 Kafka, we had a consumer
which used a ConsumerConnector to stream all the messages to be processed.

The new KafkaConsumer seems to use a polling mechanism instead of
streaming, and I was wondering: what is the 'right' way to go forward?
Should I poll with 0 millis? Should I poll every 100ms and accept the
polling delay? Should I stick to the previous way and keep using the
ConsumerConnector to stream the messages per topic?

I'm just wondering what the best way forward is, and I hope somebody can
give me a bit of advice in this.

Thanks,

Erik

Reply via email to