Minor Description
This was originally raised in a kafka-users post.
There is a HashMap stored in QueryableStoreProvider#storeProviders (code link) which can be mutated by a KafkaStreams#removeStreamThread() call. This can be problematic when KafkaStreams#store is called from a separate thread.
We need to somehow make this part of code thread-safe by replacing it by ConcurrentHashMap or/and using an existing locking mechanism.
Attachments
Issue Links
- links to