已关闭。此问题需要details or clarity。目前不接受回答。
**要改进此问题吗？**通过editing this post添加详细信息并阐明问题。
10小时前关闭。
Improve this question的
我一直在努力，我将来自Kafka的消息存储到TimestampedKeyValueStore中，但我的消息有一个标题（不仅类型id），并且在它们被存储并发送到该行之后，头丢失了。我引入了一个新的类ValueAndTimestampWithHeaders，它基本上是一个ValueAndTimestamp，但也有一个头，但现在这引起了大量的麻烦。所以，我的问题是，是否可以存储自定义类，如果可以，它需要什么？如果不可以，是否可以创建自定义存储？如果可以，它需要什么？
1条答案
按热度按时间3zwjbxry1#
是-自定义类由Serde存储。
是的-Store接口可以替换为您自己的实现。
https://kafka.apache.org/36/documentation/streams/developer-guide/processor-api.html#implementing-custom-state-stores