是否可以用spring cloud stream API聚合字符串的对象instad？

Question

我想使用spring cloud stream api聚合来自主题的事件。因此，我使用kstream作为输入。

KStream<Object, LoggerCreatedMessage>

现在我想使用聚合器将我的新对象存储在KeyValue存储区中，所以我使用以下代码：

input
  .map((key, value) -> {
    return new KeyValue<>(value.logger_id,value);
  })
  /*.groupBy(
    (s, loggerEvent) -> loggerEvent.logger_id,
    Serialized.with(null, loggerEventSerde))*/
  .groupByKey()
  .aggregate(
    String::new,
    (s, loggerEvent, vr) -> {
      return vr;
    },
    Materialized.<String, String, KeyValueStore<Bytes, byte[]>>as(STORE_NAME).withKeySerde(Serdes.String()).
      withValueSerde(Serdes.String())
  );

为什么我只能使用字符串作为初始值设定项，不可能使用任何对象？

我错过什么了吗？

Answer 1

通过物化将 定义为 。 > --如果您的值类型应该是LoggerDomain，那么它应该是物化。 >() 。

注意，您需要为loggerdomain提供自定义的serde，对于这种情况，还需要为物化提供自定义的loggerdomain。