Akosiaris has uploaded a new change for review. https://gerrit.wikimedia.org/r/67958
Change subject: Revert "Update to 3b470f56b479f618b7e90577f9857b4e25b38c1a" ...................................................................... Revert "Update to 3b470f56b479f618b7e90577f9857b4e25b38c1a" This reverts commit 04f21656a55bdb0cc0212fdb5439cd3ca900785a. This was done wrongly on master. Should be done on upstream branch Change-Id: I10141b34435500b4843fe5a16c9975f40817f840 --- M .gitignore M README.md D bin/kafka-check-reassignment-status.sh M bin/kafka-consumer-perf-test.sh D bin/kafka-preferred-replica-election.sh D 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 D bin/kafka-topics.sh M bin/run-rat.sh D bin/windows/kafka-console-consumer.bat D bin/windows/kafka-console-producer.bat D bin/windows/kafka-run-class.bat D bin/windows/kafka-server-start.bat D bin/windows/kafka-server-stop.bat D bin/windows/zookeeper-server-start.bat D bin/windows/zookeeper-server-stop.bat M config/consumer.properties M config/log4j.properties M config/producer.properties M config/server.properties D 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 D 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 D core/build.sbt D core/lib/metrics-annotation-3.0.0-c0c8be71.jar D core/lib/metrics-core-3.0.0-c0c8be71.jar D core/lib/zkclient-20120522.jar M core/src/main/scala/kafka/Kafka.scala D core/src/main/scala/kafka/admin/AdminOperationException.scala D core/src/main/scala/kafka/admin/AdminUtils.scala D core/src/main/scala/kafka/admin/CheckReassignmentStatus.scala D core/src/main/scala/kafka/admin/DeleteTopicCommand.scala D core/src/main/scala/kafka/admin/ListTopicCommand.scala D core/src/main/scala/kafka/admin/PreferredReplicaLeaderElectionCommand.scala D core/src/main/scala/kafka/admin/ReassignPartitionsCommand.scala D core/src/main/scala/kafka/admin/ShutdownBroker.scala D core/src/main/scala/kafka/admin/TopicCommand.scala D core/src/main/scala/kafka/api/ApiUtils.scala M core/src/main/scala/kafka/api/FetchRequest.scala D core/src/main/scala/kafka/api/FetchResponse.scala D core/src/main/scala/kafka/api/LeaderAndIsrRequest.scala D core/src/main/scala/kafka/api/LeaderAndIsrResponse.scala D core/src/main/scala/kafka/api/OffsetCommitRequest.scala D core/src/main/scala/kafka/api/OffsetCommitResponse.scala D core/src/main/scala/kafka/api/OffsetFetchRequest.scala D core/src/main/scala/kafka/api/OffsetFetchResponse.scala M core/src/main/scala/kafka/api/OffsetRequest.scala D core/src/main/scala/kafka/api/OffsetResponse.scala M core/src/main/scala/kafka/api/ProducerRequest.scala D core/src/main/scala/kafka/api/ProducerResponse.scala M core/src/main/scala/kafka/api/RequestKeys.scala D core/src/main/scala/kafka/api/RequestOrResponse.scala D core/src/main/scala/kafka/api/StopReplicaRequest.scala D core/src/main/scala/kafka/api/StopReplicaResponse.scala D core/src/main/scala/kafka/api/TopicMetadata.scala D core/src/main/scala/kafka/api/TopicMetadataRequest.scala D core/src/main/scala/kafka/api/TopicMetadataResponse.scala D 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 D core/src/main/scala/kafka/cluster/Replica.scala D core/src/main/scala/kafka/common/AdminCommandFailedException.scala D core/src/main/scala/kafka/common/BrokerNotAvailableException.scala D core/src/main/scala/kafka/common/BrokerNotExistException.scala D core/src/main/scala/kafka/common/ClientIdAndBroker.scala D core/src/main/scala/kafka/common/ClientIdAndTopic.scala D core/src/main/scala/kafka/common/Config.scala D core/src/main/scala/kafka/common/ControllerMovedException.scala M core/src/main/scala/kafka/common/ErrorMapping.scala D core/src/main/scala/kafka/common/FailedToSendMessageException.scala D core/src/main/scala/kafka/common/InvalidTopicException.scala D core/src/main/scala/kafka/common/KafkaException.scala D core/src/main/scala/kafka/common/KafkaStorageException.scala D core/src/main/scala/kafka/common/LeaderNotAvailableException.scala D core/src/main/scala/kafka/common/MessageSizeTooLargeException.scala D core/src/main/scala/kafka/common/NoEpochForPartitionException.scala D core/src/main/scala/kafka/common/NotLeaderForPartitionException.scala D core/src/main/scala/kafka/common/OffsetMetadataAndError.scala D core/src/main/scala/kafka/common/OffsetMetadataTooLargeException.scala D core/src/main/scala/kafka/common/OptimisticLockFailureException.scala D core/src/main/scala/kafka/common/PartitionOfflineException.scala D core/src/main/scala/kafka/common/QueueFullException.scala D core/src/main/scala/kafka/common/ReplicaNotAvailableException.scala D core/src/main/scala/kafka/common/RequestTimedOutException.scala D core/src/main/scala/kafka/common/StateChangeFailedException.scala D core/src/main/scala/kafka/common/Topic.scala D core/src/main/scala/kafka/common/TopicAndPartition.scala D core/src/main/scala/kafka/common/TopicExistsException.scala D core/src/main/scala/kafka/common/UnknownTopicException.scala D 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 D core/src/main/scala/kafka/consumer/ConsumerFetcherManager.scala D 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 D core/src/main/scala/kafka/consumer/ConsumerTopicStats.scala D core/src/main/scala/kafka/consumer/FetchRequestAndResponseStats.scala M core/src/main/scala/kafka/consumer/FetchedDataChunk.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/controller/ControllerChannelManager.scala D core/src/main/scala/kafka/controller/KafkaController.scala D core/src/main/scala/kafka/controller/PartitionLeaderSelector.scala D core/src/main/scala/kafka/controller/PartitionStateMachine.scala D core/src/main/scala/kafka/controller/ReplicaStateMachine.scala D core/src/main/scala/kafka/javaapi/FetchRequest.scala D core/src/main/scala/kafka/javaapi/FetchResponse.scala M core/src/main/scala/kafka/javaapi/Implicits.scala D core/src/main/scala/kafka/javaapi/OffsetCommitRequest.scala D core/src/main/scala/kafka/javaapi/OffsetCommitResponse.scala D core/src/main/scala/kafka/javaapi/OffsetFetchRequest.scala D core/src/main/scala/kafka/javaapi/OffsetFetchResponse.scala D core/src/main/scala/kafka/javaapi/OffsetRequest.scala D core/src/main/scala/kafka/javaapi/OffsetResponse.scala D core/src/main/scala/kafka/javaapi/TopicMetadata.scala D core/src/main/scala/kafka/javaapi/TopicMetadataRequest.scala D 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/log/CleanerConfig.scala D core/src/main/scala/kafka/log/FileMessageSet.scala M core/src/main/scala/kafka/log/Log.scala D core/src/main/scala/kafka/log/LogCleaner.scala D core/src/main/scala/kafka/log/LogConfig.scala M core/src/main/scala/kafka/log/LogManager.scala D core/src/main/scala/kafka/log/LogSegment.scala D core/src/main/scala/kafka/log/OffsetIndex.scala D core/src/main/scala/kafka/log/OffsetMap.scala D core/src/main/scala/kafka/log/OffsetPosition.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 D core/src/main/scala/kafka/message/CompressionFactory.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 D core/src/main/scala/kafka/metrics/KafkaCSVMetricsReporter.scala D core/src/main/scala/kafka/metrics/KafkaMetricsConfig.scala D core/src/main/scala/kafka/metrics/KafkaMetricsGroup.scala D core/src/main/scala/kafka/metrics/KafkaMetricsReporter.scala D core/src/main/scala/kafka/metrics/KafkaTimer.scala D 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/RequestChannel.scala M core/src/main/scala/kafka/network/SocketServer.scala M core/src/main/scala/kafka/network/Transmission.scala M core/src/main/scala/kafka/producer/BrokerPartitionInfo.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 D 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 D core/src/main/scala/kafka/producer/ProducerClosedException.scala M core/src/main/scala/kafka/producer/ProducerConfig.scala M core/src/main/scala/kafka/producer/ProducerPool.scala D core/src/main/scala/kafka/producer/ProducerRequestStats.scala D core/src/main/scala/kafka/producer/ProducerStats.scala D 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 M core/src/main/scala/kafka/producer/async/AsyncProducerConfig.scala M core/src/main/scala/kafka/producer/async/AsyncProducerStats.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 M core/src/main/scala/kafka/serializer/Decoder.scala M core/src/main/scala/kafka/serializer/Encoder.scala D core/src/main/scala/kafka/server/AbstractFetcherManager.scala D core/src/main/scala/kafka/server/AbstractFetcherThread.scala D core/src/main/scala/kafka/server/KafkaApis.scala M core/src/main/scala/kafka/server/KafkaConfig.scala D core/src/main/scala/kafka/server/KafkaHealthcheck.scala D core/src/main/scala/kafka/server/KafkaRequestHandler.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/LeaderElector.scala M core/src/main/scala/kafka/server/MessageSetSend.scala D core/src/main/scala/kafka/server/OffsetCheckpoint.scala D core/src/main/scala/kafka/server/ReplicaFetcherManager.scala D core/src/main/scala/kafka/server/ReplicaFetcherThread.scala D core/src/main/scala/kafka/server/ReplicaManager.scala D core/src/main/scala/kafka/server/RequestPurgatory.scala D core/src/main/scala/kafka/server/TopicConfigManager.scala D core/src/main/scala/kafka/server/ZookeeperLeaderElector.scala M core/src/main/scala/kafka/tools/ConsumerOffsetChecker.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 D core/src/main/scala/kafka/tools/KafkaMigrationTool.java M core/src/main/scala/kafka/tools/MirrorMaker.scala M core/src/main/scala/kafka/tools/ReplayLogProducer.scala M core/src/main/scala/kafka/tools/SimpleConsumerShell.scala D core/src/main/scala/kafka/tools/StateChangeLogMerger.scala D core/src/main/scala/kafka/tools/UpdateOffsetsInZK.scala M core/src/main/scala/kafka/tools/VerifyConsumerRebalance.scala D core/src/main/scala/kafka/utils/CommandLineUtils.scala D core/src/main/scala/kafka/utils/Crc32.java M core/src/main/scala/kafka/utils/DelayedItem.scala D core/src/main/scala/kafka/utils/FileLock.scala M core/src/main/scala/kafka/utils/IteratorTemplate.scala D 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 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/ShutdownableThread.scala M core/src/main/scala/kafka/utils/Throttler.scala D core/src/main/scala/kafka/utils/Topic.scala M core/src/main/scala/kafka/utils/Utils.scala D 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/scala/other/kafka/StressTestLog.scala D core/src/test/scala/other/kafka/TestCrcPerformance.scala D 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 D 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 D core/src/test/scala/unit/kafka/admin/AdminTest.scala D core/src/test/scala/unit/kafka/api/ApiUtilsTest.scala D core/src/test/scala/unit/kafka/api/RequestResponseSerializationTest.scala D core/src/test/scala/unit/kafka/common/ConfigTest.scala D core/src/test/scala/unit/kafka/common/TopicTest.scala D 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 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 M core/src/test/scala/unit/kafka/integration/PrimitiveApiTest.scala M core/src/test/scala/unit/kafka/integration/ProducerConsumerTestHarness.scala D core/src/test/scala/unit/kafka/integration/TopicMetadataTest.scala M core/src/test/scala/unit/kafka/javaapi/consumer/ZookeeperConsumerConnectorTest.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/log/CleanerTest.scala D core/src/test/scala/unit/kafka/log/FileMessageSetTest.scala D 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/LogSegmentTest.scala M core/src/test/scala/unit/kafka/log/LogTest.scala D core/src/test/scala/unit/kafka/log/OffsetIndexTest.scala D core/src/test/scala/unit/kafka/log/OffsetMapTest.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/MessageCompressionTest.scala M core/src/test/scala/unit/kafka/message/MessageTest.scala D 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 M core/src/test/scala/unit/kafka/producer/ProducerTest.scala M core/src/test/scala/unit/kafka/producer/SyncProducerTest.scala D core/src/test/scala/unit/kafka/server/HighwatermarkPersistenceTest.scala D core/src/test/scala/unit/kafka/server/ISRExpirationTest.scala D core/src/test/scala/unit/kafka/server/LeaderElectionTest.scala D core/src/test/scala/unit/kafka/server/LogOffsetTest.scala D core/src/test/scala/unit/kafka/server/LogRecoveryTest.scala D core/src/test/scala/unit/kafka/server/OffsetCommitTest.scala D core/src/test/scala/unit/kafka/server/ReplicaFetchTest.scala D core/src/test/scala/unit/kafka/server/RequestPurgatoryTest.scala M core/src/test/scala/unit/kafka/server/ServerShutdownTest.scala D core/src/test/scala/unit/kafka/server/SimpleFetchTest.scala D core/src/test/scala/unit/kafka/utils/IteratorTemplateTest.scala D core/src/test/scala/unit/kafka/utils/JsonTest.scala D core/src/test/scala/unit/kafka/utils/MockScheduler.scala D core/src/test/scala/unit/kafka/utils/MockTime.scala D 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 M core/src/test/scala/unit/kafka/zk/ZooKeeperTestHarness.scala D examples/build.sbt M examples/src/main/java/kafka/examples/Consumer.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 D lib/apache-rat-0.8.jar M lib/sbt-launch.jar D 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 D project/Build.scala M project/build.properties M project/build/KafkaProject.scala D project/plugins.sbt D sbt.bat D system_test/README.txt D 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 D system_test/cluster_config.json M system_test/common/util.sh D system_test/logging.conf D system_test/metrics.json D system_test/migration_tool_testsuite/0.7/bin/kafka-run-class.sh D system_test/migration_tool_testsuite/0.7/bin/zookeeper-server-start.sh D system_test/migration_tool_testsuite/0.7/lib/kafka-0.7.0.jar D system_test/migration_tool_testsuite/0.7/lib/kafka-perf-0.7.0.jar D system_test/migration_tool_testsuite/0.7/lib/zkclient-0.1.jar D system_test/migration_tool_testsuite/__init__.py D system_test/migration_tool_testsuite/cluster_config.json D system_test/migration_tool_testsuite/config/migration_consumer.properties D system_test/migration_tool_testsuite/config/migration_producer.properties D system_test/migration_tool_testsuite/config/server.properties D system_test/migration_tool_testsuite/config/zookeeper.properties D system_test/migration_tool_testsuite/migration_tool_test.py D system_test/migration_tool_testsuite/testcase_9001/testcase_9001_properties.json D system_test/migration_tool_testsuite/testcase_9003/cluster_config.json D system_test/migration_tool_testsuite/testcase_9003/testcase_9003_properties.json D system_test/migration_tool_testsuite/testcase_9004/cluster_config.json D system_test/migration_tool_testsuite/testcase_9004/testcase_9004_properties.json D system_test/migration_tool_testsuite/testcase_9005/cluster_config.json D system_test/migration_tool_testsuite/testcase_9005/testcase_9005_properties.json D system_test/migration_tool_testsuite/testcase_9006/cluster_config.json D 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 D system_test/mirror_maker_testsuite/__init__.py D system_test/mirror_maker_testsuite/cluster_config.json D system_test/mirror_maker_testsuite/config/console_consumer.properties D system_test/mirror_maker_testsuite/config/consumer.properties D system_test/mirror_maker_testsuite/config/log4j.properties D system_test/mirror_maker_testsuite/config/mirror_consumer.properties D system_test/mirror_maker_testsuite/config/mirror_producer.properties D system_test/mirror_maker_testsuite/config/producer.properties D system_test/mirror_maker_testsuite/config/producer_performance.properties D system_test/mirror_maker_testsuite/config/server.properties D system_test/mirror_maker_testsuite/config/zookeeper.properties D system_test/mirror_maker_testsuite/mirror_maker_test.py D system_test/mirror_maker_testsuite/testcase_5001/testcase_5001_properties.json D system_test/mirror_maker_testsuite/testcase_5002/testcase_5002_properties.json D system_test/mirror_maker_testsuite/testcase_5003/cluster_config.json D system_test/mirror_maker_testsuite/testcase_5003/testcase_5003_properties.json D system_test/mirror_maker_testsuite/testcase_5004/cluster_config.json D system_test/mirror_maker_testsuite/testcase_5004/testcase_5004_properties.json D system_test/mirror_maker_testsuite/testcase_5005/cluster_config.json D system_test/mirror_maker_testsuite/testcase_5005/testcase_5005_properties.json D system_test/mirror_maker_testsuite/testcase_5006/cluster_config.json D 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 D system_test/replication_testsuite/__init__.py D system_test/replication_testsuite/config/console_consumer.properties D system_test/replication_testsuite/config/consumer.properties D system_test/replication_testsuite/config/log4j.properties D system_test/replication_testsuite/config/producer.properties D system_test/replication_testsuite/config/producer_performance.properties D system_test/replication_testsuite/config/server.properties D system_test/replication_testsuite/config/zookeeper.properties D system_test/replication_testsuite/replica_basic_test.py D system_test/replication_testsuite/testcase_0001/testcase_0001_properties.json D system_test/replication_testsuite/testcase_0002/testcase_0002_properties.json D system_test/replication_testsuite/testcase_0003/testcase_0003_properties.json D system_test/replication_testsuite/testcase_0004/testcase_0004_properties.json D system_test/replication_testsuite/testcase_0005/testcase_0005_properties.json D system_test/replication_testsuite/testcase_0006/testcase_0006_properties.json D system_test/replication_testsuite/testcase_0007/testcase_0007_properties.json D system_test/replication_testsuite/testcase_0008/testcase_0008_properties.json D system_test/replication_testsuite/testcase_0009/testcase_0009_properties.json D system_test/replication_testsuite/testcase_0010/testcase_0010_properties.json D system_test/replication_testsuite/testcase_0011/testcase_0011_properties.json D system_test/replication_testsuite/testcase_0021/cluster_config.json D system_test/replication_testsuite/testcase_0021/testcase_0021_properties.json D system_test/replication_testsuite/testcase_0022/cluster_config.json D system_test/replication_testsuite/testcase_0022/testcase_0022_properties.json D system_test/replication_testsuite/testcase_0023/cluster_config.json D system_test/replication_testsuite/testcase_0023/testcase_0023_properties.json D system_test/replication_testsuite/testcase_0024/testcase_0024_properties.json D system_test/replication_testsuite/testcase_0101/testcase_0101_properties.json D system_test/replication_testsuite/testcase_0102/testcase_0102_properties.json D system_test/replication_testsuite/testcase_0103/testcase_0103_properties.json D system_test/replication_testsuite/testcase_0104/testcase_0104_properties.json D system_test/replication_testsuite/testcase_0105/testcase_0105_properties.json D system_test/replication_testsuite/testcase_0106/testcase_0106_properties.json D system_test/replication_testsuite/testcase_0107/testcase_0107_properties.json D system_test/replication_testsuite/testcase_0108/testcase_0108_properties.json D system_test/replication_testsuite/testcase_0109/testcase_0109_properties.json D system_test/replication_testsuite/testcase_0110/testcase_0110_properties.json D system_test/replication_testsuite/testcase_0111/testcase_0111_properties.json D system_test/replication_testsuite/testcase_0112/testcase_0112_properties.json D system_test/replication_testsuite/testcase_0113/testcase_0113_properties.json D system_test/replication_testsuite/testcase_0114/testcase_0114_properties.json D system_test/replication_testsuite/testcase_0115/testcase_0115_properties.json D system_test/replication_testsuite/testcase_0116/testcase_0116_properties.json D system_test/replication_testsuite/testcase_0117/testcase_0117_properties.json D system_test/replication_testsuite/testcase_0118/testcase_0118_properties.json D system_test/replication_testsuite/testcase_0119/testcase_0119_properties.json D system_test/replication_testsuite/testcase_0121/cluster_config.json D system_test/replication_testsuite/testcase_0121/testcase_0121_properties.json D system_test/replication_testsuite/testcase_0122/cluster_config.json D system_test/replication_testsuite/testcase_0122/testcase_0122_properties.json D system_test/replication_testsuite/testcase_0123/cluster_config.json D system_test/replication_testsuite/testcase_0123/testcase_0123_properties.json D system_test/replication_testsuite/testcase_0124/cluster_config.json D system_test/replication_testsuite/testcase_0124/testcase_0124_properties.json D system_test/replication_testsuite/testcase_0125/cluster_config.json D system_test/replication_testsuite/testcase_0125/testcase_0125_properties.json D system_test/replication_testsuite/testcase_0126/cluster_config.json D system_test/replication_testsuite/testcase_0126/testcase_0126_properties.json D system_test/replication_testsuite/testcase_0127/cluster_config.json D system_test/replication_testsuite/testcase_0127/testcase_0127_properties.json D system_test/replication_testsuite/testcase_0128/testcase_0128_properties.json D system_test/replication_testsuite/testcase_0131/cluster_config.json D system_test/replication_testsuite/testcase_0131/testcase_0131_properties.json D system_test/replication_testsuite/testcase_0132/cluster_config.json D system_test/replication_testsuite/testcase_0132/testcase_0132_properties.json D system_test/replication_testsuite/testcase_0133/cluster_config.json D system_test/replication_testsuite/testcase_0133/testcase_0133_properties.json D system_test/replication_testsuite/testcase_0134/testcase_0134_properties.json D system_test/replication_testsuite/testcase_0151/testcase_0151_properties.json D system_test/replication_testsuite/testcase_0152/testcase_0152_properties.json D system_test/replication_testsuite/testcase_0153/testcase_0153_properties.json D system_test/replication_testsuite/testcase_0154/testcase_0154_properties.json D system_test/replication_testsuite/testcase_0155/testcase_0155_properties.json D system_test/replication_testsuite/testcase_0156/testcase_0156_properties.json D system_test/replication_testsuite/testcase_0157/testcase_0157_properties.json D system_test/replication_testsuite/testcase_0158/testcase_0158_properties.json D system_test/replication_testsuite/testcase_0159/testcase_0159_properties.json D system_test/replication_testsuite/testcase_0201/testcase_0201_properties.json D system_test/replication_testsuite/testcase_0202/testcase_0202_properties.json D system_test/replication_testsuite/testcase_0203/testcase_0203_properties.json D system_test/replication_testsuite/testcase_0204/testcase_0204_properties.json D system_test/replication_testsuite/testcase_0205/testcase_0205_properties.json D system_test/replication_testsuite/testcase_0206/testcase_0206_properties.json D system_test/replication_testsuite/testcase_0207/testcase_0207_properties.json D system_test/replication_testsuite/testcase_0208/testcase_0208_properties.json D system_test/replication_testsuite/testcase_0209/testcase_0209_properties.json D system_test/replication_testsuite/testcase_0251/testcase_0251_properties.json D system_test/replication_testsuite/testcase_0252/testcase_0252_properties.json D system_test/replication_testsuite/testcase_0253/testcase_0253_properties.json D system_test/replication_testsuite/testcase_0254/testcase_0254_properties.json D system_test/replication_testsuite/testcase_0255/testcase_0255_properties.json D system_test/replication_testsuite/testcase_0256/testcase_0256_properties.json D system_test/replication_testsuite/testcase_0257/testcase_0257_properties.json D system_test/replication_testsuite/testcase_0258/testcase_0258_properties.json D system_test/replication_testsuite/testcase_0259/testcase_0259_properties.json D system_test/replication_testsuite/testcase_0301/testcase_0301_properties.json D system_test/replication_testsuite/testcase_0302/testcase_0302_properties.json D system_test/replication_testsuite/testcase_0303/testcase_0303_properties.json D system_test/replication_testsuite/testcase_0304/testcase_0304_properties.json D system_test/replication_testsuite/testcase_0305/testcase_0305_properties.json D system_test/replication_testsuite/testcase_0306/testcase_0306_properties.json D system_test/replication_testsuite/testcase_0307/testcase_0307_properties.json D system_test/replication_testsuite/testcase_0308/testcase_0308_properties.json D system_test/replication_testsuite/testcase_0309/testcase_0309_properties.json D system_test/replication_testsuite/testcase_1/cluster_config.json D system_test/replication_testsuite/testcase_1/testcase_1_properties.json D system_test/replication_testsuite/testcase_4001/cluster_config.json D system_test/replication_testsuite/testcase_4001/testcase_4001_properties.json D system_test/replication_testsuite/testcase_4002/cluster_config.json D system_test/replication_testsuite/testcase_4002/testcase_4002_properties.json D system_test/replication_testsuite/testcase_4003/cluster_config.json D system_test/replication_testsuite/testcase_4003/testcase_4003_properties.json D system_test/replication_testsuite/testcase_4004/cluster_config.json D system_test/replication_testsuite/testcase_4004/testcase_4004_properties.json D system_test/replication_testsuite/testcase_4005/cluster_config.json D system_test/replication_testsuite/testcase_4005/testcase_4005_properties.json D system_test/replication_testsuite/testcase_4006/cluster_config.json D system_test/replication_testsuite/testcase_4006/testcase_4006_properties.json D system_test/replication_testsuite/testcase_4007/cluster_config.json D system_test/replication_testsuite/testcase_4007/testcase_4007_properties.json D system_test/replication_testsuite/testcase_4008/cluster_config.json D system_test/replication_testsuite/testcase_4008/testcase_4008_properties.json D system_test/replication_testsuite/testcase_4011/cluster_config.json D system_test/replication_testsuite/testcase_4011/testcase_4011_properties.json D system_test/replication_testsuite/testcase_4012/cluster_config.json D system_test/replication_testsuite/testcase_4012/testcase_4012_properties.json D system_test/replication_testsuite/testcase_4013/cluster_config.json D system_test/replication_testsuite/testcase_4013/testcase_4013_properties.json D system_test/replication_testsuite/testcase_4014/cluster_config.json D system_test/replication_testsuite/testcase_4014/testcase_4014_properties.json D system_test/replication_testsuite/testcase_4015/cluster_config.json D system_test/replication_testsuite/testcase_4015/testcase_4015_properties.json D system_test/replication_testsuite/testcase_4016/cluster_config.json D system_test/replication_testsuite/testcase_4016/testcase_4016_properties.json D system_test/replication_testsuite/testcase_4017/cluster_config.json D system_test/replication_testsuite/testcase_4017/testcase_4017_properties.json D system_test/replication_testsuite/testcase_4018/cluster_config.json D system_test/replication_testsuite/testcase_4018/testcase_4018_properties.json D system_test/replication_testsuite/testcase_9051/cluster_config.json D system_test/replication_testsuite/testcase_9051/testcase_9051_properties.json D system_test/run_sanity.sh D system_test/system_test_env.py D system_test/system_test_runner.py D system_test/testcase_to_run.json D system_test/testcase_to_run_all.json D system_test/testcase_to_run_sanity.json D system_test/testcase_to_skip.json D system_test/utils/__init__.py D system_test/utils/kafka_system_test_utils.py D system_test/utils/metrics.py D system_test/utils/pyh.py D system_test/utils/replication_utils.py D system_test/utils/setup_utils.py D system_test/utils/system_test_utils.py D system_test/utils/testcase_env.py 549 files changed, 7,133 insertions(+), 48,565 deletions(-) git pull ssh://gerrit.wikimedia.org:29418/operations/debs/kafka refs/changes/58/67958/1 -- To view, visit https://gerrit.wikimedia.org/r/67958 To unsubscribe, visit https://gerrit.wikimedia.org/r/settings Gerrit-MessageType: newchange Gerrit-Change-Id: I10141b34435500b4843fe5a16c9975f40817f840 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