我正在使用Kafka Consumer从多个主题中读取数据,我希望其中一个主题具有更高的优先级。处理需要很长时间,并且通常有许多(低优先级)主题中的消息,但我希望来自另一个主题的消息尽快被处理。
这与Kafka是否支持主题或消息优先级类似,但此问题使用旧API。
在新的API(0.10.1.1)中,有以下方法:
这与Kafka是否支持主题或消息优先级类似,但此问题使用旧API。
在新的API(0.10.1.1)中,有以下方法:
KafkaConsumer::pause(Collection)
KafkaConsumer::resume(Collection)
但我不清楚如何有效地检测高优先级主题中是否有新消息,并且需要暂停从其他主题进行消费。
有什么想法/示例吗?