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.

Reply via email to