TopicDefinition

A definition for any Kafka topic.

These can be used to create KTopics, KTabless, or GlobalKTabless.

Functions

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>

open val pid: String

unique Kafka processor ID - to help ensure topology names are unique