chore: handle kafka transport with confluentkafka ✨ (#1574)

Co-authored-by: Tomer Nosrati <[email protected]>
celery · Jul 2, 2024 · 4fb7246 · 4fb7246
1 parent 6e9e74c
commit 4fb7246
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/kombu/transport/__init__.py b/kombu/transport/__init__.py
@@ -24,6 +24,7 @@ def supports_librabbitmq() -> bool | None:
     'pyamqp': 'kombu.transport.pyamqp:Transport',
     'librabbitmq': 'kombu.transport.librabbitmq:Transport',
     'confluentkafka': 'kombu.transport.confluentkafka:Transport',
+    'kafka': 'kombu.transport.confluentkafka:Transport',
     'memory': 'kombu.transport.memory:Transport',
     'redis': 'kombu.transport.redis:Transport',
     'rediss': 'kombu.transport.redis:Transport',