We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 57bfe8e commit 734ff10Copy full SHA for 734ff10
1 file changed
pulsar/__init__.py
@@ -646,6 +646,7 @@ def create_producer(self, topic,
646
_check_type_or_none(str, encryption_key, 'encryption_key')
647
_check_type_or_none(CryptoKeyReader, crypto_key_reader, 'crypto_key_reader')
648
_check_type(bool, lazy_start_partitioned_producers, 'lazy_start_partitioned_producers')
649
+ _check_type(ProducerAccessMode, access_mode, 'access_mode')
650
651
conf = _pulsar.ProducerConfiguration()
652
conf.send_timeout_millis(send_timeout_millis)
0 commit comments