diff --git a/producer.py b/producer.py index 091003a..16be502 100755 --- a/producer.py +++ b/producer.py @@ -10,8 +10,6 @@ # See https://github.com/edenhill/librdkafka/blob/master/CONFIGURATION.md conf = { 'bootstrap.servers': os.environ['CLOUDKARAFKA_BROKERS'], - 'session.timeout.ms': 6000, - 'default.topic.config': {'auto.offset.reset': 'smallest'}, 'security.protocol': 'SASL_SSL', 'sasl.mechanisms': 'SCRAM-SHA-256', 'sasl.username': os.environ['CLOUDKARAFKA_USERNAME'],