合流kafka python暂停恢复功能示例

xfyts7mz  于 2021-06-06  发布在  Kafka
关注(0)|答案(1)|浏览(609)

试图使用融合Kafka消费者的暂停和恢复功能,但除了主链接,在互联网上找不到任何例子。
https://docs.confluent.io/5.0.0/clients/confluent-kafka-python/index.html
无法理解要传递给它的参数。它的分区列表或主题名还是什么?

dbf7pr2w

dbf7pr2w1#

暂停并继续 TopicPartition class confluent_kafka.TopicPartition TopicPartition 是一个泛型类型,用于保存单个分区及其各种信息。
它通常用于为各种操作(如consumer.assign())提供主题或分区的列表。 TopicPartition(topic[, partition][, offset]) 示例化topicpartition对象。
参数: topic (字符串)–主题名称 partition (int)–分区id offset (int)–初始分区偏移

相关问题