microsoft / CSharpClient-for-Kafka

.Net implementation of the Apache Kafka Protocol that provides basic functionality through Producer/Consumer classes. The project also offers balanced consumer implementation.
Other
463 stars 95 forks source link

Fix for RecreateSyncProducerPoolForMetadata() #33

Closed maximecaron closed 8 years ago

maximecaron commented 8 years ago

RecreateSyncProducerPoolForMetadata was never called in RefreshMetadata() if RefreshMetadataInternal throw exceptions. Thus the consumer get stuck with an invalid list of broker unless KafkaSimpleManager is recreated completely.

msftclas commented 8 years ago

Hi @maximecaron, I'm your friendly neighborhood Microsoft Pull Request Bot (You can call me MSBOT). Thanks for your contribution! This seems like a small (but important) contribution, so no Contribution License Agreement is required at this point. Real humans will now evaluate your PR.

TTYL, MSBOT;