From b50447a091048c91c61b90be161d6b9af1c9cc9a Mon Sep 17 00:00:00 2001 From: Nikhar Saxena Date: Wed, 27 Oct 2021 14:06:21 -0700 Subject: [PATCH] fix(kafka-headers): Make transaction forwarder header relevant Now that the transaction forwarder is running in production and its offsets have caught up with current forwarder, its time to make the switch --- src/sentry/eventstream/kafka/backend.py | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/src/sentry/eventstream/kafka/backend.py b/src/sentry/eventstream/kafka/backend.py index 834a4162a71501..fc81c80b514770 100644 --- a/src/sentry/eventstream/kafka/backend.py +++ b/src/sentry/eventstream/kafka/backend.py @@ -69,9 +69,7 @@ def encode_bool(value: Optional[bool]) -> str: def strip_none_values(value: Mapping[str, Optional[str]]) -> Mapping[str, str]: return {key: value for key, value in value.items() if value is not None} - # TODO: Change transaction_forwarder to be intelligent once transaction post process forwarder - # is implemented and caught up with current events post process forwarder. - transaction_forwarder = False + transaction_forwarder = True if event.group_id is None else False send_new_headers = options.get("eventstream:kafka-headers")