Repository navigation
kafka: add server debug switch for franz-go and enable it in CI (#6567) - #6642
ti-chi-bot wants to merge 1 commit into
Conversation
Signed-off-by: ti-chi-bot <ti-community-prow-bot@tidb.io>
|
This cherry pick PR is for a release branch and has not yet been approved by triage owners. To merge this cherry pick:
DetailsInstructions 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. |
|
[APPROVALNOTIFIER] This PR is NOT APPROVED This pull-request has been approved by: The full list of commands accepted by this bot can be found here. DetailsNeeds approval from an approver in each of these files:Approvers can indicate their approval by writing |
|
@3AceShowHand This PR has conflicts, I have hold it. |
|
@ti-chi-bot: ## If you want to know how to resolve it, please read the guide in TiDB Dev Guide. DetailsInstructions 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 ti-community-infra/tichi repository. |
|
Warning Review limit reachedYou've used all free OSS reviews for now. Wait for the free limit to reset to keep reviewing this public repository. Next included review available in 51 minutes. View limit details
Thanks for using CodeRabbit! It's free for OSS, and your support helps us grow. If you like it, consider giving us a shout-out. Comment |
Signed-off-by: ti-chi-bot <ti-community-prow-bot@tidb.io> (cherry picked from commit 54b55ba)
|
closed by #6411 |
This is an automated cherry-pick of #6567
What problem does this PR solve?
Issue Number: close #6566
What is changed and how it works?
[debug] enable-kafka-franz-goserver option, disabled by default. Explicitkafka-clientURI settings take precedence.cdc_server.tomlthat enables franz-go. The launcher uses this file by default, and an explicit--configselects the case-specific file.server.toml.Check List
Tests
make unit_test_pkg PKG='./pkg/config ./pkg/sink/kafka' P=2— 407 tests passed with race detection.make cdc— passed.bash -n tests/integration_tests/_utils/run_cdc_server tests/integration_tests/cli_with_auth/run.sh tests/integration_tests/cli_tls_with_auth/run.sh— passed.tools/bin/shfmt -d tests/integration_tests/_utils/run_cdc_server tests/integration_tests/cli_with_auth/run.sh tests/integration_tests/cli_tls_with_auth/run.sh— passed.git diff --check— passed.Kafka integration tests were not run locally because required cluster binaries were unavailable.
Questions
Will it cause performance regression or break compatibility?
Client selection happens when sink options are constructed. The server default remains Sarama, and explicit URI selections retain their behavior. Kafka integration tests opt in to franz-go through their server configuration.
Do you need to update user documentation, design documentation or monitoring documentation?
No. This is a temporary debug option for the franz-go migration.
Release note
Summary by CodeRabbit