Kafka Throttled commit: Handle case where consumer committed throws error (ex. WakeupException)

Author: ozangunalp

smallrye-reactive-messaging-kafka/src/main/java/io/smallrye/reactive/messaging/kafka/commit/KafkaThrottledLatestProcessedCommit.java

@@ -231,6 +231,7 @@ public <K, V> Uni<IncomingKafkaRecord<K, V>> received(IncomingKafkaRecord<K, V>
             } else {
                 uni = consumer.committed(recordsTopicPartition)
                         .emitOn(this::runOnContext) // Switch back to event loop
+                        .onFailure().recoverWithItem(Collections::emptyMap)
                         .onItem().transform(offsets -> {
                             OffsetAndMetadata lastCommitted = offsets.get(recordsTopicPartition);
                             OffsetStore store = new OffsetStore(recordsTopicPartition, unprocessedRecordMaxAge,