command
Version:
v2.13.0+incompatible
Opens a new window with list of versions in this module.
Published: Aug 27, 2020
License: MIT
Opens a new window with license information.
Imports: 8
Opens a new window with list of imports.
Imported by: 0
Opens a new window with list of known importers.
Documentation
¶
qbus暂停/恢复消费功能示例:对每个topic,每次消费一个批次(固定数量)的消息,就会暂停消费该topic一段时间,之后恢复消费。
仅支持 Kafka 模式
Source Files
¶
Click to show internal directories.
Click to hide internal directories.