How to write KTable in a Kafka topic? Like we use "to()" in KStreams how to do that for KTable?

Question

As there is no "to()" method for KTable so do we need to always convert it to KStream before sending any message to a topic? Or how can we store a KTable in our topic?

score 5 · Answer 1 · answered Jun 02 '20 at 21:09

5

Yes, in order to materialize a KTable to a topic, you're required to convert it to a regular stream (instead of a changelog stream) via table.toStream().to("myTopic").

answered Jun 02 '20 at 21:09

ck1

5,243
1
21
25

score 1 · Answer 2 · answered Dec 16 '20 at 07:03

Note that KTable had a to method some time ago.

In general, if you check older versions of KTable, like 1.0, you'll see that the API was simplified significantly and more than a dozen methods were deprecated, many of them deleted as of today, including to():

How to write KTable in a Kafka topic? Like we use "to()" in KStreams how to do that for KTable?

2 Answers2