试图使用融合Kafka消费者的暂停和恢复功能，但除了主链接，在互联网上找不到任何例子。https://docs.confluent.io/5.0.0/clients/confluent-kafka-python/index.html无法理解要传递给它的参数。它的分区列表或主题名还是什么？
dbf7pr2w1#
暂停并继续 TopicPartition class confluent_kafka.TopicPartition TopicPartition 是一个泛型类型，用于保存单个分区及其各种信息。它通常用于为各种操作（如consumer.assign（））提供主题或分区的列表。 TopicPartition(topic[, partition][, offset]) 示例化topicpartition对象。参数： topic （字符串）–主题名称 partition （int）–分区id offset （int）–初始分区偏移
TopicPartition
TopicPartition(topic[, partition][, offset])
topic
partition
offset
1条答案
按热度按时间dbf7pr2w1#
暂停并继续
TopicPartitionclass confluent_kafka.TopicPartitionTopicPartition是一个泛型类型，用于保存单个分区及其各种信息。它通常用于为各种操作（如consumer.assign（））提供主题或分区的列表。
TopicPartition(topic[, partition][, offset])示例化topicpartition对象。参数：
topic（字符串）–主题名称partition（int）–分区idoffset（int）–初始分区偏移