----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/34524/#review86304 -----------------------------------------------------------
Ship it! I brought up a local vagrant cluster of 2 brokers, 1 zk node, and one worker node. The worker node had a producer and consumer. Both brokers were in the broker-list / bootstrap.servers lists for the producer / consumer, respectively. I kill -9'd the broker doing the coordination for the consumer. The consumer was able to switch over its coordination to the other broker. - Onur Karaman On June 2, 2015, 9:07 p.m., Guozhang Wang wrote: > > ----------------------------------------------------------- > This is an automatically generated e-mail. To reply, visit: > https://reviews.apache.org/r/34524/ > ----------------------------------------------------------- > > (Updated June 2, 2015, 9:07 p.m.) > > > Review request for kafka. > > > Bugs: KAFKA-2208 > https://issues.apache.org/jira/browse/KAFKA-2208 > > > Repository: kafka > > > Description > ------- > > Incorporate Onur's comments > > > Diffs > ----- > > > clients/src/main/java/org/apache/kafka/clients/consumer/internals/Coordinator.java > b2764df11afa7a99fce46d1ff48960d889032d14 > > clients/src/main/java/org/apache/kafka/clients/consumer/internals/Fetcher.java > ef9dd5238fbc771496029866ece1d85db6d7b7a5 > > clients/src/main/java/org/apache/kafka/common/requests/HeartbeatResponse.java > f548cd0ef70929b35ac887f8fccb7b24c3e2c11a > > clients/src/main/java/org/apache/kafka/common/requests/JoinGroupResponse.java > fd9c545c99058ad3fbe3b2c55ea8b6ea002f5a51 > core/src/main/scala/kafka/coordinator/ConsumerCoordinator.scala > af06ad45cdc46ac3bc27898ebc1a5bd5b1c7b19e > core/src/main/scala/kafka/coordinator/ConsumerGroupMetadata.scala > 47bdfa7cc86fd4e841e2b1d6bfd40f1508e643bd > core/src/main/scala/kafka/network/RequestChannel.scala > 1d0024c8f0c2ab0efa6d8cfca6455877a6ed8026 > core/src/main/scala/kafka/server/KafkaConfig.scala > 9efa15ca5567b295ab412ee9eea7c03eb4cdc18b > core/src/test/scala/integration/kafka/api/ConsumerBounceTest.scala > 5c4cca653b3801df3494003cc40a56ae60a789a6 > core/src/test/scala/integration/kafka/api/ConsumerTest.scala > a1eed965a148eb19d9a6cefbfce131f58aaffc24 > core/src/test/scala/unit/kafka/server/KafkaConfigConfigDefTest.scala > 8014a5a6c362785539f24eb03d77278434614fe6 > > Diff: https://reviews.apache.org/r/34524/diff/ > > > Testing > ------- > > > Thanks, > > Guozhang Wang > >
