我不清楚为什么我们需要session.timeout.ms和max.poll.interval.ms以及何时使用一个或另一个或两者?似乎两者都表明时间协调器的上限将等待消费者获得心跳,然后再将其假死.
另外,对于基于KIP-62的 0.10.1.0+版本,它的表现如何?
我正在探索Kafka是否支持任何队列或消息处理的优先级这一事实.
它似乎不支持任何这样的事情.我用Google搜索并发现了这个支持此邮件的邮件存档:http: //mail-archives.apache.org/mod_mbox/incubator-kafka-users/201206.mbox/%3CCAOeJiJhVHsr=d6aSTihPsqWVg6vK5xYLam6yMDcd6UAUoXf-DQ@mail.gmail.com%3E
这里有没有人配置Kafka来优先处理任何主题或消息?