kotka-streams-extensions

dev.adamko.kotka.extensions

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

Package-level declarations

Types

PrintedOutputStream

interface PrintedOutputStream

TimestampedQueryStoreType

typealias TimestampedQueryStoreType<K, V> = QueryableStoreType<ReadOnlyKeyValueStore<K, ValueAndTimestamp<V>>>

Functions

fun <Key, Val> branchedAs(name: String): Branched<Key, Val>

@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

@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

@JvmName(name = "keyValueTimestampGetTimestamp")

operator fun <K, V> KeyValue<K, ValueAndTimestamp<V>>.component3(): Long

Get the timestamp of a timestamped-KeyValue

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>

fun <Key, Val> groupedAs(name: String? = null, keySerde: Serde<Key>? = null, valueSerde: Serde<Val>? = null): Grouped<Key, Val>

fun <Key, Val, otherVal> joinedAs( name: String? = null, keySerde: Serde<Key>? = null, valueSerde: Serde<Val>? = null, otherValueSerde: Serde<otherVal>?): Joined<Key, Val, otherVal>

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>>

materializedWith

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>

fun namedAs(name: String): Named

fun <Key, Val> printed( name: String? = null, outputStream: PrintedOutputStream, label: String? = null, mapper: KeyValueMapper<Key, Val, String>? = null): Printed<Key, Val>

fun <Key, Val> producedAs( name: String? = null, keySerde: Serde<Key>? = null, valueSerde: Serde<Val>? = null, partitioner: StreamPartitioner<Key, Val>? = null): Produced<Key, Val>

repartitionedAs

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>

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>

fun <Key, otherKey> tableJoined( name: String? = null, partitioner: StreamPartitioner<Key, Void>? = null, otherPartitioner: StreamPartitioner<otherKey, Void>? = null): TableJoined<Key, otherKey>

inline fun <K, V> Pair<K, V>.toKeyValue(): KeyValue<K, V>

Convert a Pair to a KeyValue

toKeyValueTimestamp

inline fun <K, V> Triple<K, V, Long>.toKeyValueTimestamp(): KeyValue<K, ValueAndTimestamp<V>>

Convert a Triple to a KeyValue, with a timestamped value

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

val <K, V> KeyValue<K, ValueAndTimestamp<V>>.timestamp: Long

Get the timestamp of a timestamped-KeyValue