kotka-streams-extensions/dev.adamko.kotka.extensions.streams

Package-level declarations

Types

TopicNameExtractorKt

fun interface TopicNameExtractorKt<K, V>

Functions

fun <K, inV, outV> KGroupedStream<K, inV>.aggregate(initializer: Initializer<outV>, materialized: Materialized<K, outV, KeyValueStore<Bytes, ByteArray>>, aggregator: Aggregator<K, inV, outV>): KTable<K, outV>

fun <K, inV, outV> KGroupedStream<K, inV>.aggregate(name: String, materialized: Materialized<K, outV, KeyValueStore<Bytes, ByteArray>>, initializer: Initializer<outV>, aggregator: Aggregator<K, inV, outV>): KTable<K, outV>

fun <K, V> BranchedKStream<K, V>.branch(branched: Branched<K, V>, predicate: Predicate<K, V>): BranchedKStream<K, V>

fun <K> KGroupedStream<K, *>.count(name: String? = null, materialized: Materialized<K, Long, KeyValueStore<Bytes, ByteArray>>? = null): KTable<K, Long>

fun <K, V> KStream<K, V>.filter(name: String, predicate: (K, V) -> Boolean): KStream<K, V>

fun <K, V> KStream<K, V>.filterNot(name: String, predicate: (K, V) -> Boolean): KStream<K, V>

inline fun <inK, inV, outK, outV> KStream<inK, inV>.flatMap(name: String? = null, crossinline mapper: (key: inK, value: inV) -> Iterable<Pair<outK, outV>>): KStream<outK, outV>

inline fun <inK, inV, outV> KStream<inK, inV>.flatMapValues(name: String? = null, crossinline mapper: (key: inK, value: inV) -> Iterable<outV>): KStream<inK, outV>

fun <K, V> KStream<K, V>.forEach(name: String? = null, forEachAction: ForeachAction<K, V>)

fun <K, V, outK> KStream<K, V>.groupBy(grouped: Grouped<outK, V>, keySelector: (K, V) -> outK): KGroupedStream<outK, V>

fun <K, V, otherV, outV> KStream<K, V>.join(table: KTable<K, otherV>, joined: Joined<K, V, otherV>, valueJoiner: ValueJoinerWithKey<K, V, otherV?, outV>): KStream<K, outV>

fun <K, inV, otherK, otherV, outV> KStream<K, inV>.join(name: String, globalTable: GlobalKTable<otherK, otherV>, keySelector: KeyValueMapper<K, inV, otherK?>, valueJoiner: ValueJoinerWithKey<K, inV, otherV?, outV>): KStream<K, outV>

fun <K, inV, otherK, otherV, outV> KStream<K, inV>.leftJoin(name: String, globalTable: GlobalKTable<otherK, otherV>, keySelector: KeyValueMapper<K, inV, otherK?>, valueJoiner: ValueJoinerWithKey<K, inV, otherV?, outV>): KStream<K, outV>

inline fun <inK, inV, outK, outV> KStream<inK, inV>.map(name: String, crossinline mapper: (key: inK, value: inV) -> Pair<outK, outV>): KStream<outK, outV>

fun <K, inV, outV> KStream<K, inV>.mapValues(name: String, mapper: (key: K, value: inV) -> outV): KStream<K, outV>

fun <K, V> KStream<K, V>.merge(name: String, other: KStream<K, V>): KStream<K, V>

fun <K, V> KStream<K, V>.peek(name: String? = null, forEachAction: ForeachAction<K, V>): KStream<K, V>

fun <K, V> KGroupedStream<K, V>.reduce(materialized: Materialized<K, V, KeyValueStore<Bytes, ByteArray>>, reducer: Reducer<V>): KTable<K, V>

fun <K, V> KGroupedStream<K, V>.reduce(name: String, materialized: Materialized<K, V, KeyValueStore<Bytes, ByteArray>>, reducer: Reducer<V>): KTable<K, V>

fun <K, V> KStream<K, V>.split(name: String? = null): BranchedKStream<K, V>

fun <K, V> KStream<K, V>.to(produced: Produced<K, V>? = null, topicNameExtractor: TopicNameExtractorKt<K, V>)

fun <K, V> KStream<K, V>.toTable(name: String? = null, materialized: Materialized<K, V, KeyValueStore<Bytes, ByteArray>>? = null): KTable<K, V>