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

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

commit 4deb01d4a15dad784b5e7870119c485c7265050a
Author: Otavio Rodolfo Piske <angusyo...@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);

Reply via email to