kotka-streams-framework/dev.adamko.kotka.topicdata/flatMapTopicRecords

flatMapTopicRecords

fun <inK, outK, inV, outV : TopicRecord<outK>> KStream<inK, inV>.flatMapTopicRecords(name: String, mapper: (key: inK, value: inV) -> Iterable<outV>): KStream<outK, outV>

See also