在confluent_kafka v0.11.2中正好有一次

Question

我怎么办启用.幂等性或者改变加工.保证在python3.6中只需一次就可以实现kafka v0.11.4的融合。来自ConfluentKafka的很多文档只讨论Scala和Java。 我试过这样做：

p = Producer({
        'bootstrap.servers':'localhost:9092',
        'processing.guarantee' : 'exactly_once'
    })

但我有个例外：

^{pr2}$

有什么建议吗？在

Answer 1

我不知道这对于Python是如何工作的，但是如果使用Kafka流（利用事务api），那么Kafka只能获得一次交付。如果您不使用Kafka Streams库，则不提供（或可能）一次。在

在此处了解有关此操作方式的详细信息：融合.io/blog/enabling-正是卡夫卡河