Kotka Streams
23.03.13
jvm
kotka-streams-framework
/
dev.adamko.kotka.topicdata
/
consumeAsKTable
consume
As
KTable
fun
<
K
,
V
>
TopicDefinition
<
K
,
V
>
.
consumeAsKTable
(
builder
:
StreamsBuilder
,
consumer
:
Consumed
<
K
,
V
>
=
serdes.consumer("${pid}.input-table")
)
:
KTable
<
K
,
V
>