对于合流kafka v0.11.4，如何在python3.6中启用.idemponency或将processing.guarance更改为恰好\u一次。来自confluent kafka的很多文档只讨论scala和java。我试过这样做：
p = Producer({
'bootstrap.servers':'localhost:9092',
'processing.guarantee' : 'exactly_once'
})但我有个例外：
cimpl.KafkaException: KafkaError{code=_INVALID_ARG,val=-186,str="No such
configuration property: "processing.guarantee""}有什么建议吗？
1条答案
按热度按时间bkkx9g8r1#
我不知道这是如何专门用于python的，但是如果您使用kafka流（利用transactions api），那么您只能通过kafka获得一次交付。如果您不使用kafka streams库，则不能（或可能）精确使用一次。
在此处了解有关此操作的更多信息：confluent.io/blog/enabling-exactly-kafka-streams