您好, 欢迎来到 !    登录 | 注册 | | 设为首页 | 收藏本站
问答- 问题:kafka-python-如何提交分区？

kafka-python-如何提交分区？

kafka-python-如何提交分区？

这样看来，我可能已经想通了，很有趣，当您写下问题时，这是如何发生的。这似乎可行：

Meta = consumer.partitions_for_topic(topic)
options = {}
options[partition] = OffsetAndMetadata(message.offset + 1, Meta)
consumer.commit(options)

需要进行更多测试，但是如果有任何更改，它将进行更新。

python 2022/1/1 18:37:25 有233人围观

撰写回答

你尚未登录，登录后可以

和开发者交流问题的细节

关注并接收问题和回答的更新提醒

参与内容的编辑和改进，让解决方法与时俱进

请先登录

推荐问题

联系我

联系我

602392714

清零编程清零编程群

置顶