fix 8 module to use firehose factory

This commit is contained in:
fjy 2013-11-11 14:30:00 -08:00
parent 9fb614c773
commit 9be644847e
1 changed files with 1 additions and 1 deletions

View File

@ -38,7 +38,7 @@ public class KafkaEightDruidModule implements DruidModule
return Arrays.<Module>asList(
new SimpleModule("KafkaEightFirehoseModule")
.registerSubtypes(
new NamedType(KafkaEightDruidModule.class, "kafka-0.8")
new NamedType(KafkaEightFirehoseFactory.class, "kafka-0.8")
)
);
}