diff --git a/examples/config/realtime/runtime.properties b/examples/config/realtime/runtime.properties index b529b63792b..cac3405e678 100644 --- a/examples/config/realtime/runtime.properties +++ b/examples/config/realtime/runtime.properties @@ -4,7 +4,7 @@ druid.port=8083 druid.zk.service.host=localhost -druid.extensions.coordinates=["io.druid.extensions:druid-examples:0.6.10"] +druid.extensions.coordinates=["io.druid.extensions:druid-examples:0.6.10","io.druid.extensions:druid-kafka-seven:0.6.10"] druid.db.connector.connectURI=jdbc\:mysql\://localhost\:3306/druid druid.db.connector.user=druid 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 658b64bf82b..18261fde99c 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 @@ -22,10 +22,10 @@ package io.druid.firehose.kafka; import com.fasterxml.jackson.databind.Module; import com.fasterxml.jackson.databind.jsontype.NamedType; import com.fasterxml.jackson.databind.module.SimpleModule; +import com.google.common.collect.ImmutableList; import com.google.inject.Binder; import io.druid.initialization.DruidModule; -import java.util.Arrays; import java.util.List; /** @@ -35,7 +35,7 @@ public class KafkaEightDruidModule implements DruidModule @Override public List getJacksonModules() { - return Arrays.asList( + return ImmutableList.of( new SimpleModule("KafkaEightFirehoseModule") .registerSubtypes( new NamedType(KafkaEightFirehoseFactory.class, "kafka-0.8") diff --git a/kafka-seven/src/main/java/io/druid/firehose/kafka/KafkaSevenDruidModule.java b/kafka-seven/src/main/java/io/druid/firehose/kafka/KafkaSevenDruidModule.java index 11682a669aa..5a39fdae5aa 100644 --- a/kafka-seven/src/main/java/io/druid/firehose/kafka/KafkaSevenDruidModule.java +++ b/kafka-seven/src/main/java/io/druid/firehose/kafka/KafkaSevenDruidModule.java @@ -22,10 +22,10 @@ package io.druid.firehose.kafka; import com.fasterxml.jackson.databind.Module; import com.fasterxml.jackson.databind.jsontype.NamedType; import com.fasterxml.jackson.databind.module.SimpleModule; +import com.google.common.collect.ImmutableList; import com.google.inject.Binder; import io.druid.initialization.DruidModule; -import java.util.Arrays; import java.util.List; /** @@ -35,7 +35,7 @@ public class KafkaSevenDruidModule implements DruidModule @Override public List getJacksonModules() { - return Arrays.asList( + return ImmutableList.of( new SimpleModule("KafkaSevenFirehoseModule") .registerSubtypes( new NamedType(KafkaSevenFirehoseFactory.class, "kafka-0.7.2") diff --git a/pom.xml b/pom.xml index 72b65ff271d..c4d353ddbb2 100644 --- a/pom.xml +++ b/pom.xml @@ -18,7 +18,8 @@ ~ Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA. --> - + 4.0.0 io.druid druid @@ -30,8 +31,8 @@ scm:git:ssh://git@github.com/metamx/druid.git scm:git:ssh://git@github.com/metamx/druid.git http://www.github.com/metamx/druid - druid-0.6.10-SNAPSHOT - + ${artifactId}-${project.version} + 3.0.3 @@ -56,6 +57,7 @@ hdfs-storage s3-extensions kafka-seven + kafka-eight @@ -412,24 +414,24 @@ test - com.ircclouds.irc - irc-api - 1.0-0011 + com.ircclouds.irc + irc-api + 1.0-0011 - com.maxmind.geoip2 - geoip2 - 0.4.0 - - - org.apache.httpcomponents - httpclient - - - org.apache.httpcomponents - httpcore - - + com.maxmind.geoip2 + geoip2 + 0.4.0 + + + org.apache.httpcomponents + httpclient + + + org.apache.httpcomponents + httpcore + +