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 <[email protected]> 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);
