You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by gu...@apache.org on 2015/03/20 00:10:35 UTC
kafka git commit: trivial fix on coding style
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 <wa...@gmail.com>
Authored: Thu Mar 19 16:10:23 2015 -0700
Committer: Guozhang Wang <wa...@gmail.com>
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());
}