Kafka错误与融合Kafka python on_commit callback()中每个TopicPartition中的错误字段

bmp9r5qi 于 5个月前发布在 Apache

关注(0)|答案(1)|浏览(30)

我正在Python中使用confluent-Kafka编写一个Kafka消费者。我使用的是onc commit API。on_commit回调的文档如下。我不明白First error参数和每个TopicPartition参数中的单个错误之间的区别。有人能给我演示如何处理这个回调吗？

on_commit(kafka.KafkaError, list(kafka.TopicPartition))（Consumer）：用于指示异步和自动提交请求成功或失败的回调。该回调在调用consumer.poll()时提供。同步提交时不会触发。回调参数：KafkaError 为提交错误，或成功时为None。list（TopicPartition） 为分区列表及其提交偏移量或每个分区的错误。

如果我们的论点是

没有错误
存在一些错误
所有的人

来源：https://stackoverflow.com/questions/77515998/kafka-error-vs-error-field-within-each-topicpartition-in-the-confluent-kafka-pyt

1条答案

按热度按时间

没有错误
第一个参数是None，以及所有TopicPartition.error
存在一些错误
有些TopicPartition.error是None，其他的都不是。
所有的人
所有错误都不是无

赞(0）回复(0）举报 5个月前

相关问题

微信公众号

热门标签

Java query python Node 开发语言 request Util 数据库 Table 后端算法 Logger Message Element Parser

最新问答

Python pillow/PIL无法识别对象“imagedraw”的属性“textsize”
回答(3) 发布于 4个月前
python-3.x ImportError：无法从“typing_extensions”导入名称“deprecated”
回答(2) 发布于 4个月前
python-3.x 我正尝试使用密码学对字典进行加密
回答(1) 发布于 4个月前
在Python的IDLE中导入audiolazy的问题
回答(1) 发布于 4个月前
如何将Python程序中的数据添加到Markdown？
回答(2) 发布于 4个月前