-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/20083/
-----------------------------------------------------------

(Updated April 9, 2014, 12:41 p.m.)


Review request for kafka.


Bugs: KAFKA-1351
    https://issues.apache.org/jira/browse/KAFKA-1351


Repository: kafka


Description (updated)
-------

KAFKA-1351 - removed redundant changes.


KAFKA-1351 - Replaced String.format occurencies with Utils.formatString


KAFKA-1351 - Implemented more efficient substitution for String.format in Scala.


Diffs (updated)
-----

  core/src/main/scala/kafka/Kafka.scala 
988014a51c332ba04609ee7fbb06f0b09546f267 
  core/src/main/scala/kafka/admin/AdminUtils.scala 
36ddeb44490e8343a4e8056c45726ac660e4b2f9 
  core/src/main/scala/kafka/admin/PreferredReplicaLeaderElectionCommand.scala 
9b3c6aeaf77db6cea75272c60a42fa45955fed5b 
  core/src/main/scala/kafka/admin/ReassignPartitionsCommand.scala 
2637586af99cf8a6c4ea3a4ccb244d1e76f0f81a 
  core/src/main/scala/kafka/admin/ShutdownBroker.scala 
2dd47e7362f42b434ec8bb6b93f0cb0cb1a50a28 
  core/src/main/scala/kafka/admin/TopicCommand.scala 
686a0dfc65b036263375db7f64f1f2bae42199b0 
  core/src/main/scala/kafka/api/FetchResponse.scala 
d117f10f724b09d6deef0df3a138d28fc91aa13a 
  core/src/main/scala/kafka/api/RequestKeys.scala 
fbfc9d3aeaffed4ca85902125fcc1050086835db 
  core/src/main/scala/kafka/api/StopReplicaRequest.scala 
68fc1389ee71122adb716d9d821dd8987a78ecee 
  core/src/main/scala/kafka/api/TopicMetadata.scala 
0513a59ed94e556894b3515dc38666ee9a66ae3d 
  core/src/main/scala/kafka/client/ClientUtils.scala 
fc9e08423a4127e1d64be1e62def567ea9eb80a3 
  core/src/main/scala/kafka/cluster/Broker.scala 
9407ed21fbbd57edeecd888edc32bea6a05d95b3 
  core/src/main/scala/kafka/cluster/Partition.scala 
6d6b4ab91608162201d2737d784580728193566a 
  core/src/main/scala/kafka/common/ClientIdAndBroker.scala 
93223a9c93b55df85e7f28d1c8667c9a0a8c8992 
  core/src/main/scala/kafka/common/ClientIdAndTopic.scala 
7acf9e76bdd874953fb49bf0673232b64afbf008 
  core/src/main/scala/kafka/common/OffsetMetadataAndError.scala 
1586243d20d6a181a1bd9f07e1c9493596005b32 
  core/src/main/scala/kafka/common/TopicAndPartition.scala 
df3db912f5daef6a25b4b2dd2220d2cc3795bce6 
  core/src/main/scala/kafka/consumer/ConsoleConsumer.scala 
0f62819be0562f62c0f778bd20ead053f01a6f2f 
  core/src/main/scala/kafka/consumer/ConsumerFetcherManager.scala 
b9e2bea7b442a19bcebd1b350d39541a8c9dd068 
  core/src/main/scala/kafka/consumer/ConsumerIterator.scala 
ac491b4da2583ef7227c67f5b8bc0fd731d705c3 
  core/src/main/scala/kafka/consumer/PartitionTopicInfo.scala 
9c779ce072fb0a3426e96fd77f383cce6991a0f9 
  core/src/main/scala/kafka/consumer/SimpleConsumer.scala 
0e64632210385ef63c2ad3445b55ac4f37a63df2 
  core/src/main/scala/kafka/consumer/TopicFilter.scala 
5a13540699be45de8fd3a6805820b5866ff9b7fa 
  core/src/main/scala/kafka/consumer/ZookeeperConsumerConnector.scala 
ff5e81943e10ef37de16f657aeecc25e17d3e83a 
  core/src/main/scala/kafka/consumer/ZookeeperTopicEventWatcher.scala 
38f4ec0bd1b388cc8fc04b38bbb2e7aaa1c3f43b 
  core/src/main/scala/kafka/controller/ControllerChannelManager.scala 
f17d97603798e803d035f313f0165f11f6d0f2c0 
  core/src/main/scala/kafka/controller/KafkaController.scala 
fcabd0da201ccd478f5884bcca9b75a8c8ea8373 
  core/src/main/scala/kafka/controller/PartitionLeaderSelector.scala 
d3b25fa405e9fe467bcedaa290784d75692e7207 
  core/src/main/scala/kafka/controller/PartitionStateMachine.scala 
6457b56340a1b5440b07612f69dcffe4b051f919 
  core/src/main/scala/kafka/controller/ReplicaStateMachine.scala 
0e47dac8cbf65a86d053a3371a18af467afd70ae 
  core/src/main/scala/kafka/controller/TopicDeletionManager.scala 
09f54acc733d49a9be9a9c6633271c190dea1bf0 
  core/src/main/scala/kafka/javaapi/TopicMetadataRequest.scala 
7e6da164a26b1893c26c624a9998d4fedf8af95e 
  core/src/main/scala/kafka/log/FileMessageSet.scala 
b2652ddbe2f857028d5980e29a008b2c614694a3 
  core/src/main/scala/kafka/log/Log.scala 
46df8d99d977a3b010a9b9f4698187fa9bfb2498 
  core/src/main/scala/kafka/log/LogCleaner.scala 
b9ffe00d6c656476ed4c4e6f68fb2ba115090c92 
  core/src/main/scala/kafka/log/LogCleanerManager.scala 
6a981345fd7dc711e6c4f058a42bd7f8f9d350fe 
  core/src/main/scala/kafka/log/LogConfig.scala 
5746ad4767589594f904aa085131dd95e56d72bb 
  core/src/main/scala/kafka/log/LogManager.scala 
8ed9b68e763aa14e3ef282eec738fa190eb20132 
  core/src/main/scala/kafka/log/LogSegment.scala 
0d6926ea105a99c9ff2cfc9ea6440f2f2d37bde8 
  core/src/main/scala/kafka/log/OffsetIndex.scala 
8a62dfad9bc48b2a295697400d4ebfd2f6806a9f 
  core/src/main/scala/kafka/message/CompressionCodec.scala 
8762a790af2ab7f60a5e4e19955c7eb7ad7bc749 
  core/src/main/scala/kafka/message/Message.scala 
52c082f5213ba48a39bf0d17e4ced2714276f0e0 
  core/src/main/scala/kafka/metrics/KafkaCSVMetricsReporter.scala 
ea9559f822c1120e1997916190fcd597328e4965 
  core/src/main/scala/kafka/network/BoundedByteBufferReceive.scala 
a44254564531a3fc6008da2be6c1df8bdb75ec75 
  core/src/main/scala/kafka/network/RequestChannel.scala 
a6ec970d72fc8adc56bc6e200d1ff5bbf0d2b748 
  core/src/main/scala/kafka/network/SocketServer.scala 
dcfca3f4156957b0006ba9bfdeca848c115825a8 
  core/src/main/scala/kafka/producer/BrokerPartitionInfo.scala 
13a8aa665016e19284c8ced35bac2195fe9e4378 
  core/src/main/scala/kafka/producer/ProducerPool.scala 
43df70bb461dd3e385e6b20396adef3c4016a3fc 
  core/src/main/scala/kafka/producer/SyncProducer.scala 
489f0077512d9a69be81649c490274964290fa40 
  core/src/main/scala/kafka/producer/async/DefaultEventHandler.scala 
d8ac915de31a26d7aa67760d69373975cacd0c9d 
  core/src/main/scala/kafka/server/AbstractFetcherManager.scala 
9390edf37dae9815d4a3790fdd31dac422382698 
  core/src/main/scala/kafka/server/AbstractFetcherThread.scala 
db7017b8a8ff06384674f36792053e4bc68419f1 
  core/src/main/scala/kafka/server/KafkaApis.scala 
c068ef69207c351eec413a595f1747c59f8b3983 
  core/src/main/scala/kafka/server/KafkaHealthcheck.scala 
4acdd70fe9c1ee78d6510741006c2ece65450671 
  core/src/main/scala/kafka/server/KafkaRequestHandler.scala 
871212bf9110ca95ca7d2109be070f69d0f90247 
  core/src/main/scala/kafka/server/KafkaServer.scala 
c208f83bed7fb91f07fae42f2b66892e6d46fecc 
  core/src/main/scala/kafka/server/OffsetCheckpoint.scala 
19f61a9718a7f8e6f9bf743ac9eb2118d0fdd9b0 
  core/src/main/scala/kafka/server/OffsetManager.scala 
89a88a7e4055f804429b64e85b2f65312d1e2155 
  core/src/main/scala/kafka/server/ReplicaFetcherManager.scala 
351dbbad3bdb709937943b336a5b0a9e0162a5e2 
  core/src/main/scala/kafka/server/ReplicaFetcherThread.scala 
75ae1e161769a020a102009df416009bd6710f4a 
  core/src/main/scala/kafka/server/ReplicaManager.scala 
0f5aaa9888d6c0ca0b073f4742bee14ad72d0484 
  core/src/main/scala/kafka/server/RequestPurgatory.scala 
c064c5c4cf1191335572da8a2caf5f95dce902c1 
  core/src/main/scala/kafka/server/TopicConfigManager.scala 
d41fd33d91406dfa2ce8c1e1b04a078e983ccadd 
  core/src/main/scala/kafka/server/ZookeeperLeaderElector.scala 
e5b6ff1e2544b043007cf16a6b9dd4451c839e63 
  core/src/main/scala/kafka/tools/ConsumerOffsetChecker.scala 
88f824fa5afe7964efc569bc0732fd40a55c5c93 
  core/src/main/scala/kafka/tools/DumpLogSegments.scala 
f0ab02a4e6dd1b945b263607c26ae22f00e6b158 
  core/src/main/scala/kafka/tools/ExportZkOffsets.scala 
005231f38dd9cea60ec953a28a1ab57d3e316eed 
  core/src/main/scala/kafka/tools/GetOffsetShell.scala 
fba652e3716a67b04431fc46790ad255201b639f 
  core/src/main/scala/kafka/tools/ImportZkOffsets.scala 
c8023ee60c07b6e59906da9331bd5d764fd60cba 
  core/src/main/scala/kafka/tools/MirrorMaker.scala 
e4d1a86f673f7df7fe71ce44e3550fcde8d01bba 
  core/src/main/scala/kafka/tools/SimpleConsumerShell.scala 
747e07280cce72d621acbc771337b909a9b2487e 
  core/src/main/scala/kafka/tools/TestLogCleaning.scala 
edb6e5f8fe511debd8b971dddb786e684ed7e1ac 
  core/src/main/scala/kafka/tools/UpdateOffsetsInZK.scala 
111c9a8b94ce45d95551482e9fd3f8c1cccbf548 
  core/src/main/scala/kafka/tools/VerifyConsumerRebalance.scala 
92c0d1f979fba3496d1f092cc073073dcf4447e6 
  core/src/main/scala/kafka/tools/newproducer/MirrorMaker.scala 
a969a22c6b82ed5c9f053a50594b1c7a768efd0e 
  core/src/main/scala/kafka/utils/Json.scala 
d1102844748f2e88f79932281fe95583a57d2d16 
  core/src/main/scala/kafka/utils/KafkaScheduler.scala 
8e3750506c1803f34b9f1829b21097f1441d7463 
  core/src/main/scala/kafka/utils/Log4jController.scala 
a015c8109f050cabdea988f2215bd01ec0d8573a 
  core/src/main/scala/kafka/utils/Throttler.scala 
d1a144d7882919426824799ff8e8a47f89c83158 
  core/src/main/scala/kafka/utils/Utils.scala 
6bfbac16e2f8d68b8c711a0336c698aa6f610ae8 
  core/src/main/scala/kafka/utils/VerifiableProperties.scala 
d40b03ca844ebb3e4f91e8bc44bc5edcf4cb292c 
  core/src/main/scala/kafka/utils/ZkUtils.scala 
16bf7e3e87b520b31485199b2830494ca5f96c1a 
  core/src/test/scala/unit/kafka/utils/UtilsTest.scala 
920f318c85a747b689f97c0e73e4234f20b1460a 

Diff: https://reviews.apache.org/r/20083/diff/


Testing
-------


Thanks,

Ivan Lyutov

Reply via email to