[WIP] Wait for offsets initialization in the control plane

[pierDipi]

Fixes #

Proposed Changes

Release Note

Docs

[knative-prow]

Skipping CI for Draft Pull Request.
If you want CI signal for your change, please convert it to an actual PR.
You can still manually trigger a test run with /test all

[pierDipi]

/test ?

[knative-prow]

[APPROVALNOTIFIER] This PR is APPROVED

This pull-request has been approved by: pierDipi

The full list of commands accepted by this bot can be found here.

The pull request process is described here

Needs approval from an approver in each of these files:

• OWNERS [pierDipi]

Approvers can indicate their approval by writing /approve in a comment
Approvers can cancel approval by writing /approve cancel in a comment

[knative-prow]

@pierDipi: The following commands are available to trigger required jobs:

/test build-tests

/test channel-integration-tests-sasl-plain

/test channel-integration-tests-sasl-ssl

/test channel-integration-tests-ssl

/test channel-reconciler-tests-sasl-plain

/test channel-reconciler-tests-sasl-ssl

/test channel-reconciler-tests-ssl

/test integration-tests

/test reconciler-tests

/test reconciler-tests-keda

/test reconciler-tests-namespaced-broker

/test unit-tests

/test upgrade-tests

Use /test all to run all jobs.

In response to this:

/test ?

Instructions for interacting with me using PR comments are available here. If you have questions or suggestions related to my behavior, please file an issue against the kubernetes-sigs/prow repository.

[pierDipi]

/test reconciler-tests

[pierDipi]

/test unit-tests

[codecov]

Codecov Report

Attention: Patch coverage is 1.47059% with 67 lines in your changes missing coverage. Please review.

Project coverage is 45.47%. Comparing base (2cde7b9) to head (3c65f70).
Report is 2 commits behind head on main.

Files with missing lines	Patch %	Lines
control-plane/pkg/kafka/offset/offsets.go	0.00%	61 Missing ⚠️
...lane/pkg/reconciler/consumergroup/consumergroup.go	14.28%	4 Missing and 2 partials ⚠️

Additional details and impacted files

@@            Coverage Diff             @@
##             main    #4206      +/-   ##
==========================================
- Coverage   45.49%   45.47%   -0.02%     
==========================================
  Files         270      269       -1     
  Lines       19873    19882       +9     
==========================================
+ Hits         9041     9042       +1     
- Misses      10113    10119       +6     
- Partials      719      721       +2     

☔ View full report in Codecov by Sentry.
📢 Have feedback on the report? Share it here.

[knative-prow]

@pierDipi: The following test failed, say /retest to rerun all failed tests or /retest-required to rerun all mandatory failed tests:

Test name	Commit	Details	Required	Rerun command
reconciler-tests_eventing-kafka-broker_main	3c65f70	link	true	/test reconciler-tests

Your PR dashboard.

Instructions for interacting with me using PR comments are available here. If you have questions or suggestions related to my behavior, please file an issue against the kubernetes-sigs/prow repository. I understand the commands that are listed here.

[Cali0707]

@pierDipi what's the purpose behind waiting for offsets in the control plane? is it to ensure that the consumergroup rebalance has finished before we say that the trigger is ready?