root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 5 Packages Projects Releases Wiki Activity

trivial fix on coding style

This commit is contained in:
Guozhang Wang 2015-03-19 16:10:23 -07:00
parent b2c833aa41
commit c62cff3559
2 changed files with 1 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java
View File

@ -30,7 +30,6 @@ import org.apache.kafka.clients.Metadata;
import org.apache.kafka.clients.NetworkClient; import org.apache.kafka.clients.NetworkClient;
import org.apache.kafka.clients.consumer.internals.Coordinator; import org.apache.kafka.clients.consumer.internals.Coordinator;
import org.apache.kafka.clients.consumer.internals.Fetcher; 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.clients.consumer.internals.SubscriptionState;
import org.apache.kafka.common.Cluster; import org.apache.kafka.common.Cluster;
import org.apache.kafka.common.Metric; import org.apache.kafka.common.Metric;

2
clients/src/main/java/org/apache/kafka/common/record/Record.java
View File

@ -323,7 +323,7 @@ public final class Record {
compressionType(), compressionType(),
checksum(), checksum(),
key() == null ? 0 : key().limit(), key() == null ? 0 : key().limit(),
value() == null ? 0: value().limit()); value() == null ? 0 : value().limit());
} }