KYLIN-1696: output more log information
Project: http://git-wip-us.apache.org/repos/asf/kylin/repo Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/7411a98d Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/7411a98d Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/7411a98d Branch: refs/heads/1.4-rc Commit: 7411a98dbedf58454f137cc7208b6ba2a9aa4b3a Parents: df46f52 Author: kyotoYaho <[email protected]> Authored: Mon May 16 18:15:15 2016 +0800 Committer: kyotoYaho <[email protected]> Committed: Mon May 16 18:15:15 2016 +0800 ---------------------------------------------------------------------- .../org/apache/kylin/source/kafka/util/KafkaRequester.java | 6 ++++++ 1 file changed, 6 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kylin/blob/7411a98d/source-kafka/src/main/java/org/apache/kylin/source/kafka/util/KafkaRequester.java ---------------------------------------------------------------------- diff --git a/source-kafka/src/main/java/org/apache/kylin/source/kafka/util/KafkaRequester.java b/source-kafka/src/main/java/org/apache/kylin/source/kafka/util/KafkaRequester.java index e39abc3..3dc542c 100644 --- a/source-kafka/src/main/java/org/apache/kylin/source/kafka/util/KafkaRequester.java +++ b/source-kafka/src/main/java/org/apache/kylin/source/kafka/util/KafkaRequester.java @@ -130,6 +130,7 @@ public final class KafkaRequester { } public static PartitionMetadata getPartitionMetadata(String topic, int partitionId, List<Broker> brokers, KafkaClusterConfig kafkaClusterConfig) { + logger.debug("Brokers: " + brokers.toString()); SimpleConsumer consumer; for (Broker broker : brokers) { consumer = getSimpleConsumer(broker, kafkaClusterConfig.getTimeout(), kafkaClusterConfig.getBufferSize(), "topic_meta_lookup"); @@ -153,6 +154,11 @@ public final class KafkaRequester { break; } for (PartitionMetadata partitionMetadata : topicMetadata.partitionsMetadata()) { + logger.debug("PartitionMetadata debug errorCode: " + partitionMetadata.errorCode()); + logger.debug("PartitionMetadata debug partitionId: " + partitionMetadata.partitionId()); + logger.debug("PartitionMetadata debug leader: " + partitionMetadata.leader()); + logger.debug("PartitionMetadata debug ISR: " + partitionMetadata.isr()); + logger.debug("PartitionMetadata debug replica: " + partitionMetadata.replicas()); if (partitionMetadata.partitionId() == partitionId) { return partitionMetadata; }
