Repository: kafka Updated Branches: refs/heads/trunk b2c833aa4 -> c62cff355
trivial fix on coding style Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/c62cff35 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/c62cff35 Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/c62cff35 Branch: refs/heads/trunk Commit: c62cff355936eea2a96e3b9678c761334fce8ee2 Parents: b2c833a Author: Guozhang Wang <[email protected]> Authored: Thu Mar 19 16:10:23 2015 -0700 Committer: Guozhang Wang <[email protected]> Committed: Thu Mar 19 16:10:23 2015 -0700 ---------------------------------------------------------------------- .../main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java | 1 - clients/src/main/java/org/apache/kafka/common/record/Record.java | 2 +- 2 files changed, 1 insertion(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/c62cff35/clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java ---------------------------------------------------------------------- diff --git a/clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java b/clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java index c7bc56c..862f1f8 100644 --- a/clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java +++ b/clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java @@ -30,7 +30,6 @@ import org.apache.kafka.clients.Metadata; import org.apache.kafka.clients.NetworkClient; import org.apache.kafka.clients.consumer.internals.Coordinator; import org.apache.kafka.clients.consumer.internals.Fetcher; -import org.apache.kafka.clients.consumer.internals.Heartbeat; import org.apache.kafka.clients.consumer.internals.SubscriptionState; import org.apache.kafka.common.Cluster; import org.apache.kafka.common.Metric; http://git-wip-us.apache.org/repos/asf/kafka/blob/c62cff35/clients/src/main/java/org/apache/kafka/common/record/Record.java ---------------------------------------------------------------------- diff --git a/clients/src/main/java/org/apache/kafka/common/record/Record.java b/clients/src/main/java/org/apache/kafka/common/record/Record.java index 197d60e..d2332c9 100644 --- a/clients/src/main/java/org/apache/kafka/common/record/Record.java +++ b/clients/src/main/java/org/apache/kafka/common/record/Record.java @@ -323,7 +323,7 @@ public final class Record { compressionType(), checksum(), key() == null ? 0 : key().limit(), - value() == null ? 0: value().limit()); + value() == null ? 0 : value().limit()); }
