Skip to content
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

#4984 update position by heartBeat #4986

Open
wants to merge 1 commit into
base: master
Choose a base branch
from

Conversation

yanghuaiGit
Copy link

支持通过心跳更新位点

@yanghuaiGit
Copy link
Author

有大佬能看下这个pr吗
数据驱动 或者 heartbeat 心跳 来更新位点信息,而不仅仅是数据驱动,因为监听的表数据可能没改动

@agapple
Copy link
Member

agapple commented Dec 19, 2023

heartbeat的位点,不具备唯一性

@yanghuaiGit
Copy link
Author

heartbeat的位点,不具备唯一性

能详细说下吗,目前我这边本地测试,heartbeat返回的就是当前slave的最新position

@yanghuaiGit
Copy link
Author

heartbeat的位点,不具备唯一性

能详细说下吗,目前我这边本地测试,heartbeat返回的就是当前slave的最新position

因为我看flinkcdc基于debezium,也有根据heartbeat的信息更新position的

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

2 participants