io.simplesource.kafka.internal.streams
