Confluent kafka python暂停-恢复功能示例

【问题标题】：Confluent kafka python pause-resume functionality exampleConfluent kafka python暂停-恢复功能示例
【发布时间】：2019-03-17 05:44:56
【问题描述】：

正在尝试使用融合 kafka 消费者的暂停和恢复功能，但除了主链接外，在互联网上找不到任何示例。

https://docs.confluent.io/5.0.0/clients/confluent-kafka-python/index.html

无法理解要传递给它的参数。是它的 patitions 列表或主题名称还是什么？

【问题讨论】：

标签： python python-3.x apache-kafka confluent-platform

【解决方案1】：

暂停和恢复获取TopicPartition的列表

class confluent_kafka.TopicPartition

TopicPartition 是一个泛型类型，用于保存单个分区和有关它的各种信息。

它通常用于为各种操作提供主题或分区列表，例如 Consumer.assign()。

TopicPartition(topic[, partition][, offset])

实例化一个 TopicPartition 对象。
参数：

topic（字符串）- 主题名称

partition (int) – 分区 ID

offset (int) – 初始分区偏移量

【讨论】：

有任何使用暂停和恢复的例子吗？