Update to Quarkus 3.8

bom/pom.xml

@@ -34,7 +34,7 @@
     <cryptvault.version>1.0.2</cryptvault.version>
     <dispatch-router.image.name>quay.io/interconnectedcloud/qdrouterd:1.17.1</dispatch-router.image.name>
     <guava.version>32.1.2-jre</guava.version>
-    <infinispan.version>14.0.11.Final</infinispan.version>
+    <infinispan.version>14.0.27.Final</infinispan.version>
     <infinispan-image.name>quay.io/infinispan/server-native:13.0.12.Final</infinispan-image.name>
     <jaeger.image.name>docker.io/jaegertracing/all-in-one:1.51</jaeger.image.name>
     <java-base-image.name>docker.io/library/eclipse-temurin:17-jre-jammy</java-base-image.name>
@@ -46,7 +46,7 @@
     <native.builder-image.name>mandrel</native.builder-image.name>
     <postgresql-image.name>docker.io/library/postgres:14-alpine</postgresql-image.name>
     <qpid-jms.version>1.10.0</qpid-jms.version>
-    <quarkus.platform.version>3.2.12.Final</quarkus.platform.version>
+    <quarkus.platform.version>3.8.4</quarkus.platform.version>
     <slf4j.version>2.0.6</slf4j.version>
     <spring-security-crypto.version>6.1.4</spring-security-crypto.version>
     <truth.version>1.1.3</truth.version>

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

@@ -1,5 +1,5 @@
 /*******************************************************************************
- * Copyright (c) 2021, 2022 Contributors to the Eclipse Foundation
+ * Copyright (c) 2021 Contributors to the Eclipse Foundation
  *
  * See the NOTICE file(s) distributed with this work for additional
  * information regarding copyright ownership.
@@ -63,9 +63,10 @@
  * completed gets committed. This prevents incompletely handled records and thereby enables at-least-once semantics.
  * <p>
  * In terms of when offsets are committed, the behaviour is similar to the one used for a consumer with
- * <em>enable.auto.commit</em>. Commits are done periodically (using <em>commitAsync</em>) and when a rebalance
- * happens or the consumer is stopped (using <em>commitSync</em>). The periodic commit interval is defined via
- * the standard <em>auto.commit.interval.ms</em> configuration property.
+ * <em>enable.auto.commit</em>. Commits are done periodically (using <em>commitAsync</em>), and they are also done
+ * (using <em>commitSync</em>) when the consumer is stopped or a rebalance happens (with eager rebalancing
+ * or a non-empty revoked partitions list).
+ * The periodic commit interval is defined via the standard <em>auto.commit.interval.ms</em> configuration property.
  * <p>
  * In order to not fall behind with the position of the committed offset vs. the last received offset, users of this
  * class have to make sure that the record handling function, which provides the completion Future, is completed in time.
@@ -90,7 +91,7 @@
  * still done) but record fetching from all assigned topic partitions is suspended until the throttling threshold is
  * reached again.
  * The overall limit, i.e. the maximum number of incomplete record handler result futures at a given point in time, is
- * calculated from the above mentioned throttling threshold plus the maximum number of records per poll operation.
+ * calculated from the above-mentioned throttling threshold plus the maximum number of records per poll operation.
  *
  * @param <V> The type of record payload this consumer can process.
  */
@@ -653,7 +654,7 @@ public OffsetsQueueEntry addOffset(final long offset) {
          * the 'skipOffsetRecommitPeriodSeconds'. Note that for the actual commit, {@code 1} has to be added to the
          * returned value.
          * <p>
-         * Otherwise an empty Optional is returned.
+         * Otherwise, an empty Optional is returned.
          *
          * @return The offset wrapped in an Optional or an empty Optional if no offset commit is needed.
          */

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

@@ -1,5 +1,5 @@
 /*******************************************************************************
- * Copyright (c) 2021, 2023 Contributors to the Eclipse Foundation
+ * Copyright (c) 2021 Contributors to the Eclipse Foundation
  *
  * See the NOTICE file(s) distributed with this work for additional
  * information regarding copyright ownership.
@@ -720,7 +720,8 @@ public void onPartitionsAssigned(final Collection<org.apache.kafka.common.TopicP
                 // invoked on the Kafka polling thread, not the event loop thread!
                 final Set<TopicPartition> partitionsSet = Helper.from(partitions);
                 if (LOG.isDebugEnabled()) {
-                    LOG.debug("partitions assigned: [{}]", HonoKafkaConsumerHelper.getPartitionsDebugString(partitions));
+                    LOG.debug("partitions assigned: [{}] [client-id: {}]",
+                            HonoKafkaConsumerHelper.getPartitionsDebugString(partitions), getClientId());
                 }
                 ensurePositionsHaveBeenSetIfNeeded(partitionsSet);
                 updateSubscribedTopicPatternTopicsAndRemoveMetrics();
@@ -744,7 +745,8 @@ public void onPartitionsRevoked(final Collection<org.apache.kafka.common.TopicPa
                 // invoked on the Kafka polling thread, not the event loop thread!
                 final Set<TopicPartition> partitionsSet = Helper.from(partitions);
                 if (LOG.isDebugEnabled()) {
-                    LOG.debug("partitions revoked: [{}]", HonoKafkaConsumerHelper.getPartitionsDebugString(partitions));
+                    LOG.debug("partitions revoked: [{}] [client-id: {}]",
+                            HonoKafkaConsumerHelper.getPartitionsDebugString(partitions), getClientId());
                 }
                 onPartitionsRevokedBlocking(partitionsSet);
                 context.runOnContext(v -> HonoKafkaConsumer.this.onPartitionsRevoked(partitionsSet));