chore: handle kafka transport with confluentkafka (#1574)

Co-authored-by: Tomer Nosrati <tomer.nosrati@gmail.com>
This commit is contained in:
Meysam 2024-07-02 15:12:57 +07:00 committed by GitHub
parent 6e9e74c8c6
commit 4fb7246ed0
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 1 additions and 0 deletions

View File

@ -24,6 +24,7 @@ TRANSPORT_ALIASES = {
'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',