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

[INT-431] Enable randomized producer id #92

Merged
merged 2 commits into from
Jan 10, 2023

Conversation

cnkarz
Copy link
Contributor

@cnkarz cnkarz commented Jan 9, 2023

Randomize Kafka producer ID for backfill jobs. This way we will be able to run multiple jobs at once and they will be able to push to same topic without being fenced.

@hughiednguyen
Copy link
Contributor

Do we have to worry about the possibility of it generating a duplicate number ?

@cnkarz
Copy link
Contributor Author

cnkarz commented Jan 9, 2023

It could generate duplicate number but probability is low. We will only run at most a few tens of jobs. And if the numbers are the same, one job will crash and restart and probably have a different number.

connector.go Outdated Show resolved Hide resolved
@cnkarz cnkarz merged commit ced6378 into main Jan 10, 2023
@cnkarz cnkarz deleted the feature/kafka-producer-id-for-backfill branch January 10, 2023 05:51
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.

None yet

4 participants