[eclipse-hono#8] Improve comments.

Signed-off-by: Abel Buechner-Mihaljevic <[email protected]>
bosch-io · Feb 12, 2021 · c7ffbed · c7ffbed
1 parent e022788
commit c7ffbed
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/.../src/main/java/org/eclipse/hono/application/client/kafka/impl/KafkaDownstreamMessage.java b/.../src/main/java/org/eclipse/hono/application/client/kafka/impl/KafkaDownstreamMessage.java
@@ -55,6 +55,7 @@ public class KafkaDownstreamMessage implements DownstreamMessage<KafkaMessageCon
      *
      * @param record The record.
      * @throws NullPointerException if the record is {@code null}.
+     * @throws IllegalArgumentException if the topic does not contain a tenant id.
      */
     public KafkaDownstreamMessage(final KafkaConsumerRecord<String, Buffer> record) {
         Objects.requireNonNull(record);

diff --git a/...rc/main/java/org/eclipse/hono/client/kafka/consumer/AbstractAtLeastOnceKafkaConsumer.java b/...rc/main/java/org/eclipse/hono/client/kafka/consumer/AbstractAtLeastOnceKafkaConsumer.java
@@ -246,7 +246,7 @@ private void handleBatch(final KafkaConsumerRecords<String, Buffer> records) {
                     addToCurrentOffsets(record);
                 } 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)
+                    // resume with committing the current offsets and then polling (failed record will be polled again)
                     break;
                 }
             }