Hi,
I am just wondering if the below snippet ConsumerIterator<byte[], byte[]) it = ... while (True) try { while (it.hasNext()) { ... ... ... } catch (ConsumerTimeoutException e) { // do nothing } } would be more robust than while(it.hasNext()) { ... ... ... }i.e. by setting a consumer timeout, catching it and again just waiting for the next message make it more robust?
Regards, Rahul.