Kotka Streams
23.03.13
jvm
kotka-streams-extensions
dev.
adamko.
kotka.
extensions
branched
As()
component1()
component2()
component3()
consumed
As()
grouped
As()
joined
As()
materialized
As()
materialized
With()
named
As()
printed()
Printed
Output
Stream
File
Sys
Out
produced
As()
repartitioned
As()
stream()
table
Joined()
timestamp
to
Key
Value()
to
Key
Value
Timestamp()
with
Config()
dev.
adamko.
kotka.
extensions.
processor
component1()
component2()
component3()
dev.
adamko.
kotka.
extensions.
state
all
As
Sequence()
prefix
Scan
As
Sequence()
range
As
Sequence()
reverse
All
As
Sequence()
reverse
Range
As
Sequence()
use
All()
use
Prefix
Scan()
use
Range()
use
Reverse
All()
use
Reverse
Range()
dev.
adamko.
kotka.
extensions.
streams
aggregate()
branch()
count()
filter()
filter
Not()
flat
Map()
flat
Map
Values()
for
Each()
group
By()
join()
left
Join()
map()
map
Values()
merge()
peek()
reduce()
split()
to()
Topic
Name
Extractor
Kt
Context
to
Table()
dev.
adamko.
kotka.
extensions.
tables
filter()
filter
Not()
Foreign
Key
Extractor
group
By()
join()
left
Join()
map
Values()
outer
Join()
to
Stream()
kotka-streams-framework
dev.
adamko.
kotka.
topicdata
consume
As
KStream()
consume
As
KTable()
flat
Map
Topic
Records()
Global
KTable
Definition
Instance
Key
Value
Serdes
Companion
map
Topic
Records()
Topic
Definition
Topic
Record
Companion
kotka-streams-kotlinx-serialization
dev.
adamko.
kotka.
kxs
kafka
Deserializer()
kafka
Serializer()
key
Value
Serdes()
Kotka
Serde
Module
serde()
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
>