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