I'm trying to debug a problem in our production Kafka Streams app. The (simplified) topology looks