Improve connection close and error handling#107

Merged

NeonDaniel merged 3 commits intodevfrom FEAT_SelectConsumerHandleExceptions

Jan 2, 2025

+24-8

Commits on Jan 2, 2025

Update SelectConsumerThread to pass exceptions to self.error_func to match BlockingConsumerThread
NeonDaniel
committed
Update BlockingConsumerThread to ensure connection is closed exactly once
NeonDaniel
committed
Ignore StreamLostErrors during consumer shutdown
NeonDaniel
committed