You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by sh...@apache.org on 2017/11/22 06:35:37 UTC
kylin git commit: KYLIN-2933 Fix compilation against the Kafka 1.0.0
release
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 <sh...@apache.org>
Authored: Wed Nov 22 14:35:30 2017 +0800
Committer: shaofengshi <sh...@apache.org>
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);
- }
- });
- }
}