Akosiaris has uploaded a new change for review. https://gerrit.wikimedia.org/r/67979
Change subject: Imported Upstream version 3b470f ...................................................................... Imported Upstream version 3b470f Change-Id: Idbe8d55f9fdd89e574a08b31a7ff0b0416cc54a8 --- M .gitignore M README.md A bin/kafka-check-reassignment-status.sh M bin/kafka-consumer-perf-test.sh D bin/kafka-consumer-shell.sh A bin/kafka-preferred-replica-election.sh D bin/kafka-producer-shell.sh A bin/kafka-reassign-partitions.sh M bin/kafka-run-class.sh M bin/kafka-server-start.sh M bin/kafka-server-stop.sh M bin/kafka-simple-consumer-perf-test.sh A bin/kafka-topics.sh M bin/run-rat.sh A bin/windows/kafka-console-consumer.bat A bin/windows/kafka-console-producer.bat A bin/windows/kafka-run-class.bat A bin/windows/kafka-server-start.bat A bin/windows/kafka-server-stop.bat A bin/windows/zookeeper-server-start.bat A bin/windows/zookeeper-server-stop.bat M config/consumer.properties M config/log4j.properties M config/producer.properties M config/server.properties A contrib/hadoop-consumer/build.sbt M contrib/hadoop-consumer/src/main/java/kafka/etl/KafkaETLContext.java M contrib/hadoop-consumer/src/main/java/kafka/etl/KafkaETLRecordReader.java M contrib/hadoop-consumer/src/main/java/kafka/etl/KafkaETLRequest.java M contrib/hadoop-consumer/src/main/java/kafka/etl/Props.java M contrib/hadoop-consumer/src/main/java/kafka/etl/impl/DataGenerator.java M contrib/hadoop-consumer/src/main/java/kafka/etl/impl/SimpleKafkaETLMapper.java M contrib/hadoop-producer/README.md A contrib/hadoop-producer/build.sbt M contrib/hadoop-producer/src/main/java/kafka/bridge/examples/TextPublisher.java M contrib/hadoop-producer/src/main/java/kafka/bridge/hadoop/KafkaOutputFormat.java M contrib/hadoop-producer/src/main/java/kafka/bridge/hadoop/KafkaRecordWriter.java M contrib/hadoop-producer/src/main/java/kafka/bridge/pig/AvroKafkaStorage.java A core/build.sbt A core/lib/metrics-annotation-3.0.0-c0c8be71.jar A core/lib/metrics-core-3.0.0-c0c8be71.jar A core/lib/zkclient-20120522.jar M core/src/main/scala/kafka/Kafka.scala A core/src/main/scala/kafka/admin/AdminOperationException.scala A core/src/main/scala/kafka/admin/AdminUtils.scala A core/src/main/scala/kafka/admin/CheckReassignmentStatus.scala A core/src/main/scala/kafka/admin/DeleteTopicCommand.scala A core/src/main/scala/kafka/admin/ListTopicCommand.scala A core/src/main/scala/kafka/admin/PreferredReplicaLeaderElectionCommand.scala A core/src/main/scala/kafka/admin/ReassignPartitionsCommand.scala A core/src/main/scala/kafka/admin/ShutdownBroker.scala A core/src/main/scala/kafka/admin/TopicCommand.scala A core/src/main/scala/kafka/api/ApiUtils.scala M core/src/main/scala/kafka/api/FetchRequest.scala A core/src/main/scala/kafka/api/FetchResponse.scala A core/src/main/scala/kafka/api/LeaderAndIsrRequest.scala A core/src/main/scala/kafka/api/LeaderAndIsrResponse.scala D core/src/main/scala/kafka/api/MultiFetchRequest.scala D core/src/main/scala/kafka/api/MultiFetchResponse.scala D core/src/main/scala/kafka/api/MultiProducerRequest.scala A core/src/main/scala/kafka/api/OffsetCommitRequest.scala A core/src/main/scala/kafka/api/OffsetCommitResponse.scala A core/src/main/scala/kafka/api/OffsetFetchRequest.scala A core/src/main/scala/kafka/api/OffsetFetchResponse.scala M core/src/main/scala/kafka/api/OffsetRequest.scala A core/src/main/scala/kafka/api/OffsetResponse.scala M core/src/main/scala/kafka/api/ProducerRequest.scala A core/src/main/scala/kafka/api/ProducerResponse.scala M core/src/main/scala/kafka/api/RequestKeys.scala A core/src/main/scala/kafka/api/RequestOrResponse.scala A core/src/main/scala/kafka/api/StopReplicaRequest.scala A core/src/main/scala/kafka/api/StopReplicaResponse.scala A core/src/main/scala/kafka/api/TopicMetadata.scala A core/src/main/scala/kafka/api/TopicMetadataRequest.scala A core/src/main/scala/kafka/api/TopicMetadataResponse.scala A core/src/main/scala/kafka/client/ClientUtils.scala M core/src/main/scala/kafka/cluster/Broker.scala M core/src/main/scala/kafka/cluster/Partition.scala A core/src/main/scala/kafka/cluster/Replica.scala A core/src/main/scala/kafka/common/AdminCommandFailedException.scala A core/src/main/scala/kafka/common/BrokerNotAvailableException.scala A core/src/main/scala/kafka/common/BrokerNotExistException.scala A core/src/main/scala/kafka/common/ClientIdAndBroker.scala A core/src/main/scala/kafka/common/ClientIdAndTopic.scala A core/src/main/scala/kafka/common/Config.scala A core/src/main/scala/kafka/common/ControllerMovedException.scala M core/src/main/scala/kafka/common/ErrorMapping.scala A core/src/main/scala/kafka/common/FailedToSendMessageException.scala D core/src/main/scala/kafka/common/InvalidPartitionException.scala A core/src/main/scala/kafka/common/InvalidTopicException.scala A core/src/main/scala/kafka/common/KafkaException.scala A core/src/main/scala/kafka/common/KafkaStorageException.scala A core/src/main/scala/kafka/common/LeaderNotAvailableException.scala A core/src/main/scala/kafka/common/MessageSizeTooLargeException.scala A core/src/main/scala/kafka/common/NoEpochForPartitionException.scala A core/src/main/scala/kafka/common/NotLeaderForPartitionException.scala A core/src/main/scala/kafka/common/OffsetMetadataAndError.scala A core/src/main/scala/kafka/common/OffsetMetadataTooLargeException.scala A core/src/main/scala/kafka/common/OptimisticLockFailureException.scala A core/src/main/scala/kafka/common/PartitionOfflineException.scala A core/src/main/scala/kafka/common/QueueFullException.scala A core/src/main/scala/kafka/common/ReplicaNotAvailableException.scala A core/src/main/scala/kafka/common/RequestTimedOutException.scala A core/src/main/scala/kafka/common/StateChangeFailedException.scala A core/src/main/scala/kafka/common/Topic.scala A core/src/main/scala/kafka/common/TopicAndPartition.scala A core/src/main/scala/kafka/common/TopicExistsException.scala A core/src/main/scala/kafka/common/UnknownTopicException.scala A core/src/main/scala/kafka/common/UnknownTopicOrPartitionException.scala M core/src/main/scala/kafka/consumer/ConsoleConsumer.scala M core/src/main/scala/kafka/consumer/ConsumerConfig.scala M core/src/main/scala/kafka/consumer/ConsumerConnector.scala A core/src/main/scala/kafka/consumer/ConsumerFetcherManager.scala A core/src/main/scala/kafka/consumer/ConsumerFetcherThread.scala M core/src/main/scala/kafka/consumer/ConsumerIterator.scala M core/src/main/scala/kafka/consumer/ConsumerTopicStat.scala A core/src/main/scala/kafka/consumer/ConsumerTopicStats.scala A core/src/main/scala/kafka/consumer/FetchRequestAndResponseStats.scala M core/src/main/scala/kafka/consumer/FetchedDataChunk.scala D core/src/main/scala/kafka/consumer/Fetcher.scala D core/src/main/scala/kafka/consumer/FetcherRunnable.scala M core/src/main/scala/kafka/consumer/KafkaStream.scala M core/src/main/scala/kafka/consumer/PartitionTopicInfo.scala M core/src/main/scala/kafka/consumer/SimpleConsumer.scala M core/src/main/scala/kafka/consumer/TopicCount.scala M core/src/main/scala/kafka/consumer/ZookeeperConsumerConnector.scala D core/src/main/scala/kafka/consumer/storage/MemoryOffsetStorage.scala D core/src/main/scala/kafka/consumer/storage/OffsetStorage.scala D core/src/main/scala/kafka/consumer/storage/OracleOffsetStorage.scala A core/src/main/scala/kafka/controller/ControllerChannelManager.scala A core/src/main/scala/kafka/controller/KafkaController.scala A core/src/main/scala/kafka/controller/PartitionLeaderSelector.scala A core/src/main/scala/kafka/controller/PartitionStateMachine.scala A core/src/main/scala/kafka/controller/ReplicaStateMachine.scala A core/src/main/scala/kafka/javaapi/FetchRequest.scala A core/src/main/scala/kafka/javaapi/FetchResponse.scala M core/src/main/scala/kafka/javaapi/Implicits.scala D core/src/main/scala/kafka/javaapi/MultiFetchResponse.scala A core/src/main/scala/kafka/javaapi/OffsetCommitRequest.scala A core/src/main/scala/kafka/javaapi/OffsetCommitResponse.scala A core/src/main/scala/kafka/javaapi/OffsetFetchRequest.scala A core/src/main/scala/kafka/javaapi/OffsetFetchResponse.scala A core/src/main/scala/kafka/javaapi/OffsetRequest.scala A core/src/main/scala/kafka/javaapi/OffsetResponse.scala D core/src/main/scala/kafka/javaapi/ProducerRequest.scala A core/src/main/scala/kafka/javaapi/TopicMetadata.scala A core/src/main/scala/kafka/javaapi/TopicMetadataRequest.scala A core/src/main/scala/kafka/javaapi/TopicMetadataResponse.scala M core/src/main/scala/kafka/javaapi/consumer/ConsumerConnector.java M core/src/main/scala/kafka/javaapi/consumer/SimpleConsumer.scala M core/src/main/scala/kafka/javaapi/consumer/ZookeeperConsumerConnector.scala M core/src/main/scala/kafka/javaapi/message/ByteBufferMessageSet.scala M core/src/main/scala/kafka/javaapi/message/MessageSet.scala M core/src/main/scala/kafka/javaapi/producer/Producer.scala D core/src/main/scala/kafka/javaapi/producer/ProducerData.scala D core/src/main/scala/kafka/javaapi/producer/SyncProducer.scala D core/src/main/scala/kafka/javaapi/producer/async/CallbackHandler.java D core/src/main/scala/kafka/javaapi/producer/async/EventHandler.java A core/src/main/scala/kafka/log/CleanerConfig.scala A core/src/main/scala/kafka/log/FileMessageSet.scala M core/src/main/scala/kafka/log/Log.scala A core/src/main/scala/kafka/log/LogCleaner.scala A core/src/main/scala/kafka/log/LogConfig.scala M core/src/main/scala/kafka/log/LogManager.scala A core/src/main/scala/kafka/log/LogSegment.scala D core/src/main/scala/kafka/log/LogStats.scala A core/src/main/scala/kafka/log/OffsetIndex.scala A core/src/main/scala/kafka/log/OffsetMap.scala A core/src/main/scala/kafka/log/OffsetPosition.scala D core/src/main/scala/kafka/log/SegmentList.scala M core/src/main/scala/kafka/log/package.html M core/src/main/scala/kafka/message/ByteBufferMessageSet.scala M core/src/main/scala/kafka/message/CompressionCodec.scala A core/src/main/scala/kafka/message/CompressionFactory.scala D core/src/main/scala/kafka/message/CompressionUtils.scala D core/src/main/scala/kafka/message/FileMessageSet.scala M core/src/main/scala/kafka/message/Message.scala M core/src/main/scala/kafka/message/MessageAndMetadata.scala M core/src/main/scala/kafka/message/MessageAndOffset.scala M core/src/main/scala/kafka/message/MessageSet.scala A core/src/main/scala/kafka/metrics/KafkaCSVMetricsReporter.scala A core/src/main/scala/kafka/metrics/KafkaMetricsConfig.scala A core/src/main/scala/kafka/metrics/KafkaMetricsGroup.scala A core/src/main/scala/kafka/metrics/KafkaMetricsReporter.scala A core/src/main/scala/kafka/metrics/KafkaTimer.scala A core/src/main/scala/kafka/network/BlockingChannel.scala M core/src/main/scala/kafka/network/BoundedByteBufferReceive.scala M core/src/main/scala/kafka/network/BoundedByteBufferSend.scala D core/src/main/scala/kafka/network/Request.scala A core/src/main/scala/kafka/network/RequestChannel.scala M core/src/main/scala/kafka/network/SocketServer.scala D core/src/main/scala/kafka/network/SocketServerStats.scala M core/src/main/scala/kafka/network/Transmission.scala M core/src/main/scala/kafka/producer/BrokerPartitionInfo.scala D core/src/main/scala/kafka/producer/ConfigBrokerPartitionInfo.scala M core/src/main/scala/kafka/producer/ConsoleProducer.scala M core/src/main/scala/kafka/producer/DefaultPartitioner.scala M core/src/main/scala/kafka/producer/KafkaLog4jAppender.scala A core/src/main/scala/kafka/producer/KeyedMessage.scala M core/src/main/scala/kafka/producer/Partitioner.scala M core/src/main/scala/kafka/producer/Producer.scala A core/src/main/scala/kafka/producer/ProducerClosedException.scala M core/src/main/scala/kafka/producer/ProducerConfig.scala D core/src/main/scala/kafka/producer/ProducerData.scala M core/src/main/scala/kafka/producer/ProducerPool.scala A core/src/main/scala/kafka/producer/ProducerRequestStats.scala A core/src/main/scala/kafka/producer/ProducerStats.scala A core/src/main/scala/kafka/producer/ProducerTopicStats.scala M core/src/main/scala/kafka/producer/SyncProducer.scala M core/src/main/scala/kafka/producer/SyncProducerConfig.scala D core/src/main/scala/kafka/producer/ZKBrokerPartitionInfo.scala D core/src/main/scala/kafka/producer/async/AsyncProducer.scala M core/src/main/scala/kafka/producer/async/AsyncProducerConfig.scala D core/src/main/scala/kafka/producer/async/AsyncProducerInterruptedException.scala M core/src/main/scala/kafka/producer/async/AsyncProducerStats.scala D core/src/main/scala/kafka/producer/async/AsyncProducerStatsMBean.scala D core/src/main/scala/kafka/producer/async/CallbackHandler.scala M core/src/main/scala/kafka/producer/async/DefaultEventHandler.scala M core/src/main/scala/kafka/producer/async/EventHandler.scala M core/src/main/scala/kafka/producer/async/ProducerSendThread.scala D core/src/main/scala/kafka/producer/async/QueueClosedException.scala D core/src/main/scala/kafka/producer/async/QueueFullException.scala M core/src/main/scala/kafka/serializer/Decoder.scala M core/src/main/scala/kafka/serializer/Encoder.scala A core/src/main/scala/kafka/server/AbstractFetcherManager.scala A core/src/main/scala/kafka/server/AbstractFetcherThread.scala A core/src/main/scala/kafka/server/KafkaApis.scala M core/src/main/scala/kafka/server/KafkaConfig.scala A core/src/main/scala/kafka/server/KafkaHealthcheck.scala A core/src/main/scala/kafka/server/KafkaRequestHandler.scala D core/src/main/scala/kafka/server/KafkaRequestHandlers.scala M core/src/main/scala/kafka/server/KafkaServer.scala M core/src/main/scala/kafka/server/KafkaServerStartable.scala D core/src/main/scala/kafka/server/KafkaZooKeeper.scala A core/src/main/scala/kafka/server/LeaderElector.scala M core/src/main/scala/kafka/server/MessageSetSend.scala D core/src/main/scala/kafka/server/MultiMessageSetSend.scala A core/src/main/scala/kafka/server/OffsetCheckpoint.scala A core/src/main/scala/kafka/server/ReplicaFetcherManager.scala A core/src/main/scala/kafka/server/ReplicaFetcherThread.scala A core/src/main/scala/kafka/server/ReplicaManager.scala A core/src/main/scala/kafka/server/RequestPurgatory.scala A core/src/main/scala/kafka/server/TopicConfigManager.scala A core/src/main/scala/kafka/server/ZookeeperLeaderElector.scala M core/src/main/scala/kafka/tools/ConsumerOffsetChecker.scala D core/src/main/scala/kafka/tools/ConsumerShell.scala M core/src/main/scala/kafka/tools/DumpLogSegments.scala M core/src/main/scala/kafka/tools/ExportZkOffsets.scala M core/src/main/scala/kafka/tools/GetOffsetShell.scala M core/src/main/scala/kafka/tools/JmxTool.scala A core/src/main/scala/kafka/tools/KafkaMigrationTool.java M core/src/main/scala/kafka/tools/MirrorMaker.scala D core/src/main/scala/kafka/tools/ProducerShell.scala M core/src/main/scala/kafka/tools/ReplayLogProducer.scala M core/src/main/scala/kafka/tools/SimpleConsumerShell.scala A core/src/main/scala/kafka/tools/StateChangeLogMerger.scala A core/src/main/scala/kafka/tools/UpdateOffsetsInZK.scala M core/src/main/scala/kafka/tools/VerifyConsumerRebalance.scala A core/src/main/scala/kafka/utils/CommandLineUtils.scala A core/src/main/scala/kafka/utils/Crc32.java M core/src/main/scala/kafka/utils/DelayedItem.scala A core/src/main/scala/kafka/utils/FileLock.scala M core/src/main/scala/kafka/utils/IteratorTemplate.scala A core/src/main/scala/kafka/utils/Json.scala M core/src/main/scala/kafka/utils/KafkaScheduler.scala M core/src/main/scala/kafka/utils/Logging.scala D core/src/main/scala/kafka/utils/MockTime.scala M core/src/main/scala/kafka/utils/Mx4jLoader.scala M core/src/main/scala/kafka/utils/Pool.scala D core/src/main/scala/kafka/utils/Range.scala A core/src/main/scala/kafka/utils/ShutdownableThread.scala M core/src/main/scala/kafka/utils/Throttler.scala A core/src/main/scala/kafka/utils/Topic.scala D core/src/main/scala/kafka/utils/TopicNameValidator.scala D core/src/main/scala/kafka/utils/UpdateOffsetsInZK.scala M core/src/main/scala/kafka/utils/Utils.scala A core/src/main/scala/kafka/utils/VerifiableProperties.scala M core/src/main/scala/kafka/utils/ZkUtils.scala M core/src/test/resources/log4j.properties D core/src/test/resources/test-kafka-logs/MagicByte0-0/00000000000000000000.kafka A core/src/test/scala/other/kafka/StressTestLog.scala A core/src/test/scala/other/kafka/TestCrcPerformance.scala A core/src/test/scala/other/kafka/TestEndToEndLatency.scala M core/src/test/scala/other/kafka/TestKafkaAppender.scala M core/src/test/scala/other/kafka/TestLinearWriteSpeed.scala A core/src/test/scala/other/kafka/TestLogCleaning.scala M core/src/test/scala/other/kafka/TestLogPerformance.scala M core/src/test/scala/other/kafka/TestZKConsumerOffsets.scala A core/src/test/scala/unit/kafka/admin/AdminTest.scala A core/src/test/scala/unit/kafka/api/ApiUtilsTest.scala A core/src/test/scala/unit/kafka/api/RequestResponseSerializationTest.scala A core/src/test/scala/unit/kafka/common/ConfigTest.scala A core/src/test/scala/unit/kafka/common/TopicTest.scala A core/src/test/scala/unit/kafka/consumer/ConsumerIteratorTest.scala M core/src/test/scala/unit/kafka/consumer/ZookeeperConsumerConnectorTest.scala M core/src/test/scala/unit/kafka/integration/AutoOffsetResetTest.scala D core/src/test/scala/unit/kafka/integration/BackwardsCompatibilityTest.scala M core/src/test/scala/unit/kafka/integration/FetcherTest.scala M core/src/test/scala/unit/kafka/integration/KafkaServerTestHarness.scala M core/src/test/scala/unit/kafka/integration/LazyInitProducerTest.scala D core/src/test/scala/unit/kafka/integration/LogCorruptionTest.scala M core/src/test/scala/unit/kafka/integration/PrimitiveApiTest.scala M core/src/test/scala/unit/kafka/integration/ProducerConsumerTestHarness.scala A core/src/test/scala/unit/kafka/integration/TopicMetadataTest.scala M core/src/test/scala/unit/kafka/javaapi/consumer/ZookeeperConsumerConnectorTest.scala D core/src/test/scala/unit/kafka/javaapi/integration/PrimitiveApiTest.scala D core/src/test/scala/unit/kafka/javaapi/integration/ProducerConsumerTestHarness.scala M core/src/test/scala/unit/kafka/javaapi/message/BaseMessageSetTestCases.scala M core/src/test/scala/unit/kafka/javaapi/message/ByteBufferMessageSetTest.scala D core/src/test/scala/unit/kafka/javaapi/producer/ProducerTest.scala D core/src/test/scala/unit/kafka/javaapi/producer/SyncProducerTest.scala A core/src/test/scala/unit/kafka/log/CleanerTest.scala A core/src/test/scala/unit/kafka/log/FileMessageSetTest.scala A core/src/test/scala/unit/kafka/log/LogCleanerIntegrationTest.scala M core/src/test/scala/unit/kafka/log/LogManagerTest.scala D core/src/test/scala/unit/kafka/log/LogOffsetTest.scala A core/src/test/scala/unit/kafka/log/LogSegmentTest.scala M core/src/test/scala/unit/kafka/log/LogTest.scala A core/src/test/scala/unit/kafka/log/OffsetIndexTest.scala A core/src/test/scala/unit/kafka/log/OffsetMapTest.scala D core/src/test/scala/unit/kafka/log/SegmentListTest.scala M core/src/test/scala/unit/kafka/log4j/KafkaLog4jAppenderTest.scala M core/src/test/scala/unit/kafka/message/BaseMessageSetTestCases.scala M core/src/test/scala/unit/kafka/message/ByteBufferMessageSetTest.scala D core/src/test/scala/unit/kafka/message/CompressionUtilsTest.scala D core/src/test/scala/unit/kafka/message/FileMessageSetTest.scala A core/src/test/scala/unit/kafka/message/MessageCompressionTest.scala M core/src/test/scala/unit/kafka/message/MessageTest.scala A core/src/test/scala/unit/kafka/metrics/KafkaTimerTest.scala M core/src/test/scala/unit/kafka/network/SocketServerTest.scala M core/src/test/scala/unit/kafka/producer/AsyncProducerTest.scala D core/src/test/scala/unit/kafka/producer/ProducerMethodsTest.scala M core/src/test/scala/unit/kafka/producer/ProducerTest.scala M core/src/test/scala/unit/kafka/producer/SyncProducerTest.scala A core/src/test/scala/unit/kafka/server/HighwatermarkPersistenceTest.scala A core/src/test/scala/unit/kafka/server/ISRExpirationTest.scala A core/src/test/scala/unit/kafka/server/LeaderElectionTest.scala A core/src/test/scala/unit/kafka/server/LogOffsetTest.scala A core/src/test/scala/unit/kafka/server/LogRecoveryTest.scala A core/src/test/scala/unit/kafka/server/OffsetCommitTest.scala A core/src/test/scala/unit/kafka/server/ReplicaFetchTest.scala A core/src/test/scala/unit/kafka/server/RequestPurgatoryTest.scala M core/src/test/scala/unit/kafka/server/ServerShutdownTest.scala A core/src/test/scala/unit/kafka/server/SimpleFetchTest.scala A core/src/test/scala/unit/kafka/utils/IteratorTemplateTest.scala A core/src/test/scala/unit/kafka/utils/JsonTest.scala A core/src/test/scala/unit/kafka/utils/MockScheduler.scala A core/src/test/scala/unit/kafka/utils/MockTime.scala A core/src/test/scala/unit/kafka/utils/SchedulerTest.scala M core/src/test/scala/unit/kafka/utils/TestUtils.scala M core/src/test/scala/unit/kafka/utils/UtilsTest.scala M core/src/test/scala/unit/kafka/zk/EmbeddedZookeeper.scala M core/src/test/scala/unit/kafka/zk/ZKEphemeralTest.scala D core/src/test/scala/unit/kafka/zk/ZKLoadBalanceTest.scala M core/src/test/scala/unit/kafka/zk/ZooKeeperTestHarness.scala A examples/build.sbt M examples/src/main/java/kafka/examples/Consumer.java D examples/src/main/java/kafka/examples/ExampleUtils.java M examples/src/main/java/kafka/examples/KafkaProperties.java M examples/src/main/java/kafka/examples/Producer.java M examples/src/main/java/kafka/examples/SimpleConsumerDemo.java A lib/apache-rat-0.8.jar M lib/sbt-launch.jar A perf/build.sbt M perf/src/main/scala/kafka/perf/ConsumerPerformance.scala M perf/src/main/scala/kafka/perf/PerfConfig.scala M perf/src/main/scala/kafka/perf/ProducerPerformance.scala M perf/src/main/scala/kafka/perf/SimpleConsumerPerformance.scala A project/Build.scala M project/build.properties M project/build/KafkaProject.scala A project/plugins.sbt D project/plugins/Plugins.scala A sbt.bat A system_test/README.txt A system_test/__init__.py M system_test/broker_failure/bin/run-test.sh M system_test/broker_failure/config/mirror_producer.properties M system_test/broker_failure/config/mirror_producer1.properties M system_test/broker_failure/config/mirror_producer2.properties M system_test/broker_failure/config/mirror_producer3.properties M system_test/broker_failure/config/server_source1.properties M system_test/broker_failure/config/server_source2.properties M system_test/broker_failure/config/server_source3.properties M system_test/broker_failure/config/server_source4.properties M system_test/broker_failure/config/server_target1.properties M system_test/broker_failure/config/server_target2.properties M system_test/broker_failure/config/server_target3.properties M system_test/broker_failure/config/whitelisttest.consumer.properties A system_test/cluster_config.json M system_test/common/util.sh A system_test/logging.conf A system_test/metrics.json A system_test/migration_tool_testsuite/0.7/bin/kafka-run-class.sh A system_test/migration_tool_testsuite/0.7/bin/zookeeper-server-start.sh A system_test/migration_tool_testsuite/0.7/lib/kafka-0.7.0.jar A system_test/migration_tool_testsuite/0.7/lib/kafka-perf-0.7.0.jar A system_test/migration_tool_testsuite/0.7/lib/zkclient-0.1.jar A system_test/migration_tool_testsuite/__init__.py A system_test/migration_tool_testsuite/cluster_config.json A system_test/migration_tool_testsuite/config/migration_consumer.properties A system_test/migration_tool_testsuite/config/migration_producer.properties A system_test/migration_tool_testsuite/config/server.properties A system_test/migration_tool_testsuite/config/zookeeper.properties A system_test/migration_tool_testsuite/migration_tool_test.py A system_test/migration_tool_testsuite/testcase_9001/testcase_9001_properties.json A system_test/migration_tool_testsuite/testcase_9003/cluster_config.json A system_test/migration_tool_testsuite/testcase_9003/testcase_9003_properties.json A system_test/migration_tool_testsuite/testcase_9004/cluster_config.json A system_test/migration_tool_testsuite/testcase_9004/testcase_9004_properties.json A system_test/migration_tool_testsuite/testcase_9005/cluster_config.json A system_test/migration_tool_testsuite/testcase_9005/testcase_9005_properties.json A system_test/migration_tool_testsuite/testcase_9006/cluster_config.json A system_test/migration_tool_testsuite/testcase_9006/testcase_9006_properties.json M system_test/mirror_maker/bin/run-test.sh M system_test/mirror_maker/config/blacklisttest.consumer.properties M system_test/mirror_maker/config/mirror_producer.properties M system_test/mirror_maker/config/server_source_1_1.properties M system_test/mirror_maker/config/server_source_1_2.properties M system_test/mirror_maker/config/server_source_2_1.properties M system_test/mirror_maker/config/server_source_2_2.properties M system_test/mirror_maker/config/server_target_1_1.properties M system_test/mirror_maker/config/server_target_1_2.properties M system_test/mirror_maker/config/whitelisttest_1.consumer.properties M system_test/mirror_maker/config/whitelisttest_2.consumer.properties A system_test/mirror_maker_testsuite/__init__.py A system_test/mirror_maker_testsuite/cluster_config.json A system_test/mirror_maker_testsuite/config/console_consumer.properties A system_test/mirror_maker_testsuite/config/consumer.properties A system_test/mirror_maker_testsuite/config/log4j.properties A system_test/mirror_maker_testsuite/config/mirror_consumer.properties A system_test/mirror_maker_testsuite/config/mirror_producer.properties A system_test/mirror_maker_testsuite/config/producer.properties A system_test/mirror_maker_testsuite/config/producer_performance.properties A system_test/mirror_maker_testsuite/config/server.properties A system_test/mirror_maker_testsuite/config/zookeeper.properties A system_test/mirror_maker_testsuite/mirror_maker_test.py A system_test/mirror_maker_testsuite/testcase_5001/testcase_5001_properties.json A system_test/mirror_maker_testsuite/testcase_5002/testcase_5002_properties.json A system_test/mirror_maker_testsuite/testcase_5003/cluster_config.json A system_test/mirror_maker_testsuite/testcase_5003/testcase_5003_properties.json A system_test/mirror_maker_testsuite/testcase_5004/cluster_config.json A system_test/mirror_maker_testsuite/testcase_5004/testcase_5004_properties.json A system_test/mirror_maker_testsuite/testcase_5005/cluster_config.json A system_test/mirror_maker_testsuite/testcase_5005/testcase_5005_properties.json A system_test/mirror_maker_testsuite/testcase_5006/cluster_config.json A system_test/mirror_maker_testsuite/testcase_5006/testcase_5006_properties.json M system_test/producer_perf/bin/run-compression-test.sh M system_test/producer_perf/bin/run-test.sh M system_test/producer_perf/config/server.properties A system_test/replication_testsuite/__init__.py A system_test/replication_testsuite/config/console_consumer.properties A system_test/replication_testsuite/config/consumer.properties A system_test/replication_testsuite/config/log4j.properties A system_test/replication_testsuite/config/producer.properties A system_test/replication_testsuite/config/producer_performance.properties A system_test/replication_testsuite/config/server.properties A system_test/replication_testsuite/config/zookeeper.properties A system_test/replication_testsuite/replica_basic_test.py A system_test/replication_testsuite/testcase_0001/testcase_0001_properties.json A system_test/replication_testsuite/testcase_0002/testcase_0002_properties.json A system_test/replication_testsuite/testcase_0003/testcase_0003_properties.json A system_test/replication_testsuite/testcase_0004/testcase_0004_properties.json A system_test/replication_testsuite/testcase_0005/testcase_0005_properties.json A system_test/replication_testsuite/testcase_0006/testcase_0006_properties.json A system_test/replication_testsuite/testcase_0007/testcase_0007_properties.json A system_test/replication_testsuite/testcase_0008/testcase_0008_properties.json A system_test/replication_testsuite/testcase_0009/testcase_0009_properties.json A system_test/replication_testsuite/testcase_0010/testcase_0010_properties.json A system_test/replication_testsuite/testcase_0011/testcase_0011_properties.json A system_test/replication_testsuite/testcase_0021/cluster_config.json A system_test/replication_testsuite/testcase_0021/testcase_0021_properties.json A system_test/replication_testsuite/testcase_0022/cluster_config.json A system_test/replication_testsuite/testcase_0022/testcase_0022_properties.json A system_test/replication_testsuite/testcase_0023/cluster_config.json A system_test/replication_testsuite/testcase_0023/testcase_0023_properties.json A system_test/replication_testsuite/testcase_0024/testcase_0024_properties.json A system_test/replication_testsuite/testcase_0101/testcase_0101_properties.json A system_test/replication_testsuite/testcase_0102/testcase_0102_properties.json A system_test/replication_testsuite/testcase_0103/testcase_0103_properties.json A system_test/replication_testsuite/testcase_0104/testcase_0104_properties.json A system_test/replication_testsuite/testcase_0105/testcase_0105_properties.json A system_test/replication_testsuite/testcase_0106/testcase_0106_properties.json A system_test/replication_testsuite/testcase_0107/testcase_0107_properties.json A system_test/replication_testsuite/testcase_0108/testcase_0108_properties.json A system_test/replication_testsuite/testcase_0109/testcase_0109_properties.json A system_test/replication_testsuite/testcase_0110/testcase_0110_properties.json A system_test/replication_testsuite/testcase_0111/testcase_0111_properties.json A system_test/replication_testsuite/testcase_0112/testcase_0112_properties.json A system_test/replication_testsuite/testcase_0113/testcase_0113_properties.json A system_test/replication_testsuite/testcase_0114/testcase_0114_properties.json A system_test/replication_testsuite/testcase_0115/testcase_0115_properties.json A system_test/replication_testsuite/testcase_0116/testcase_0116_properties.json A system_test/replication_testsuite/testcase_0117/testcase_0117_properties.json A system_test/replication_testsuite/testcase_0118/testcase_0118_properties.json A system_test/replication_testsuite/testcase_0119/testcase_0119_properties.json A system_test/replication_testsuite/testcase_0121/cluster_config.json A system_test/replication_testsuite/testcase_0121/testcase_0121_properties.json A system_test/replication_testsuite/testcase_0122/cluster_config.json A system_test/replication_testsuite/testcase_0122/testcase_0122_properties.json A system_test/replication_testsuite/testcase_0123/cluster_config.json A system_test/replication_testsuite/testcase_0123/testcase_0123_properties.json A system_test/replication_testsuite/testcase_0124/cluster_config.json A system_test/replication_testsuite/testcase_0124/testcase_0124_properties.json A system_test/replication_testsuite/testcase_0125/cluster_config.json A system_test/replication_testsuite/testcase_0125/testcase_0125_properties.json A system_test/replication_testsuite/testcase_0126/cluster_config.json A system_test/replication_testsuite/testcase_0126/testcase_0126_properties.json A system_test/replication_testsuite/testcase_0127/cluster_config.json A system_test/replication_testsuite/testcase_0127/testcase_0127_properties.json A system_test/replication_testsuite/testcase_0128/testcase_0128_properties.json A system_test/replication_testsuite/testcase_0131/cluster_config.json A system_test/replication_testsuite/testcase_0131/testcase_0131_properties.json A system_test/replication_testsuite/testcase_0132/cluster_config.json A system_test/replication_testsuite/testcase_0132/testcase_0132_properties.json A system_test/replication_testsuite/testcase_0133/cluster_config.json A system_test/replication_testsuite/testcase_0133/testcase_0133_properties.json A system_test/replication_testsuite/testcase_0134/testcase_0134_properties.json A system_test/replication_testsuite/testcase_0151/testcase_0151_properties.json A system_test/replication_testsuite/testcase_0152/testcase_0152_properties.json A system_test/replication_testsuite/testcase_0153/testcase_0153_properties.json A system_test/replication_testsuite/testcase_0154/testcase_0154_properties.json A system_test/replication_testsuite/testcase_0155/testcase_0155_properties.json A system_test/replication_testsuite/testcase_0156/testcase_0156_properties.json A system_test/replication_testsuite/testcase_0157/testcase_0157_properties.json A system_test/replication_testsuite/testcase_0158/testcase_0158_properties.json A system_test/replication_testsuite/testcase_0159/testcase_0159_properties.json A system_test/replication_testsuite/testcase_0201/testcase_0201_properties.json A system_test/replication_testsuite/testcase_0202/testcase_0202_properties.json A system_test/replication_testsuite/testcase_0203/testcase_0203_properties.json A system_test/replication_testsuite/testcase_0204/testcase_0204_properties.json A system_test/replication_testsuite/testcase_0205/testcase_0205_properties.json A system_test/replication_testsuite/testcase_0206/testcase_0206_properties.json A system_test/replication_testsuite/testcase_0207/testcase_0207_properties.json A system_test/replication_testsuite/testcase_0208/testcase_0208_properties.json A system_test/replication_testsuite/testcase_0209/testcase_0209_properties.json A system_test/replication_testsuite/testcase_0251/testcase_0251_properties.json A system_test/replication_testsuite/testcase_0252/testcase_0252_properties.json A system_test/replication_testsuite/testcase_0253/testcase_0253_properties.json A system_test/replication_testsuite/testcase_0254/testcase_0254_properties.json A system_test/replication_testsuite/testcase_0255/testcase_0255_properties.json A system_test/replication_testsuite/testcase_0256/testcase_0256_properties.json A system_test/replication_testsuite/testcase_0257/testcase_0257_properties.json A system_test/replication_testsuite/testcase_0258/testcase_0258_properties.json A system_test/replication_testsuite/testcase_0259/testcase_0259_properties.json A system_test/replication_testsuite/testcase_0301/testcase_0301_properties.json A system_test/replication_testsuite/testcase_0302/testcase_0302_properties.json A system_test/replication_testsuite/testcase_0303/testcase_0303_properties.json A system_test/replication_testsuite/testcase_0304/testcase_0304_properties.json A system_test/replication_testsuite/testcase_0305/testcase_0305_properties.json A system_test/replication_testsuite/testcase_0306/testcase_0306_properties.json A system_test/replication_testsuite/testcase_0307/testcase_0307_properties.json A system_test/replication_testsuite/testcase_0308/testcase_0308_properties.json A system_test/replication_testsuite/testcase_0309/testcase_0309_properties.json A system_test/replication_testsuite/testcase_1/cluster_config.json A system_test/replication_testsuite/testcase_1/testcase_1_properties.json A system_test/replication_testsuite/testcase_4001/cluster_config.json A system_test/replication_testsuite/testcase_4001/testcase_4001_properties.json A system_test/replication_testsuite/testcase_4002/cluster_config.json A system_test/replication_testsuite/testcase_4002/testcase_4002_properties.json A system_test/replication_testsuite/testcase_4003/cluster_config.json A system_test/replication_testsuite/testcase_4003/testcase_4003_properties.json A system_test/replication_testsuite/testcase_4004/cluster_config.json A system_test/replication_testsuite/testcase_4004/testcase_4004_properties.json A system_test/replication_testsuite/testcase_4005/cluster_config.json A system_test/replication_testsuite/testcase_4005/testcase_4005_properties.json A system_test/replication_testsuite/testcase_4006/cluster_config.json A system_test/replication_testsuite/testcase_4006/testcase_4006_properties.json A system_test/replication_testsuite/testcase_4007/cluster_config.json A system_test/replication_testsuite/testcase_4007/testcase_4007_properties.json A system_test/replication_testsuite/testcase_4008/cluster_config.json A system_test/replication_testsuite/testcase_4008/testcase_4008_properties.json A system_test/replication_testsuite/testcase_4011/cluster_config.json A system_test/replication_testsuite/testcase_4011/testcase_4011_properties.json A system_test/replication_testsuite/testcase_4012/cluster_config.json A system_test/replication_testsuite/testcase_4012/testcase_4012_properties.json A system_test/replication_testsuite/testcase_4013/cluster_config.json A system_test/replication_testsuite/testcase_4013/testcase_4013_properties.json A system_test/replication_testsuite/testcase_4014/cluster_config.json A system_test/replication_testsuite/testcase_4014/testcase_4014_properties.json A system_test/replication_testsuite/testcase_4015/cluster_config.json A system_test/replication_testsuite/testcase_4015/testcase_4015_properties.json A system_test/replication_testsuite/testcase_4016/cluster_config.json A system_test/replication_testsuite/testcase_4016/testcase_4016_properties.json A system_test/replication_testsuite/testcase_4017/cluster_config.json A system_test/replication_testsuite/testcase_4017/testcase_4017_properties.json A system_test/replication_testsuite/testcase_4018/cluster_config.json A system_test/replication_testsuite/testcase_4018/testcase_4018_properties.json A system_test/replication_testsuite/testcase_9051/cluster_config.json A system_test/replication_testsuite/testcase_9051/testcase_9051_properties.json A system_test/run_sanity.sh A system_test/system_test_env.py A system_test/system_test_runner.py A system_test/testcase_to_run.json A system_test/testcase_to_run_all.json A system_test/testcase_to_run_sanity.json A system_test/testcase_to_skip.json A system_test/utils/__init__.py A system_test/utils/kafka_system_test_utils.py A system_test/utils/metrics.py A system_test/utils/pyh.py A system_test/utils/replication_utils.py A system_test/utils/setup_utils.py A system_test/utils/system_test_utils.py A system_test/utils/testcase_env.py 605 files changed, 48,538 insertions(+), 12,409 deletions(-) git pull ssh://gerrit.wikimedia.org:29418/operations/debs/kafka refs/changes/79/67979/1 -- To view, visit https://gerrit.wikimedia.org/r/67979 To unsubscribe, visit https://gerrit.wikimedia.org/r/settings Gerrit-MessageType: newchange Gerrit-Change-Id: Idbe8d55f9fdd89e574a08b31a7ff0b0416cc54a8 Gerrit-PatchSet: 1 Gerrit-Project: operations/debs/kafka Gerrit-Branch: master Gerrit-Owner: Akosiaris <akosia...@wikimedia.org> _______________________________________________ MediaWiki-commits mailing list MediaWiki-commits@lists.wikimedia.org https://lists.wikimedia.org/mailman/listinfo/mediawiki-commits
