java - KStream mapValues 和 transformValues 之间的区别

Question

引用他们的javadoc，KStream.transformValues需要额外的storeName参数，因此是有状态的，同时通过transformValues方法，我们可以利用ProccessorContext和标点符号。

是否存在特殊的具体情况，我应该更喜欢 transformValues 而不是 mapValues？

Answer 1

这取决于您的用例。如果您想与供应商一起实现自定义(值)变压器并更多地致力于使用 PAPI也许你应该选择转换或转换值。如果您需要例如的上下文访问包含 header 、分区/偏移量信息的完整记录，您可能需要使用 PAPI。如果您希望更好地控制流拓扑和底层细节，这种情况很常见。对于“简单”转换，map/mapValues 可能就足够了。