diff options
Diffstat (limited to 'oslo_messaging/_drivers/impl_kafka.py')
| -rw-r--r-- | oslo_messaging/_drivers/impl_kafka.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/oslo_messaging/_drivers/impl_kafka.py b/oslo_messaging/_drivers/impl_kafka.py index ea3d102..dc4fe09 100644 --- a/oslo_messaging/_drivers/impl_kafka.py +++ b/oslo_messaging/_drivers/impl_kafka.py @@ -399,7 +399,7 @@ class KafkaDriver(base.BaseDriver): LOG.info("Kafka messaging driver shutdown") def send(self, target, ctxt, message, wait_for_reply=None, timeout=None, - call_monitor_timeout=None, retry=None): + call_monitor_timeout=None, retry=None, transport_options=None): raise NotImplementedError( 'The RPC implementation for Kafka is not implemented') |