New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
feat: channels use consumergroups #3816
base: main
Are you sure you want to change the base?
Conversation
Signed-off-by: Calum Murray <cmurray@redhat.com>
[APPROVALNOTIFIER] This PR is APPROVED This pull-request has been approved by: Cali0707 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:
Approvers can indicate their approval by writing |
Signed-off-by: Calum Murray <cmurray@redhat.com>
@pierDipi I'm planning on removing the channel v1 implementation in a follow up PR, so that it's easier to see any changes I make in this PR (rather than having a complicated diff) |
Codecov ReportAttention: Patch coverage is
Additional details and impacted files@@ Coverage Diff @@
## main #3816 +/- ##
=============================================
- Coverage 73.70% 48.45% -25.25%
=============================================
Files 100 246 +146
Lines 3419 14474 +11055
Branches 292 0 -292
=============================================
+ Hits 2520 7014 +4494
- Misses 723 6755 +6032
- Partials 176 705 +529
Flags with carried forward coverage won't be shown. Click here to find out more. ☔ View full report in Codecov by Sentry. |
Looks like everything is broken 😅 |
Signed-off-by: Calum Murray <cmurray@redhat.com>
Signed-off-by: Calum Murray <cmurray@redhat.com>
Signed-off-by: Calum Murray <cmurray@redhat.com>
Signed-off-by: Calum Murray <cmurray@redhat.com>
Signed-off-by: Calum Murray <cmurray@redhat.com>
Signed-off-by: Calum Murray <cmurray@redhat.com>
Signed-off-by: Calum Murray <cmurray@redhat.com>
Signed-off-by: Calum Murray <cmurray@redhat.com>
Signed-off-by: Calum Murray <cmurray@redhat.com>
Signed-off-by: Calum Murray <cmurray@redhat.com>
Signed-off-by: Calum Murray <cmurray@redhat.com>
/unhold I think things should work now (the failing tests passed when I ran them locally, I think they are flaky in CI) |
Signed-off-by: Calum Murray <cmurray@redhat.com>
/retest-required |
Signed-off-by: Calum Murray <cmurray@redhat.com>
/cc @creydr Would you mind taking another look now that the merge conflicts are fixed? |
Signed-off-by: Calum Murray <cmurray@redhat.com>
@Cali0707 thanks for updating. Can you check on @pierDipi comments? (e.g. #3816 (review)) |
Signed-off-by: Calum Murray <cmurray@redhat.com>
Signed-off-by: Calum Murray <cmurray@redhat.com>
Signed-off-by: Calum Murray <cmurray@redhat.com>
/retest-required |
1 similar comment
/retest-required |
|
||
func (k *kafkaDeploymentDeleter) DeleteChannelDeployments(ctx context.Context) error { | ||
deployments := []string{ | ||
"kafka-channel-receiver", |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
same as the other one, received should be kept to Deployment
@@ -46,4 +46,4 @@ data: | |||
renewDeadline: "10s" | |||
retryPeriod: "2s" | |||
map-lease-prefix.kafka-broker-controller.knative.dev.eventing-kafka-broker.control-plane.pkg.reconciler.source.Reconciler: kafka-controller.knative.dev.eventing-kafka.pkg.source.reconciler.source.reconciler | |||
map-lease-prefix.kafka-broker-controller.knative.dev.eventing-kafka-broker.control-plane.pkg.reconciler.channel.Reconciler: kafkachannel-controller.knative.dev.eventing-kafka.pkg.channel.consolidated.reconciler.controller.reconciler | |||
map-lease-prefix.kafka-broker-controller.knative.dev.eventing-kafka-broker.control-plane.pkg.reconciler.channel.v2.Reconciler: kafkachannel-controller.knative.dev.eventing-kafka.pkg.channel.consolidated.reconciler.controller.reconciler |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
if we move to the top-level pkg and remove the old one, I think we don't need this update
Signed-off-by: Calum Murray <cmurray@redhat.com>
Signed-off-by: Calum Murray <cmurray@redhat.com>
/cc @pierDipi Thanks for all the reviews so far! |
Looks like trust bundle issues on the container source /retest-required |
/test integration-tests |
Signed-off-by: Calum Murray <cmurray@redhat.com>
@Cali0707: The following test failed, say
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. |
Fixes #3047
As part of the KEDA Kafka component scaling, we need to move channels to use consumergroups internally. This makes that change.
Proposed Changes
Release Note
Docs