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.
