confluentinc/ksql

KsqlTesterTest coverage for partition/offset

Open

#8,194 建立於 2021年9月29日

在 GitHub 查看
 (0 留言) (0 反應) (0 負責人)Java (5,739 star) (1,048 fork)batch import
enhancementgood first issuestreaming-enginetest-coverage

描述

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.

貢獻者指南

技術棧
java
領域
testingbackend
議題類型
feature
難度面向新貢獻者的預計實作難度，1 表示很小改動，5 表示專家級工作。
3
預計時間有經驗貢獻者完成調查、實作、測試並準備 pull request 的粗略時間範圍。
1-2 days
活動狀態議題目前的可參與程度：新鮮、活躍、陳舊、阻塞或等待維護者輸入。
stale
清晰度議題是否清楚說明預期改動、驗收標準和下一步。
mostly clear
前置要求
Basic understanding of KafkaJava programmingFamiliarity with JUnit
新手友善度1-100 的估計分數，表示該議題對首次貢獻者的友善程度。
50
研究方向
Examine the existing KsqlTesterTest infrastructure and refer to issue #7982 for context on how partition and offset are handled in Kafka test tools. The goal is to extend the spoofed Kafka topic to support non zero partition/offset values. Look at the linked PR in #7982 and the test classes to identify where changes can be made.