[eclipse-hono#8] Stop consuming the current batch if message handler …

…throws an exception.

Signed-off-by: Abel Buechner-Mihaljevic <[email protected]>

clients/kafka-common/src/main/java/org/eclipse/hono/client/kafka/consumer/AbstractAtLeastOnceKafkaConsumer.java

@@ -247,6 +247,7 @@ private void handleBatch(final KafkaConsumerRecords<String, Buffer> records) {
                 } catch (final RuntimeException messageHandlingError) {
                     LOG.debug("Message handler failed", messageHandlingError);
                     // will commit the offset of the failed record and then resume polling (will include failed record)
+                    break;
                 }
             }
             commit(true).compose(ok -> poll()).onSuccess(this::handleBatch);