kafka-python-如何提交分区？

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

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

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