From 23a17893bffecc63447e17c289b29fcc4b6303e4 Mon Sep 17 00:00:00 2001 From: Chase Engelbrecht Date: Sat, 11 Nov 2023 22:29:39 -0600 Subject: [PATCH] Remove debug log Signed-off-by: Chase Engelbrecht --- .../plugins/kafka/consumer/KafkaCustomConsumerFactory.java | 1 - 1 file changed, 1 deletion(-) diff --git a/data-prepper-plugins/kafka-plugins/src/main/java/org/opensearch/dataprepper/plugins/kafka/consumer/KafkaCustomConsumerFactory.java b/data-prepper-plugins/kafka-plugins/src/main/java/org/opensearch/dataprepper/plugins/kafka/consumer/KafkaCustomConsumerFactory.java index 9e81d6ff30..fab0a4f56e 100644 --- a/data-prepper-plugins/kafka-plugins/src/main/java/org/opensearch/dataprepper/plugins/kafka/consumer/KafkaCustomConsumerFactory.java +++ b/data-prepper-plugins/kafka-plugins/src/main/java/org/opensearch/dataprepper/plugins/kafka/consumer/KafkaCustomConsumerFactory.java @@ -182,7 +182,6 @@ private void setSchemaRegistryProperties(final KafkaConsumerConfig kafkaConsumer private void setPropertiesForPlaintextAndJsonWithoutSchemaRegistry(Properties properties, final TopicConfig topicConfig) { MessageFormat dataFormat = topicConfig.getSerdeFormat(); schemaType = dataFormat.toString(); - LOG.error("Setting schemaType to {}", schemaType); } private void setPropertiesForSchemaRegistryConnectivity(final KafkaConsumerConfig kafkaConsumerConfig, final Properties properties) {