From a4d1219184c541194b9bdc7929c555d4de5314d0 Mon Sep 17 00:00:00 2001 From: Aaron Bossert Date: Wed, 21 Aug 2019 21:03:57 -0400 Subject: [PATCH] Removed hard-coded Kafka Deserializer in Web-UI Kafka data import such that users can supply a custom deserializer in the UI as well as in hand-built ingestion specs. (#8364) --- .../java/org/apache/druid/indexing/kafka/KafkaSamplerSpec.java | 3 --- 1 file changed, 3 deletions(-) diff --git a/extensions-core/kafka-indexing-service/src/main/java/org/apache/druid/indexing/kafka/KafkaSamplerSpec.java b/extensions-core/kafka-indexing-service/src/main/java/org/apache/druid/indexing/kafka/KafkaSamplerSpec.java index 63f519bc8da..ae98c229e5b 100644 --- a/extensions-core/kafka-indexing-service/src/main/java/org/apache/druid/indexing/kafka/KafkaSamplerSpec.java +++ b/extensions-core/kafka-indexing-service/src/main/java/org/apache/druid/indexing/kafka/KafkaSamplerSpec.java @@ -31,7 +31,6 @@ import org.apache.druid.indexing.overlord.sampler.FirehoseSampler; import org.apache.druid.indexing.overlord.sampler.SamplerConfig; import org.apache.druid.indexing.seekablestream.SeekableStreamSamplerSpec; import org.apache.druid.indexing.seekablestream.common.RecordSupplier; -import org.apache.kafka.common.serialization.ByteArrayDeserializer; import java.util.HashMap; import java.util.Map; @@ -77,8 +76,6 @@ public class KafkaSamplerSpec extends SeekableStreamSamplerSpec props.put("enable.auto.commit", "false"); props.put("auto.offset.reset", "none"); - props.put("key.deserializer", ByteArrayDeserializer.class.getName()); - props.put("value.deserializer", ByteArrayDeserializer.class.getName()); props.put("request.timeout.ms", Integer.toString(samplerConfig.getTimeoutMs())); return new KafkaRecordSupplier(props, objectMapper);