我已经有点挣扎了。我将来自 Kafka 的消息存储到 TimestampedKeyValueStore 中，但我的消息有一个标头（不仅仅是类型 id），在存储并发送出去后，标头会丢失。我引入了一个新类 ValueAndTimestampWithHeaders ，它基本上是一个 ValueAndTimestamp 但也有一个标头，但现在这引起了很多麻烦。所以，我的问题是，是否可以存储自定义类，如果可以，它需要什么？如果没有，是否可以创建自定义商店？如果是的话需要什么？
是 - 自定义类由 Serde 存储。
是的 - Store 接口可以替换为您自己的实现。