storm-kafka KafkaSpout：设置主题之间的优先级
storm-kafka KafkaSpout: setting priority among topics
apache storm KafkaSpout 是否有在订阅的源主题中设置优先级的概念？
例如，如果 KafkaSpout 正在订阅主题 t1、t2、t3 有没有办法像 70% 那样控制消费率来自 t1、来自 t2 的 20% 和来自 t3 的 10%，如果主题 t1 中没有任何消息，则分配 t1的资源到t2等等？
不，这不是内置的。Kafka 没有主题优先级的概念。可以使用 KafkaConsumer.pause 和 KafkaConsumer.resume 方法构建类似的东西。 spout 目前不支持此功能，但如果您希望添加它，可以在 https://issues.apache.org/jira. If you'd like to work on adding it, you can find the Storm code at https://github.com/apache/storm 提出问题。
apache storm KafkaSpout 是否有在订阅的源主题中设置优先级的概念？
例如，如果 KafkaSpout 正在订阅主题 t1、t2、t3 有没有办法像 70% 那样控制消费率来自 t1、来自 t2 的 20% 和来自 t3 的 10%，如果主题 t1 中没有任何消息，则分配 t1的资源到t2等等？
不，这不是内置的。Kafka 没有主题优先级的概念。可以使用 KafkaConsumer.pause 和 KafkaConsumer.resume 方法构建类似的东西。 spout 目前不支持此功能，但如果您希望添加它，可以在 https://issues.apache.org/jira. If you'd like to work on adding it, you can find the Storm code at https://github.com/apache/storm 提出问题。