kafka-trunk/
kafka-trunk/.gitignore
kafka-trunk/.travis.yml
kafka-trunk/CONTRIBUTING.md
kafka-trunk/HEADER
kafka-trunk/LICENSE
kafka-trunk/NOTICE
kafka-trunk/README.md
kafka-trunk/Vagrantfile
kafka-trunk/bin/
kafka-trunk/bin/connect-distributed.sh
kafka-trunk/bin/connect-standalone.sh
kafka-trunk/bin/kafka-acls.sh
kafka-trunk/bin/kafka-broker-api-versions.sh
kafka-trunk/bin/kafka-configs.sh
kafka-trunk/bin/kafka-console-consumer.sh
kafka-trunk/bin/kafka-console-producer.sh
kafka-trunk/bin/kafka-consumer-groups.sh
kafka-trunk/bin/kafka-consumer-offset-checker.sh
kafka-trunk/bin/kafka-consumer-perf-test.sh
kafka-trunk/bin/kafka-delete-records.sh
kafka-trunk/bin/kafka-log-dirs.sh
kafka-trunk/bin/kafka-mirror-maker.sh
kafka-trunk/bin/kafka-preferred-replica-election.sh
kafka-trunk/bin/kafka-producer-perf-test.sh
kafka-trunk/bin/kafka-reassign-partitions.sh
kafka-trunk/bin/kafka-replay-log-producer.sh
kafka-trunk/bin/kafka-replica-verification.sh
kafka-trunk/bin/kafka-run-class.sh
kafka-trunk/bin/kafka-server-start.sh
kafka-trunk/bin/kafka-server-stop.sh
kafka-trunk/bin/kafka-simple-consumer-shell.sh
kafka-trunk/bin/kafka-streams-application-reset.sh
kafka-trunk/bin/kafka-topics.sh
kafka-trunk/bin/kafka-verifiable-consumer.sh
kafka-trunk/bin/kafka-verifiable-producer.sh
kafka-trunk/bin/trogdor.sh
kafka-trunk/bin/windows/
kafka-trunk/bin/windows/connect-distributed.bat
kafka-trunk/bin/windows/connect-standalone.bat
kafka-trunk/bin/windows/kafka-acls.bat
kafka-trunk/bin/windows/kafka-broker-api-versions.bat
kafka-trunk/bin/windows/kafka-configs.bat
kafka-trunk/bin/windows/kafka-console-consumer.bat
kafka-trunk/bin/windows/kafka-console-producer.bat
kafka-trunk/bin/windows/kafka-consumer-groups.bat
kafka-trunk/bin/windows/kafka-consumer-offset-checker.bat
kafka-trunk/bin/windows/kafka-consumer-perf-test.bat
kafka-trunk/bin/windows/kafka-mirror-maker.bat
kafka-trunk/bin/windows/kafka-preferred-replica-election.bat
kafka-trunk/bin/windows/kafka-producer-perf-test.bat
kafka-trunk/bin/windows/kafka-reassign-partitions.bat
kafka-trunk/bin/windows/kafka-replay-log-producer.bat
kafka-trunk/bin/windows/kafka-replica-verification.bat
kafka-trunk/bin/windows/kafka-run-class.bat
kafka-trunk/bin/windows/kafka-server-start.bat
kafka-trunk/bin/windows/kafka-server-stop.bat
kafka-trunk/bin/windows/kafka-simple-consumer-shell.bat
kafka-trunk/bin/windows/kafka-topics.bat
kafka-trunk/bin/windows/zookeeper-server-start.bat
kafka-trunk/bin/windows/zookeeper-server-stop.bat
kafka-trunk/bin/windows/zookeeper-shell.bat
kafka-trunk/bin/zookeeper-security-migration.sh
kafka-trunk/bin/zookeeper-server-start.sh
kafka-trunk/bin/zookeeper-server-stop.sh
kafka-trunk/bin/zookeeper-shell.sh
kafka-trunk/build.gradle
kafka-trunk/checkstyle/
kafka-trunk/checkstyle/checkstyle.xml
kafka-trunk/checkstyle/import-control-core.xml
kafka-trunk/checkstyle/import-control.xml
kafka-trunk/checkstyle/java.header
kafka-trunk/checkstyle/suppressions.xml
kafka-trunk/clients/
kafka-trunk/clients/.gitignore
kafka-trunk/clients/out/
kafka-trunk/clients/out/test/
kafka-trunk/clients/out/test/resources/
kafka-trunk/clients/out/test/resources/log4j.properties
kafka-trunk/clients/out/test/resources/serializedData/
kafka-trunk/clients/out/test/resources/serializedData/offsetAndMetadataSerializedfile
kafka-trunk/clients/out/test/resources/serializedData/topicPartitionSerializedfile
kafka-trunk/clients/src/
kafka-trunk/clients/src/main/
kafka-trunk/clients/src/main/java/
kafka-trunk/clients/src/main/java/org/
kafka-trunk/clients/src/main/java/org/apache/
kafka-trunk/clients/src/main/java/org/apache/kafka/
kafka-trunk/clients/src/main/java/org/apache/kafka/clients/
kafka-trunk/clients/src/main/java/org/apache/kafka/clients/ApiVersions.java
kafka-trunk/clients/src/main/java/org/apache/kafka/clients/ClientRequest.java
kafka-trunk/clients/src/main/java/org/apache/kafka/clients/ClientResponse.java
kafka-trunk/clients/src/main/java/org/apache/kafka/clients/ClientUtils.java
kafka-trunk/clients/src/main/java/org/apache/kafka/clients/ClusterConnectionStates.java
kafka-trunk/clients/src/main/java/org/apache/kafka/clients/CommonClientConfigs.java
kafka-trunk/clients/src/main/java/org/apache/kafka/clients/ConnectionState.java
kafka-trunk/clients/src/main/java/org/apache/kafka/clients/InFlightRequests.java
kafka-trunk/clients/src/main/java/org/apache/kafka/clients/KafkaClient.java
kafka-trunk/clients/src/main/java/org/apache/kafka/clients/ManualMetadataUpdater.java
kafka-trunk/clients/src/main/java/org/apache/kafka/clients/Metadata.java
kafka-trunk/clients/src/main/java/org/apache/kafka/clients/MetadataUpdater.java
kafka-trunk/clients/src/main/java/org/apache/kafka/clients/NetworkClient.java
kafka-trunk/clients/src/main/java/org/apache/kafka/clients/NetworkClientUtils.java
kafka-trunk/clients/src/main/java/org/apache/kafka/clients/NodeApiVersions.java
kafka-trunk/clients/src/main/java/org/apache/kafka/clients/RequestCompletionHandler.java
kafka-trunk/clients/src/main/java/org/apache/kafka/clients/admin/
kafka-trunk/clients/src/main/java/org/apache/kafka/clients/admin/AbstractOptions.java
kafka-trunk/clie