org.apache.kafka.streams org.apache.kafka.streams.errors org.apache.kafka.streams.kstream org.apache.kafka.streams.processor org.apache.kafka.streams.processor.api org.apache.kafka.streams.processor.assignment org.apache.kafka.streams.processor.assignment.assignors org.apache.kafka.streams.query org.apache.kafka.streams.state