You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by or...@apache.org on 2022/08/10 16:26:40 UTC

[camel] 02/06: (chores) camel-kafka: fixed typo in the resume strategy

This is an automated email from the ASF dual-hosted git repository.

orpiske pushed a commit to branch camel-3.18.x
in repository https://gitbox.apache.org/repos/asf/camel.git

commit b4c8000991b63fbcd7e4cf72ffaa06791592bc09
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Mon Aug 8 11:20:23 2022 +0200

    (chores) camel-kafka: fixed typo in the resume strategy
---
 .../camel/processor/resume/kafka/SingleNodeKafkaResumeStrategy.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/components/camel-kafka/src/main/java/org/apache/camel/processor/resume/kafka/SingleNodeKafkaResumeStrategy.java b/components/camel-kafka/src/main/java/org/apache/camel/processor/resume/kafka/SingleNodeKafkaResumeStrategy.java
index db87f65074a..007e9d29bb7 100644
--- a/components/camel-kafka/src/main/java/org/apache/camel/processor/resume/kafka/SingleNodeKafkaResumeStrategy.java
+++ b/components/camel-kafka/src/main/java/org/apache/camel/processor/resume/kafka/SingleNodeKafkaResumeStrategy.java
@@ -176,7 +176,7 @@ public class SingleNodeKafkaResumeStrategy<T extends Resumable> implements Kafka
                 LOG.trace("Read from Kafka: {}", value);
 
                 if (!deserializable.deserialize(ByteBuffer.wrap(record.key()), ByteBuffer.wrap(record.value()))) {
-                    LOG.warn("Deserializar indicates that this is the last record to deserialize");
+                    LOG.warn("Deserializer indicates that this is the last record to deserialize");
                 }
             }
         } while (true);