kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject kafka git commit: trivial fix on coding style
Date Thu, 19 Mar 2015 23:10:35 GMT
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 <wangguoz@gmail.com>
Authored: Thu Mar 19 16:10:23 2015 -0700
Committer: Guozhang Wang <wangguoz@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());
 
     }
 


Mime
View raw message