confluent-kafka-python
confluent-kafka-python copied to clipboard
Producer idempotence not work
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?