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

Review request for kafka.


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


Repository: kafka


Description
-------

working


working


working


working


working


almost done


almost done


done


one more thing


one more thing


one more thing


Diffs
-----

  config/client.keystore PRE-CREATION 
  config/client.public-key PRE-CREATION 
  config/client.ssl.properties PRE-CREATION 
  config/log4j.properties 95022543debedf26b5da58cc019de5d5b809f97f 
  config/server.keystore PRE-CREATION 
  config/server.properties b0e4496a8ca736b6abe965a430e8ce87b0e8287f 
  config/server.public-key PRE-CREATION 
  config/server.ssl.properties PRE-CREATION 
  contrib/hadoop-consumer/src/main/java/kafka/etl/KafkaETLContext.java 
1d0e0a917985736bef7af66c741e5807d8503121 
  core/src/main/scala/kafka/api/RequestKeys.scala 
c24c0345feedc7b9e2e9f40af11bfa1b8d328c43 
  core/src/main/scala/kafka/api/TopicMetadataForChannelRequest.scala 
PRE-CREATION 
  core/src/main/scala/kafka/api/UpdateMetadataRequest.scala 
530982e36b17934b8cc5fb668075a5342e142c59 
  core/src/main/scala/kafka/client/ClientUtils.scala 
ebba87f0566684c796c26cb76c64b4640a5ccfde 
  core/src/main/scala/kafka/cluster/Broker.scala 
0060add008bb3bc4b0092f2173c469fce0120be6 
  core/src/main/scala/kafka/common/BrokerChannelNotAvailableException.scala 
PRE-CREATION 
  core/src/main/scala/kafka/consumer/ConsumerConfig.scala 
9ebbee6c16dc83767297c729d2d74ebbd063a993 
  core/src/main/scala/kafka/consumer/ConsumerFetcherManager.scala 
b9e2bea7b442a19bcebd1b350d39541a8c9dd068 
  core/src/main/scala/kafka/consumer/ConsumerFetcherThread.scala 
f8c1b4e674f7515c377c6c30d212130f1ff022dd 
  core/src/main/scala/kafka/consumer/SimpleConsumer.scala 
d349a3000feb9ccd57d1f3cb163548d5bf432186 
  core/src/main/scala/kafka/consumer/ZookeeperConsumerConnector.scala 
fbc680fde21b02f11285a4f4b442987356abd17b 
  core/src/main/scala/kafka/controller/ControllerChannelManager.scala 
ecbfa0f328ba6a652a758ab20cacef324a8b2fb8 
  core/src/main/scala/kafka/controller/KafkaController.scala 
8ab4a1b8072c9dd187a9a6e94138b725d1f1b153 
  core/src/main/scala/kafka/controller/ReplicaStateMachine.scala 
3e87e1d36f87b7dd539a474609b1c95487a4c337 
  core/src/main/scala/kafka/javaapi/consumer/SimpleConsumer.scala 
0ab0195dc9f66f407061d0fac2549bd6291e41ff 
  core/src/main/scala/kafka/network/BlockingChannel.scala 
eb7bb14d94cb3648c06d4de36a3b34aacbde4556 
  core/src/main/scala/kafka/network/ChannelFactory.scala PRE-CREATION 
  core/src/main/scala/kafka/network/ChannelInfo.scala PRE-CREATION 
  core/src/main/scala/kafka/network/ChannelType.scala PRE-CREATION 
  core/src/main/scala/kafka/network/KafkaChannel.scala PRE-CREATION 
  core/src/main/scala/kafka/network/PlainSocketChannelFactory.scala 
PRE-CREATION 
  core/src/main/scala/kafka/network/SocketServer.scala 
cee76b323e5f3e4c783749ac9e78e1ef02897e3b 
  core/src/main/scala/kafka/network/ssl/KeyStores.scala PRE-CREATION 
  core/src/main/scala/kafka/network/ssl/SSLAuth.scala PRE-CREATION 
  core/src/main/scala/kafka/network/ssl/SSLChannelFactory.scala PRE-CREATION 
  core/src/main/scala/kafka/network/ssl/SSLConnectionConfig.scala PRE-CREATION 
  core/src/main/scala/kafka/network/ssl/SSLSocketChannel.scala PRE-CREATION 
  core/src/main/scala/kafka/network/ssl/store/JKSInitializer.scala PRE-CREATION 
  core/src/main/scala/kafka/producer/ProducerConfig.scala 
3cdf23dce3407f1770b9c6543e3a8ae8ab3ff255 
  core/src/main/scala/kafka/producer/SyncProducer.scala 
42c950375098b51f45c79c6a4a99a36f387bf02b 
  core/src/main/scala/kafka/producer/SyncProducerConfig.scala 
69b2d0c11bb1412ce76d566f285333c806be301a 
  core/src/main/scala/kafka/server/AbstractFetcherThread.scala 
2e9532e820b5b5c63dfd55f5454b32866d084a37 
  core/src/main/scala/kafka/server/KafkaApis.scala 
c584b559416b3ee4bcbec5966be4891e0a03eefb 
  core/src/main/scala/kafka/server/KafkaConfig.scala 
165c816a9f4c925f6e46560e7e2ff9cf7591946b 
  core/src/main/scala/kafka/server/KafkaHealthcheck.scala 
4acdd70fe9c1ee78d6510741006c2ece65450671 
  core/src/main/scala/kafka/server/KafkaServer.scala 
3e9e91f2b456bbdeb3055d571e18ffea8675b4bf 
  core/src/main/scala/kafka/server/MetadataCache.scala 
bf81a1ab88c14be8697b441eedbeb28fa0112643 
  core/src/main/scala/kafka/server/ReplicaFetcherThread.scala 
6879e730282185bda3d6bc3659cb15af0672cecf 
  core/src/main/scala/kafka/tools/ConsoleConsumer.scala 
323fc8566d974acc4e5c7d7c2a065794f3b5df4a 
  core/src/main/scala/kafka/tools/ConsoleProducer.scala 
8e9ba0b284671989f87d9c421bc98f5c4384c260 
  core/src/main/scala/kafka/tools/ConsumerOffsetChecker.scala 
d1e7c434e77859d746b8dc68dd5d5a3740425e79 
  core/src/main/scala/kafka/tools/GetOffsetShell.scala 
3d9293e4abbe3f4a4a2bc5833385747c604d5a95 
  core/src/main/scala/kafka/tools/ReplicaVerificationTool.scala 
ba6ddd7a909df79a0f7d45e8b4a2af94ea0fceb6 
  core/src/main/scala/kafka/tools/SimpleConsumerPerformance.scala 
7602b8d705970a5dab49ed36d117346a960701ac 
  core/src/main/scala/kafka/tools/SimpleConsumerShell.scala 
b4f903b6c7c3bb725cac7c05eb1f885906413c4d 
  core/src/main/scala/kafka/tools/UpdateOffsetsInZK.scala 
111c9a8b94ce45d95551482e9fd3f8c1cccbf548 
  core/src/main/scala/kafka/utils/ZkUtils.scala 
a7b1fdcb50d5cf930352d37e39cb4fc9a080cb12 
  docs/SECURITY.md PRE-CREATION 
  examples/src/main/java/kafka/examples/SimpleConsumerDemo.java 
c79192c5c195d4c3a7facf1be8f503478b6cc809 

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


Testing
-------


Thanks,

Ivan Lyutov

Reply via email to