confluent-kafka-python icon indicating copy to clipboard operation
confluent-kafka-python copied to clipboard

Published 20 hours ago • verified publisher icon confluentinc

Producer idempotence not work

Open wagnzi opened this issue 2 years ago • 0 comments

here is my producer config： kafka_producer = SerializingProducer({ 'bootstrap.servers': 'master:9092,slave1:9092,slave2:9092', 'key.serializer': StringSerializer('utf_8'), 'value.serializer': StringSerializer('utf_8'), 'queue.buffering.max.kbytes': 2000000, 'queue.buffering.max.messages': 1000000, 'acks': -1, 'enable.idempotence': 'true' }) confluent kafka version is 1.9.0， but it does not work， the same message is still stored in kafka， anyone can help me?

wagnzi avatar Jun 24 '22 10:06 wagnzi