使用kafka-python-1.0.2。
如果我有一个包含10个分区的主题，那么如何遍历各个分区和消息，同时提交一个特定的分区。我似乎无法在文档中或其他任何地方找到此示例
从文档中，我想使用：
consumer.commit(offset=offsets)
具体来说，如何创建偏移量所需的分区和OffsetAndMetadata字典（字典，可选）– {TopicPartition：OffsetAndMetadata}。
我希望函数调用就像这样：
consumer.commit(partition, offset)
但这似乎并非如此。
提前致谢。