Kafka DSL Kstream->Ktable Join - Joined Serialization compile Error答案

【问题标题】：Kafka DSL Kstream->Ktable Join - Joined Serialization compile ErrorKafka DSL Kstream->Ktable Join - Joined Serialization compile Error
【发布时间】：2021-01-07 19:44:17
【问题描述】：

我正在尝试根据kafka documentation 实现此连接。

我不知道为什么这个连接不起作用...

首先我传递了所有值。

这里它试图强制泛型为 Object 类型，这是非常错误的。

如果没有加入序列化选项，我会收到此运行时异常：

线程“StreamAPP-stream-event-b3dc5fff-abee-4fa0-92f9-e1690f8fd152-StreamThread-1”中的异常 org.apache.kafka.streams.errors.StreamsException：ClassCastException 生成数据到主题 StreamAPP-stream-event -KSTREAM-KEY-SELECT-0000000025-重新分区。序列化程序（键：org.apache.kafka.common.serialization.ByteArraySerializer / 值：org.apache.kafka.common.serialization.ByteArraySerializer）与实际的键或值类型（键类型：br.com.calebebrim .kafka.entities.stream.sharing.registry.StreamRegistryKey / 值类型：br.com.calebebrim.kafka.entities.stream.sharing.stream.Event）。更改 StreamConfig 中的默认 Serdes 或通过方法参数提供正确的 Serdes（例如，如果使用 DSL，#to(String topic, Produced<K, V> produced) 和 Produced.keySerde(WindowedSerdes.timeWindowedSerdeFrom(String.class))）

谁能帮帮我？

谢谢！

【问题讨论】：

标签： java compiler-errors apache-kafka-streams dsl

【解决方案1】：

解决了，

我发现join操作不能转换数据。

所以，我之前只是应用了 mapValues：

【讨论】：