ref: Type check post process forwarder (#51210)

pyproject.toml

@@ -1563,7 +1563,6 @@ module = [
     "tests.sentry.plugins.bases.test_issue2",
     "tests.sentry.plugins.bases.test_notify",
     "tests.sentry.plugins.test_config",
-    "tests.sentry.post_process_forwarder.test_post_process_forwarder",
     "tests.sentry.processing.realtime_metrics.test_redis",
     "tests.sentry.profiles.consumers.test_process",
     "tests.sentry.profiles.test_task",

tests/sentry/post_process_forwarder/test_post_process_forwarder.py

@@ -45,12 +45,7 @@ def kafka_message_payload() -> Any:
 
 class PostProcessForwarderTest(TestCase):
     def _get_producer(self, cluster_name: str) -> Producer:
-        conf = {
-            "bootstrap.servers": settings.KAFKA_CLUSTERS[cluster_name]["common"][
-                "bootstrap.servers"
-            ],
-            "session.timeout.ms": 6000,
-        }
+        conf = settings.KAFKA_CLUSTERS[cluster_name]["common"]
         return Producer(conf)
 
     def setUp(self) -> None: