You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by Tong Li <li...@us.ibm.com> on 2015/03/09 04:19:33 UTC
Review Request 31844: Patch for KAFKA-1926
-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/31844/
-----------------------------------------------------------
Review request for kafka.
Bugs: KAFKA-1926
https://issues.apache.org/jira/browse/KAFKA-1926
Repository: kafka
Description
-------
Diffs
-----
core/src/main/scala/kafka/Kafka.scala 37de7df059829f40300aa5f920219b869f9c7f78
core/src/main/scala/kafka/admin/ConsumerGroupCommand.scala 89fa29a882ae1f2be512e1ae469631c02adeeddb
core/src/main/scala/kafka/admin/PreferredReplicaLeaderElectionCommand.scala 79b5e0aeb4af77d356f80107685cd9a7d508ef16
core/src/main/scala/kafka/admin/ReassignPartitionsCommand.scala 979992b68af3723cd229845faff81c641123bb88
core/src/main/scala/kafka/admin/TopicCommand.scala f400b71f8444fffd3fc1d8398a283682390eba4e
core/src/main/scala/kafka/client/ClientUtils.scala ebba87f0566684c796c26cb76c64b4640a5ccfde
core/src/main/scala/kafka/cluster/Broker.scala 0060add008bb3bc4b0092f2173c469fce0120be6
core/src/main/scala/kafka/cluster/Partition.scala c4bf48a801007ebe7497077d2018d6dffe1677d4
core/src/main/scala/kafka/consumer/ConsumerFetcherManager.scala b9e2bea7b442a19bcebd1b350d39541a8c9dd068
core/src/main/scala/kafka/consumer/ConsumerIterator.scala 78fbf75651583e390258af2d9f09df6911a97b59
core/src/main/scala/kafka/consumer/PartitionAssignor.scala e6ff7683a0df4a7d221e949767e57c34703d5aad
core/src/main/scala/kafka/consumer/TopicCount.scala 0954b3c3ff8b3b7a7a4095436bc9e6c494a38c37
core/src/main/scala/kafka/consumer/ZookeeperConsumerConnector.scala 5487259751ebe19f137948249aa1fd2637d2deb4
core/src/main/scala/kafka/controller/ControllerChannelManager.scala c582191636f6188c25d62a67ff0315b56f163133
core/src/main/scala/kafka/controller/KafkaController.scala 09fc46d759b74bcdad2d2a610d9c5a93ff02423f
core/src/main/scala/kafka/controller/PartitionStateMachine.scala 2f0694bc5cdfc763f4872d58bec925d0cf919da1
core/src/main/scala/kafka/controller/ReplicaStateMachine.scala 3e87e1d36f87b7dd539a474609b1c95487a4c337
core/src/main/scala/kafka/controller/TopicDeletionManager.scala e56f22d7399061a72aa67a9ee73ea4d91345c01f
core/src/main/scala/kafka/log/FileMessageSet.scala b2652ddbe2f857028d5980e29a008b2c614694a3
core/src/main/scala/kafka/log/Log.scala 06b8ecc5d11a1acfbaf3c693c42bf3ce5b2cd86d
core/src/main/scala/kafka/log/LogCleanerManager.scala 351824b3c9fabe0942528147bdde8cee13b63e20
core/src/main/scala/kafka/log/LogConfig.scala 8b67aee3a37765178b30d79e9e7bb882bdc89c29
core/src/main/scala/kafka/log/LogManager.scala 47d250af62c1aa53d11204a332d0684fb4217c8d
core/src/main/scala/kafka/log/LogSegment.scala ac9643423a28d189133705ba69b16cfce23f0049
core/src/main/scala/kafka/log/OffsetIndex.scala ca82c043bb8413b1e010c40de9db1b6dae85e3ac
core/src/main/scala/kafka/log/OffsetMap.scala 42cdfbb6100b5c89d86144f92f661ebd844b2132
core/src/main/scala/kafka/message/Message.scala d3024807a84e104e6a28a29c957f4b964d8dd416
core/src/main/scala/kafka/message/MessageAndMetadata.scala d693abc620aef7030f29f915604c5e172d60da0d
core/src/main/scala/kafka/metrics/KafkaCSVMetricsReporter.scala ea9559f822c1120e1997916190fcd597328e4965
core/src/main/scala/kafka/metrics/KafkaMetricsConfig.scala 84f6208610e09943e984b54c07b8d287945574f8
core/src/main/scala/kafka/metrics/KafkaMetricsReporter.scala 14e46244ee27c8c99f33852cf03bb907cebafa51
core/src/main/scala/kafka/network/BoundedByteBufferReceive.scala a44254564531a3fc6008da2be6c1df8bdb75ec75
core/src/main/scala/kafka/network/SocketServer.scala 76ce41aed6e04ac5ba88395c4d5008aca17f9a73
core/src/main/scala/kafka/producer/ByteArrayPartitioner.scala 6a3b02e414eb7d62cfaece3344245feac54cecda
core/src/main/scala/kafka/producer/DefaultPartitioner.scala 3afb22eeb4e3b8ecf49e92bd167f2f67b8f6a961
core/src/main/scala/kafka/producer/Producer.scala e38d2fa7ec873677cc23b94092ddcd55baf1a3a2
core/src/main/scala/kafka/producer/ProducerConfig.scala 3cdf23dce3407f1770b9c6543e3a8ae8ab3ff255
core/src/main/scala/kafka/producer/async/DefaultEventHandler.scala 821901e4f434dfd9eec6eceabfc2e1e65507a57c
core/src/main/scala/kafka/server/AbstractFetcherManager.scala 20c00cb8cc2351950edbc8cb1752905a0c26e79f
core/src/main/scala/kafka/server/AbstractFetcherThread.scala 8c281d4668f92eff95a4a5df3c03c4b5b20e7095
core/src/main/scala/kafka/server/BrokerMetadataCheckpoint.scala 0e542ff0cc3eda1cbcef621e73e404c56f092862
core/src/main/scala/kafka/server/KafkaConfig.scala 48e33626695ad8a28b0018362ac225f11df94973
core/src/main/scala/kafka/server/KafkaRequestHandler.scala 4d86bdf5d146d193858005e7ecadd6e322ca2e20
core/src/main/scala/kafka/server/KafkaServer.scala 378a74d9e8e408e1e5d283badf3eded6333fadff
core/src/main/scala/kafka/server/MetadataCache.scala 6aef6e4508ecadbbcc1e12bed2054547b7aa333e
core/src/main/scala/kafka/server/OffsetManager.scala d05e14d2018c0a0b5d22697313e9abde4363d65d
core/src/main/scala/kafka/server/ZookeeperLeaderElector.scala a75818a724ff3492f640eec7a57f596324ce6c03
core/src/main/scala/kafka/tools/ConsoleConsumer.scala 910691e88ccc66a1542d0ea85bb2f732861d805e
core/src/main/scala/kafka/tools/DumpLogSegments.scala fe2cc11b75f370beb9cb87ebc9ed01b63fd65f87
core/src/main/scala/kafka/tools/KafkaMigrationTool.java 026d8198678d3e3e41feddcdaa53b67dad5c0e64
core/src/main/scala/kafka/tools/MirrorMaker.scala bafa379ff57bc46458ea8409406f5046dc9c973e
core/src/main/scala/kafka/tools/SimpleConsumerShell.scala b4f903b6c7c3bb725cac7c05eb1f885906413c4d
core/src/main/scala/kafka/tools/StateChangeLogMerger.scala b34b8c7d7d4caaab230719a67048310e0fbb3280
core/src/main/scala/kafka/tools/TestLogCleaning.scala af496f7c547a5ac7a4096a6af325dad0d8feec6f
core/src/main/scala/kafka/tools/UpdateOffsetsInZK.scala 111c9a8b94ce45d95551482e9fd3f8c1cccbf548
core/src/main/scala/kafka/utils/CoreUtils.scala PRE-CREATION
core/src/main/scala/kafka/utils/Crc32.java 0e0e7bcb33886f47b9770a122d00d6eafdbb89a9
core/src/main/scala/kafka/utils/KafkaScheduler.scala 7ceadccefe8206440ab1218a0e7cc36f1307e85a
core/src/main/scala/kafka/utils/Log4jController.scala a015c8109f050cabdea988f2215bd01ec0d8573a
core/src/main/scala/kafka/utils/Logging.scala 2890e7f51ddcb056672b30047b7b1df84a5b8df9
core/src/main/scala/kafka/utils/Utils.scala 738c1af9ef5de16fdf5130daab69757a14c48b5c
core/src/main/scala/kafka/utils/VerifiableProperties.scala 2ffc7f452dc7a1b6a06ca7a509ed49e1ab3d1e68
core/src/test/scala/integration/kafka/api/ProducerCompressionTest.scala cae72f4f87f10b843c29dc731c6e0028b1d50734
core/src/test/scala/other/kafka/DeleteZKPath.scala 25545037517b127911cedc39419194535a75be8a
core/src/test/scala/other/kafka/StressTestLog.scala e19b8b28383554512a0c1f651d6764650d8db9c4
core/src/test/scala/other/kafka/TestCrcPerformance.scala 42e3c62055c1562d3a1cee4c8374ae2559a55be7
core/src/test/scala/other/kafka/TestLinearWriteSpeed.scala 7211c2529c1db76100432737da7a1d1d221dfba0
core/src/test/scala/unit/kafka/admin/AddPartitionsTest.scala 8bc178505e00932a316c46ed1d904bd57b5b3f75
core/src/test/scala/unit/kafka/admin/AdminTest.scala ee0b21e6a94ad79c11dd08f6e5adf98c333e2ec9
core/src/test/scala/unit/kafka/consumer/ConsumerIteratorTest.scala 995397ba2e2dfc6fadd9d5c5efd90f2c4ac0d59c
core/src/test/scala/unit/kafka/integration/KafkaServerTestHarness.scala dc0512b526e914df7e7581b27df18f498da428e2
core/src/test/scala/unit/kafka/integration/PrimitiveApiTest.scala 30deaf47b64592f2e1cc84a4156671fac11b67ef
core/src/test/scala/unit/kafka/integration/RollingBounceTest.scala 4d27e41c727e73544b2b214a0a0b60f6acdbfd17
core/src/test/scala/unit/kafka/integration/UncleanLeaderElectionTest.scala 8342cae564ebc39fe74a512343a4523072ca205a
core/src/test/scala/unit/kafka/log/BrokerCompressionTest.scala fa4a8ad0acc9e8eca8f2e035ec7fe9bb24d8589a
core/src/test/scala/unit/kafka/log/CleanerTest.scala a4da95f765e5778c896551ecef0e0eaef5167ae1
core/src/test/scala/unit/kafka/log/LogCleanerIntegrationTest.scala 07acd460b1259e0a3f4069b8b8dcd8123ef5810e
core/src/test/scala/unit/kafka/log/LogManagerTest.scala 90cd53033fafaf952ba0b3f1e28b0e1f1ad3ea76
core/src/test/scala/unit/kafka/log/LogTest.scala 8cd5f2fa4a1a536c3983c5b6eac3d80de49d5a94
core/src/test/scala/unit/kafka/log4j/KafkaLog4jAppenderTest.scala 36db9172ea2d4d7e242e023ba914596c1f64f5f4
core/src/test/scala/unit/kafka/message/MessageTest.scala 7b74a0d31547074ef4ed0f95e5b347b2007c6eaf
core/src/test/scala/unit/kafka/producer/AsyncProducerTest.scala be90c5bc7f1f5ba8a237d1c7176f27029727c918
core/src/test/scala/unit/kafka/producer/ProducerTest.scala d2f3851cb68ff595bbb859d27b3552e751d060bb
core/src/test/scala/unit/kafka/server/AdvertiseBrokerTest.scala 296e2b563041318d360db4037411879613a63968
core/src/test/scala/unit/kafka/server/HighwatermarkPersistenceTest.scala 0bdbc2f31fcac2abdeff4e41e448a7b9ab13b95b
core/src/test/scala/unit/kafka/server/LeaderElectionTest.scala f2528059dd86bb051d1ce9d72039cde3b78b8817
core/src/test/scala/unit/kafka/server/LogOffsetTest.scala 8c9f9e748e888da6035755c9f4241ac3aa0500c9
core/src/test/scala/unit/kafka/server/LogRecoveryTest.scala 92d6b2c672f74cdd526f2e98da8f7fb3696a88e3
core/src/test/scala/unit/kafka/server/OffsetCommitTest.scala ea9b315099254eca82b8d5534bc02535b5996ee9
core/src/test/scala/unit/kafka/server/ServerGenerateBrokerIdTest.scala 96a8a5a8cb1f40f743490f85bf18d441ce86a765
core/src/test/scala/unit/kafka/server/ServerShutdownTest.scala b46daa436231d5aa5c1e2992fd5c2d9a73a30c80
core/src/test/scala/unit/kafka/server/ServerStartupTest.scala 60021ef8d8d7fa172d6b160db48ee5eb9574e1a9
core/src/test/scala/unit/kafka/utils/TestUtils.scala 6ce18076f6b5deb05b51c25be5bed9957e6b4339
core/src/test/scala/unit/kafka/utils/UtilsTest.scala 8c3797a964a2760a00ed60530d1a48e3da473769
core/src/test/scala/unit/kafka/zk/EmbeddedZookeeper.scala 31515615089385c722325bfe019a47ae3a9a4052
core/src/test/scala/unit/kafka/zk/ZooKeeperTestHarness.scala 67d9c4bab270c852dc05d47aaa4dd96b0f6039d4
Diff: https://reviews.apache.org/r/31844/diff/
Testing
-------
Thanks,
Tong Li