Yes, this is just the POC. I'd like to have the stores registered by name and partition in the KafkaStreams object so we don't have to do these loops. This is a big source of inefficiency in IQ today.