Resources can be closed twice, in different ways
Closed this issue · 1 comments
zcox commented
There are new ProducerApi and ConsumerApi constructors that return Resource[F, A], which invokes the close method. However, other common things like recordStream also close the consumer, using closeAndRecoverConcurrentModificationWithWakeup.
We need to re-assess how we close things, especially the consumer. Maybe we don't need closeAndRecoverConcurrentModificationWithWakeup now?