search

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 #34

Open maximecaron opened 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.

robinson commented 8 years ago

Cool, from when Microsoft use the Pull Request Bot? In the near future, the bot probably fix the bug and full request for us! :+1: