confluentinc/ksql

KsqlTesterTest coverage for partition/offset

Open

#8,194 opened on 2021年9月29日

GitHub で見る
 (0 comments) (0 reactions) (0 assignees)Java (5,739 stars) (1,048 forks)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
Issue 種別
feature
難度新しい貢献者にとっての実装難度です。1 は非常に小さな変更、5 は専門的な作業です。
3
推定時間経験ある貢献者が調査、実装、テスト、pull request 準備にかけるおおよその時間範囲です。
1-2 days
活動状況Issue が今どれだけ取り組みやすいかを示します。新しい、活発、古い、ブロック中、またはメンテナー入力待ちなどです。
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.
KsqlTesterTest coverage for partition/offset · confluentinc/ksql#8194 | Good First Issue