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