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

KeyValueSerdes

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

A pair of Serdes - one for the Key, another for the Value.

TopicDefinition

interface TopicDefinition<K, V>

A definition for any Kafka topic.

TopicRecord

interface TopicRecord<K>

Functions

consumeAsKStream

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

consumeAsKTable

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

flatMapTopicRecords

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

mapTopicRecords

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