From 9be644847ecd6c621d8267acebc7c0aa0f13063b Mon Sep 17 00:00:00 2001 From: fjy Date: Mon, 11 Nov 2013 14:30:00 -0800 Subject: [PATCH] fix 8 module to use firehose factory --- .../java/io/druid/firehose/kafka/KafkaEightDruidModule.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/kafka-eight/src/main/java/io/druid/firehose/kafka/KafkaEightDruidModule.java b/kafka-eight/src/main/java/io/druid/firehose/kafka/KafkaEightDruidModule.java index b8ccc933651..658b64bf82b 100644 --- a/kafka-eight/src/main/java/io/druid/firehose/kafka/KafkaEightDruidModule.java +++ b/kafka-eight/src/main/java/io/druid/firehose/kafka/KafkaEightDruidModule.java @@ -38,7 +38,7 @@ public class KafkaEightDruidModule implements DruidModule return Arrays.asList( new SimpleModule("KafkaEightFirehoseModule") .registerSubtypes( - new NamedType(KafkaEightDruidModule.class, "kafka-0.8") + new NamedType(KafkaEightFirehoseFactory.class, "kafka-0.8") ) ); }