We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 5bd1b24 commit d2decf3Copy full SHA for d2decf3
src/sentry/consumers/dlq.py
@@ -113,7 +113,7 @@ def submit(self, message: Message[KafkaPayload]) -> None:
113
# If we get a valid message for a partition later, don't emit a filtered message for it
114
if self.offsets_to_forward:
115
for partition in message.committable:
116
- self.offsets_to_forward.pop(partition)
+ self.offsets_to_forward.pop(partition, None)
117
118
self.next_step.submit(message)
119
0 commit comments