confluentinc/ksql

KsqlTesterTest coverage for partition/offset

开放

#8,194 创建于 2021年9月29日

 (0 条评论) (0 个反应) (0 位负责人)Java (1,048 个派生)batch import
enhancementgood first issuestreaming-enginetest-coverage

仓库指标

星标
 (5,739 个星标)
PR 合并指标
 (平均合并 4天 20小时) (30 天内合并 6 个 PR)

描述

Is your feature request related to a problem? Please describe. When trying to develop tests for the new pseudocolumns ROWPARTITION and ROWOFFSET, which represent the partition and offset of the record, respectively, I found that the returned partition and offset were always equal to 0.

Describe the solution you'd like The spoofed kafka topic to include support for partition and offset- QTTs don't do this perfectly (see https://github.com/confluentinc/ksql/issues/7982) , but they provide enough support for most use cases.

Describe alternatives you've considered Adding testing without coverage for partition/offset values. This is probably fine for now but can be improved upon.

贡献者指南