----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/30477/ -----------------------------------------------------------
Review request for kafka. Bugs: KAFKA-1907 https://issues.apache.org/jira/browse/KAFKA-1907 Repository: kafka Description ------- KAFKA-1907 Introduce a custom ZkClient for Kafka which allows timeouts on operations. Also mark certain Kafka threads as daemon to allow proper JVM shutdown Diffs ----- core/src/main/scala/kafka/network/SocketServer.scala 39b1651b680b2995cedfde95d74c086d9c6219ef core/src/main/scala/kafka/server/DelayedOperation.scala fc06b01cad3a0497800df727fa2abf60772694f2 core/src/main/scala/kafka/server/KafkaHealthcheck.scala 4acdd70fe9c1ee78d6510741006c2ece65450671 core/src/main/scala/kafka/server/KafkaServer.scala 89200da30a04943f0b9befe84ab17e62b747c8c4 core/src/main/scala/kafka/utils/KafkaZkClient.scala PRE-CREATION core/src/main/scala/kafka/utils/Utils.scala 738c1af9ef5de16fdf5130daab69757a14c48b5c core/src/main/scala/kafka/utils/ZkUtils.scala c14bd455b6642f5e6eb254670bef9f57ae41d6cb Diff: https://reviews.apache.org/r/30477/diff/ Testing ------- Thanks, Jaikiran Pai