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 02f74172b198ae19e7ac1434348ab3c8cec8abaa Author: Otavio Rodolfo Piske <[email protected]> AuthorDate: Mon Jun 20 11:07:03 2022 +0200 (chores) camel-vertx-kafka-component: removed unused parameters --- .../component/vertx/kafka/VertxKafkaConfigurationOptionsProxy.java | 4 ++-- .../vertx/kafka/operations/VertxKafkaProducerOperations.java | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/main/java/org/apache/camel/component/vertx/kafka/VertxKafkaConfigurationOptionsProxy.java b/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/main/java/org/apache/camel/component/vertx/kafka/VertxKafkaConfigurationOptionsProxy.java index 6ab88e9ac27..abccae5105c 100644 --- a/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/main/java/org/apache/camel/component/vertx/kafka/VertxKafkaConfigurationOptionsProxy.java +++ b/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/main/java/org/apache/camel/component/vertx/kafka/VertxKafkaConfigurationOptionsProxy.java @@ -38,11 +38,11 @@ public class VertxKafkaConfigurationOptionsProxy { return getOption(message, VertxKafkaConstants.MESSAGE_KEY, () -> null, Object.class); } - public String getKeySerializer(final Message message) { + public String getKeySerializer() { return configuration.getKeySerializer(); } - public String getValueSerializer(final Message message) { + public String getValueSerializer() { return configuration.getValueSerializer(); } diff --git a/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/main/java/org/apache/camel/component/vertx/kafka/operations/VertxKafkaProducerOperations.java b/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/main/java/org/apache/camel/component/vertx/kafka/operations/VertxKafkaProducerOperations.java index b27dc9e32f0..f2adffcae46 100644 --- a/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/main/java/org/apache/camel/component/vertx/kafka/operations/VertxKafkaProducerOperations.java +++ b/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/main/java/org/apache/camel/component/vertx/kafka/operations/VertxKafkaProducerOperations.java @@ -179,7 +179,7 @@ public class VertxKafkaProducerOperations { private Object getMessageKey(final Message message) { return VertxKafkaTypeSerializer.tryConvertToSerializedType(message, configurationOptionsProxy.getMessageKey(message), - configurationOptionsProxy.getKeySerializer(message)); + configurationOptionsProxy.getKeySerializer()); } private Integer getPartitionId(final Message message) { @@ -188,7 +188,7 @@ public class VertxKafkaProducerOperations { private Object getMessageValue(final Message message, final Object inputData) { return VertxKafkaTypeSerializer.tryConvertToSerializedType(message, inputData, - configurationOptionsProxy.getValueSerializer(message)); + configurationOptionsProxy.getValueSerializer()); } private Long getOverrideTimestamp(final Message message) {
