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

fix(mce-consumer): add METADATA_CHANGE_LOG_KAFKA_CONSUMER_GROUP_ID environment variable to MCE consumer. #519

Merged

Conversation

Masterchen09
Copy link
Contributor

Although the MCE consumer is not consuming any topic using the consumer group ID of the MAE consumer (which would make no sense), it seems the MCE consumer needs the consumer group ID used by the MAE consumer for the KafkaThrottleFactory - I think this is something new and wasn't there half a year ago.

FYI @RyanHolstien: I am tagging you here because you merged my original PR #436 - I hope we can have this fix merged a bit sooner and don't have to wait almost half a year (or more than half a year?)...😅

Checklist

  • The PR conforms to DataHub's Contributing Guideline (particularly Commit Message Format)
  • Links to related issues (if applicable)
  • Tests for the changes have been added/updated (if applicable)
  • Docs related to the changes have been added/updated (if applicable)

@Masterchen09 Masterchen09 force-pushed the fix-mce-consumer-group-id branch 2 times, most recently from 9370589 to f94744d Compare November 8, 2024 16:42
@Masterchen09 Masterchen09 changed the title Added METADATA_CHANGE_LOG_KAFKA_CONSUMER_GROUP_ID environment variable to MCE consumer. fix(mce-consumer): added METADATA_CHANGE_LOG_KAFKA_CONSUMER_GROUP_ID environment variable to MCE consumer. Nov 8, 2024
@Masterchen09 Masterchen09 force-pushed the fix-mce-consumer-group-id branch from f94744d to 14f5df3 Compare November 8, 2024 16:43
@Masterchen09 Masterchen09 force-pushed the fix-mce-consumer-group-id branch from 14f5df3 to d719742 Compare November 12, 2024 22:58
@Masterchen09 Masterchen09 changed the title fix(mce-consumer): added METADATA_CHANGE_LOG_KAFKA_CONSUMER_GROUP_ID environment variable to MCE consumer. fix(mce-consumer): add METADATA_CHANGE_LOG_KAFKA_CONSUMER_GROUP_ID environment variable to MCE consumer. Nov 12, 2024
Copy link
Contributor

@david-leifker david-leifker left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

LGTM! Thanks as always!

@david-leifker david-leifker merged commit 767bbdc into acryldata:master Nov 29, 2024
1 check passed
@Masterchen09 Masterchen09 deleted the fix-mce-consumer-group-id branch December 16, 2024 18:19
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