Skip to content

Navigation Menu

Explore
By company size
By use case
By industry
View all solutions
Topics
- AI
- DevOps
- Security
- Software Development
- View all
Explore
- GitHub Sponsors
  Fund open source developers
- The ReadME Project
  GitHub community articles
Repositories
- Enterprise platform
  AI-powered developer platform
Available add-ons
Pricing

Search code, repositories, users, issues, pull requests...

Search

Clear

Search syntax tips

Provide feedback

We read every piece of feedback, and take your input very seriously.

Include my email address so I can be contacted

Saved searches

Use saved searches to filter your results more quickly

Name

Query

To see all available qualifiers, see our documentation.

You signed in with another tab or window. Reload to refresh your session. You signed out in another tab or window. Reload to refresh your session. You switched accounts on another tab or window. Reload to refresh your session.

Dismiss alert

pingcap / tiflow Public

Notifications You must be signed in to change notification settings
Fork 289
Star 431

Code
Issues 625
Pull requests 165
Actions
Projects 1
Security
Insights

Additional navigation options

Code
Issues
Pull requests
Actions
Projects
Security
Insights

cdc/sink: adjust kafka initialization logic#3192

Merged

ti-chi-bot merged 80 commits intopingcap:masterpingcap/tiflow:masterfrom 3AceShowHand:extract-kafka-admin3AceShowHand/tiflow:extract-kafka-adminCopy head branch name to clipboard

Nov 12, 2021

+254-106

Conversation Commits80 (80)Checks Files changed

Commits

Commits on Nov 12, 2021

add admin file
3AceShowHand
committed
rebase master.
3AceShowHand
committed
fix create topic.
3AceShowHand
committed
use config.partitionNum directly.
3AceShowHand
committed
close admin.
3AceShowHand
committed
fix testcase.
3AceShowHand
committed
tiny fix.
3AceShowHand
committed
fix some typo.
3AceShowHand
committed
refactor parameter check in topicPreProcess.
3AceShowHand
committed
fix kafka test.
3AceShowHand
committed
add a test for config initialization.
3AceShowHand
committed
remove unnecessary code in kafka test.
3AceShowHand
committed
add ut for initialization.
3AceShowHand
committed
use PartitionNum.
3AceShowHand
committed
remove unnecessary kafka package at the moment.
3AceShowHand
committed
add a log.
3AceShowHand
committed
tiny fix.
3AceShowHand
committed
tiny fix.
3AceShowHand
committed
use failpoint to workaround for NewClusterAdmin in test.
3AceShowHand
committed
simple typo fix.
3AceShowHand
committed
add more test for preprocess.
3AceShowHand
committed
disable the checkpoint.
3AceShowHand
committed
fix enable failpoint syntax.
3AceShowHand
committed
fix parameters.
3AceShowHand
committed
Adjust the layout of comment for create sarama config.
3AceShowHand
committed
adjust layout for sarama config producer.
3AceShowHand
committed
fix test.
3AceShowHand
committed
fix kafka version in mq_test.
3AceShowHand
committed
remove failpoint.
3AceShowHand
committed
remove control by variable.
3AceShowHand
committed
add failpoint.
3AceShowHand
committed
add failpoint.
3AceShowHand
committed
fix failpoint interm.
3AceShowHand
committed
revert version.
3AceShowHand
committed
try to fix max-message-size larger than topic.
3AceShowHand
committed
add a debug log.
3AceShowHand
committed
remove the log.
3AceShowHand
committed
create topic with max-message-size.
3AceShowHand
committed
fix comment.
3AceShowHand
committed
Update cdc/sink/producer/kafka/kafka.go

3AceShowHand
and
overvenus
committed
fix by code review suggestion.
3AceShowHand
committed
Update cdc/sink/producer/kafka/kafka.go

3AceShowHand
and
liuzix
committed
Update cdc/sink/producer/kafka/kafka.go

3AceShowHand
and
liuzix
committed
Update cdc/sink/producer/kafka/kafka.go

3AceShowHand
and
liuzix
committed
fix by code review suggestion.
3AceShowHand
committed
fix log layout.
3AceShowHand
committed
make topic out of the Config.
3AceShowHand
committed
fix test.
3AceShowHand
committed
fix test.
3AceShowHand
committed
fix by code review suggestion.
3AceShowHand
committed
Rewrite the logic in topicPreProcess.
3AceShowHand
committed
Adjust the layout of comment for create sarama config.
3AceShowHand
committed
fix logic if topic already exist.
3AceShowHand
committed
Adjust the layout of comment for create sarama config.
3AceShowHand
committed
tiny fix.
3AceShowHand
committed
remove useless test.
3AceShowHand
committed
try to get broker configuration.
3AceShowHand
committed
add print config entries.
3AceShowHand
committed
fix convert to string.
3AceShowHand
committed
tiny fix.
3AceShowHand
committed
move get broker config up.
3AceShowHand
committed
refine the logic when create the topic.
3AceShowHand
committed
remove initialize topic with max-message-bytes.
3AceShowHand
committed
adjust comment.
3AceShowHand
committed
fix the comment.
3AceShowHand
committed
fix the comment.
3AceShowHand
committed
only fetch message.max.bytes.
3AceShowHand
committed
refine the comment.
3AceShowHand
committed
if topic cannot find the max.message.bytes, find message.max.bytes from brokers.
3AceShowHand
committed
extract adjustPartitionNum.
3AceShowHand
committed
remove TopicPreProcessCreate test.
3AceShowHand
committed
revert comment out test.
3AceShowHand
committed
check max-message-bytes only for default and craft protocol.
3AceShowHand
committed
fix make check.
3AceShowHand
committed
fix error handling.
3AceShowHand
committed
Update cdc/sink/mq.go

3AceShowHand
and
liuzix
authored
Merge branch 'master' into extract-kafka-admin
ti-chi-bot
authored
Merge branch 'master' into extract-kafka-admin
ti-chi-bot
authored
Merge branch 'master' into extract-kafka-admin
ti-chi-bot
authored
Merge branch 'master' into extract-kafka-admin
ti-chi-bot
authored

Footer

© 2025 GitHub, Inc.

Footer navigation

Terms
Privacy
Security
Status
Docs
Contact

You can’t perform that action at this time.