Distributed Message Queue kafka source codes

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

• We are an exchange download platform that only provides communication channels. The downloaded content comes from the internet. Except for download issues, please Google on your own.
• The downloaded content is provided for members to upload. If it unintentionally infringes on your copyright, please contact us.
• Please use Winrar for decompression tools
• If download fail, Try it againg or Feedback to us.
• If downloaded content did not match the introduction, Feedback to us，Confirm and will be refund.
• Before downloading, you can inquire through the uploaded person information

Nothing．