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

Package-level declarations

Functions

Link copied to clipboard
fun <Key, Val> branchedAs(name: String): Branched<Key, Val>
Link copied to clipboard
@JvmName(name = "keyValueGetKey")
operator fun <K, V> KeyValue<K, V>.component1(): K

Get the key of a KeyValue

@JvmName(name = "keyValueTimestampGetKey")
operator fun <K, V> KeyValue<K, ValueAndTimestamp<V>>.component1(): K

Get the key of a timestamped-KeyValue

@JvmName(name = "valueTimestampGetValue")
operator fun <V> ValueAndTimestamp<V>.component1(): V

Get the value of a ValueAndTimestamp

Link copied to clipboard
@JvmName(name = "keyValueGetValue")
operator fun <K, V> KeyValue<K, V>.component2(): V

Get the value of a KeyValue

@JvmName(name = "keyValueTimestampGetValue")
operator fun <K, V> KeyValue<K, ValueAndTimestamp<V>>.component2(): V

Get the value of a timestamped-KeyValue

@JvmName(name = "valueTimestampGetTimestamp")
operator fun <V> ValueAndTimestamp<V>.component2(): Long

Get the timestamp of a ValueAndTimestamp

Link copied to clipboard
@JvmName(name = "keyValueTimestampGetTimestamp")
operator fun <K, V> KeyValue<K, ValueAndTimestamp<V>>.component3(): Long

Get the timestamp of a timestamped-KeyValue

Link copied to clipboard
fun <Key, Val> consumedAs(name: String? = null, keySerde: Serde<Key>? = null, valueSerde: Serde<Val>? = null, resetPolicy: Topology.AutoOffsetReset? = null, timestampExtractor: TimestampExtractor? = null): Consumed<Key, Val>
Link copied to clipboard
fun <Key, Val> groupedAs(name: String? = null, keySerde: Serde<Key>? = null, valueSerde: Serde<Val>? = null): Grouped<Key, Val>
Link copied to clipboard
fun <Key, Val, otherVal> joinedAs(name: String? = null, keySerde: Serde<Key>? = null, valueSerde: Serde<Val>? = null, otherValueSerde: Serde<otherVal>?): Joined<Key, Val, otherVal>
Link copied to clipboard
fun <Key, Val, Store : StateStore> materializedAs(storeName: String, keySerde: Serde<Key>? = null, valueSerde: Serde<Val>? = null, loggingConfig: Map<String, String>? = null, cachingEnabled: Boolean = true, retention: Duration? = null): Materialized<Key, Val, Store>
fun <Key, Val> materializedAs(storeSupplier: KeyValueBytesStoreSupplier, keySerde: Serde<Key>? = null, valueSerde: Serde<Val>? = null, loggingConfig: Map<String, String>? = null, cachingEnabled: Boolean = true, retention: Duration? = null): Materialized<Key, Val, KeyValueStore<Bytes, ByteArray>>
fun <Key, Val> materializedAs(storeSupplier: SessionBytesStoreSupplier, keySerde: Serde<Key>? = null, valueSerde: Serde<Val>? = null, loggingConfig: Map<String, String>? = null, cachingEnabled: Boolean = true, retention: Duration? = null): Materialized<Key, Val, SessionStore<Bytes, ByteArray>>
fun <Key, Val> materializedAs(storeSupplier: WindowBytesStoreSupplier, keySerde: Serde<Key>? = null, valueSerde: Serde<Val>? = null, loggingConfig: Map<String, String>? = null, cachingEnabled: Boolean = true, retention: Duration? = null): Materialized<Key, Val, WindowStore<Bytes, ByteArray>>
Link copied to clipboard
fun <Key, Val, Store : StateStore> materializedWith(keySerde: Serde<Key>? = null, valueSerde: Serde<Val>? = null, loggingConfig: Map<String, String>? = null, cachingEnabled: Boolean = true, retention: Duration? = null): Materialized<Key, Val, Store>
Link copied to clipboard
fun namedAs(name: String): Named
Link copied to clipboard
fun <Key, Val> printed(name: String? = null, outputStream: PrintedOutputStream, label: String? = null, mapper: KeyValueMapper<Key, Val, String>? = null): Printed<Key, Val>
Link copied to clipboard
fun <Key, Val> producedAs(name: String? = null, keySerde: Serde<Key>? = null, valueSerde: Serde<Val>? = null, partitioner: StreamPartitioner<Key, Val>? = null): Produced<Key, Val>
Link copied to clipboard
fun <Key, Val> repartitionedAs(name: String? = null, keySerde: Serde<Key>? = null, valueSerde: Serde<Val>? = null, numberOfPartitions: Int? = null, partitioner: StreamPartitioner<Key, Val>? = null): Repartitioned<Key, Val>
Link copied to clipboard
fun <K, V> StreamsBuilder.stream(vararg topics: String): KStream<K, V>
fun <K, V> StreamsBuilder.stream(consumed: Consumed<K, V>? = null, vararg topics: String): KStream<K, V>
Link copied to clipboard
fun <Key, otherKey> tableJoined(name: String? = null, partitioner: StreamPartitioner<Key, Void>? = null, otherPartitioner: StreamPartitioner<otherKey, Void>? = null): TableJoined<Key, otherKey>
Link copied to clipboard
inline fun <K, V> Pair<K, V>.toKeyValue(): KeyValue<K, V>

Convert a Pair to a KeyValue

Link copied to clipboard
Link copied to clipboard
fun <Key, Val, Store : StateStore> Materialized<Key, Val, Store>.withConfig(keySerde: Serde<Key>? = null, valueSerde: Serde<Val>? = null, loggingConfig: Map<String, String>? = null, cachingEnabled: Boolean = true, retention: Duration? = null): Materialized<Key, Val, Store>

Properties

Link copied to clipboard
val <K, V> KeyValue<K, ValueAndTimestamp<V>>.timestamp: Long

Get the timestamp of a timestamped-KeyValue