-
Notifications
You must be signed in to change notification settings - Fork 108
feat(replay): Remove replay_relay_snuba_publish_disabled_sample_rate
#5629
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
feat(replay): Remove replay_relay_snuba_publish_disabled_sample_rate
#5629
Conversation
| start_time: safe_timestamp(received_at), | ||
| payload, | ||
| }; | ||
| self.produce(KafkaTopic::ReplayEvents, KafkaMessage::ReplayEvent(message))?; |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I think we can then also remove the ReplayEvents topic (and follow that up with an infra change to unconfigure the topic)
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I think for the time that we remove it here but not yet in the infra this will error here:
Line 50 in 88085ca
| || relay_log::error!("unused topic assignment '{name}'"), |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Yeah that should happen and it's fine, this is the safest way to do it. Remove from code before removing from infra (e.g. to allow for rollbacks). In this case we could do something else considering the topic hasn't been used in a long time, but better to do it the 'right ' way.
We could lower that message from error to warn though. It's error because we didn't used to pipe warnings into Sentry.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Cursor Bugbot has reviewed your changes and found 1 potential issue.
Bugbot Autofix is OFF. To automatically fix reported issues with Cloud Agents, enable Autofix in the Cursor dashboard.
| start_time: safe_timestamp(received_at), | ||
| payload, | ||
| }; | ||
| self.produce(KafkaTopic::ReplayEvents, KafkaMessage::ReplayEvent(message))?; |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Yeah that should happen and it's fine, this is the safest way to do it. Remove from code before removing from infra (e.g. to allow for rollbacks). In this case we could do something else considering the topic hasn't been used in a long time, but better to do it the 'right ' way.
We could lower that message from error to warn though. It's error because we didn't used to pipe warnings into Sentry.
jjbayer
left a comment
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Might benefit from an "internal" changelog because it will change behavior in self-hosted.
While working on the refactor of the
process_replaylogic we noticed thatrelay-snuba-publishing-disabledis perpetually set to 100%.This PR replaces the option with a hard coded true value and removes all the code that is dead due to this change. Specifically
produce_replay_eventwhich currently just early returns andReplayEventKafkaMessagewhich is only constructed in this function. Furthermore the tests that rely on the option are also modified or removed (if they now test behaviour that is no longer possible).Follow up:
replay_eventsin the processor since they are dropped silently in the store anyways.