我试图实现这个连接根据Kafka文件。
我不知道为什么这不起作用。。。

首先我传递了所有的值。

这里它试图强制泛型为object类型，这是非常错误的。
如果不使用序列化选项连接，我将收到以下运行时异常：
线程“streamapp-stream-event-b3dc5fff-abee-4fa0-92f9-e1690f8fd152-streamthread-1”org.apache.kafka.streams.errors.streamsexception:向主题streamapp-stream-event-kstream-key-select-00000000 25重新分区生成数据时出现异常。序列化程序（键：org.apache.kafka.common.serialization.bytearrayserializer/value:org.apache.kafka.common.serialization.bytearrayserializer）与实际的键或值类型（键类型：br.com.calebebrim.kafka.entities.stream.sharing.registry.streamregistrykey/value类型：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)) )
有人能帮我吗？
谢谢！