diff options
| author | Bryan Newbold <bnewbold@robocracy.org> | 2021-11-02 18:14:59 -0700 |
|---|---|---|
| committer | Bryan Newbold <bnewbold@robocracy.org> | 2021-11-02 18:14:59 -0700 |
| commit | 31d1a6a713d177990609767d508209ced19ca396 (patch) | |
| tree | a628a57bdb373669394a6b520102b1b4b5ffe7da /python/fatcat_tools/kafka.py | |
| parent | 9dc891b8098542bb089c8c47098b60a8beb76a53 (diff) | |
| download | fatcat-31d1a6a713d177990609767d508209ced19ca396.tar.gz fatcat-31d1a6a713d177990609767d508209ced19ca396.zip | |
fmt (black): fatcat_tools/
Diffstat (limited to 'python/fatcat_tools/kafka.py')
| -rw-r--r-- | python/fatcat_tools/kafka.py | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/python/fatcat_tools/kafka.py b/python/fatcat_tools/kafka.py index 32749db2..2a4451ad 100644 --- a/python/fatcat_tools/kafka.py +++ b/python/fatcat_tools/kafka.py @@ -1,4 +1,3 @@ - from confluent_kafka import KafkaException, Producer @@ -9,14 +8,15 @@ def kafka_fail_fast(err, msg): # TODO: should it be sys.exit(-1)? raise KafkaException(err) + def simple_kafka_producer(kafka_hosts): kafka_config = { - 'bootstrap.servers': kafka_hosts, - 'message.max.bytes': 20000000, # ~20 MBytes; broker-side max is ~50 MBytes - 'delivery.report.only.error': True, - 'default.topic.config': { - 'request.required.acks': -1, + "bootstrap.servers": kafka_hosts, + "message.max.bytes": 20000000, # ~20 MBytes; broker-side max is ~50 MBytes + "delivery.report.only.error": True, + "default.topic.config": { + "request.required.acks": -1, }, } return Producer(kafka_config) |