Yura Nosenko created KAFKA-12695:
------------------------------------
Summary: KStream.toTable must be extended to allow for a specific
Serde
Key: KAFKA-12695
URL: https://issues.apache.org/jira/browse/KAFKA-12695
Project: Kafka
Issue Type: Bug
Components: streams
Affects Versions: 2.7.0
Reporter: Yura Nosenko
`KStream.toTable` seems to not be as useful as it can.`KStream.toTable` seems
to not be as useful as it can.I have a simple piece of code:
{{ builder.stream[String, String](post)}}{{.map(postExtractor)}}{{.toTable }}
{{That fails with:}}
{{ Caused by: java.lang.ClassCastException: class java.lang.Long cannot be
cast to class [B (java.lang.Long and [B are in module java.base of loader
'bootstrap')}}
But if I tweak it to:
builder.stream[String, String](post).map(postExtractor).to("output-topic")
It seems that toTable can only work with the default Serde configs. But if it's
the case it's of a limited use.
Especially in Scala code where all Produced/Consumed can be inferred as
implicit otherwise.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
