Repository: kylin Updated Branches: refs/heads/master b02e7bd24 -> 0be3ae31b
KYLIN-2933 Fix compilation against the Kafka 1.0.0 release Project: http://git-wip-us.apache.org/repos/asf/kylin/repo Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/0be3ae31 Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/0be3ae31 Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/0be3ae31 Branch: refs/heads/master Commit: 0be3ae31b58777fd7d3ece6769ed772b9a6e99cb Parents: b02e7bd Author: shaofengshi <[email protected]> Authored: Wed Nov 22 14:35:30 2017 +0800 Committer: shaofengshi <[email protected]> Committed: Wed Nov 22 14:35:30 2017 +0800 ---------------------------------------------------------------------- .../source/kafka/config/KafkaClusterConfig.java | 19 ------------------- 1 file changed, 19 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kylin/blob/0be3ae31/source-kafka/src/main/java/org/apache/kylin/source/kafka/config/KafkaClusterConfig.java ---------------------------------------------------------------------- diff --git a/source-kafka/src/main/java/org/apache/kylin/source/kafka/config/KafkaClusterConfig.java b/source-kafka/src/main/java/org/apache/kylin/source/kafka/config/KafkaClusterConfig.java index 4c4a09b..00df6d2 100644 --- a/source-kafka/src/main/java/org/apache/kylin/source/kafka/config/KafkaClusterConfig.java +++ b/source-kafka/src/main/java/org/apache/kylin/source/kafka/config/KafkaClusterConfig.java @@ -20,10 +20,6 @@ package org.apache.kylin.source.kafka.config; import java.util.List; -import javax.annotation.Nullable; - -import org.apache.kafka.common.network.ListenerName; -import org.apache.kafka.common.protocol.SecurityProtocol; import org.apache.kylin.common.persistence.JsonSerializer; import org.apache.kylin.common.persistence.RootPersistentEntity; import org.apache.kylin.common.persistence.Serializer; @@ -31,10 +27,6 @@ import org.apache.kylin.common.persistence.Serializer; import com.fasterxml.jackson.annotation.JsonAutoDetect; import com.fasterxml.jackson.annotation.JsonBackReference; import com.fasterxml.jackson.annotation.JsonProperty; -import com.google.common.base.Function; -import com.google.common.collect.Lists; - -import kafka.cluster.Broker; /** */ @@ -60,15 +52,4 @@ public class KafkaClusterConfig extends RootPersistentEntity { return brokerConfigs; } - public List<Broker> getBrokers() { - return Lists.transform(brokerConfigs, new Function<BrokerConfig, Broker>() { - @Nullable - @Override - public Broker apply(BrokerConfig input) { - return new Broker(input.getId(), input.getHost(), input.getPort(), - ListenerName.forSecurityProtocol(SecurityProtocol.PLAINTEXT), - SecurityProtocol.PLAINTEXT); - } - }); - } }
