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