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