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

Package-level declarations

Types

abstract class GlobalKTableDefinition<K, V>(val tableName: String, val storeName: String = "-store", val topicName: String = "-topic", val serdes: KeyValueSerdes<K, V>, val storeType: <Error class: unknown class><K, V> = timestampedKeyValueStore()) : TopicDefinition<K, V>

equals a GlobalTableDefinition

open class KeyValueSerdes<K, V>(val keySerde: Serde<K>, val valueSerde: Serde<V>)

A definition for any Kafka topic.

fun <K, V> TopicDefinition<K, V>.consumeAsKStream(builder: StreamsBuilder, consumer: Consumed<K, V> = serdes.consumer("${pid}.input-stream")): KStream<K, V>

fun <K, V> TopicDefinition<K, V>.consumeAsKTable(builder: StreamsBuilder, consumer: Consumed<K, V> = serdes.consumer("${pid}.input-table")): KTable<K, V>