apache stormKafkaSpout是否有在订阅的源主题中设置优先级的概念？
例如，如果KafkaSpout订阅主题t1、t2、t3，是否有一种方法可以控制消耗率，如t1的70%、t2的20%和t3的10%，如果主题t1中没有任何消息，则将t1的资源分配给t2，依此类推？
不，这不是内置的。Kafka没有主题优先级的概念。使用KafkaConsumer.pause和KafkaConsumer.resume方法可以构建类似的东西。喷口目前还不支持这一点，但如果你想看到它被添加，你可以在https://issues.apache.org/jira.如果你想添加它，你可以在https://github.com/apache/storm.