Kafka Python消费者提交API

Question

我需要使用kafka-python api进行编程提交。从文档中我看到我需要使用下面的api，但找不到一个好的用法示例：

​

​

它需要偏移量作为TopicPartition和OffsetMetadata的字典。我在考虑对使用者使用assignment() API，它会返回当前使用者的TopicPartitions列表。对于OffsetAndMetadata，我可以设置偏移量，但我不知道需要为元数据属性设置什么。文档并没有那么有帮助。

请让我知道。

提前谢谢。

Answer 1

元数据在OffsetAndMetadata对象中是可选的。您可以将None作为元数据值传递。

Kafka不在内部使用此元数据，因此它实际上是一个不透明的字节数组，可用于存储特定于应用程序的数据。

更多信息请点击此处：https://github.com/dpkp/kafka-python/issues/645