Kafka支持主题或消息的优先级吗？

Question

我正在研究Kafka是否支持任何要处理的队列或消息的优先级。

看来它不支持任何这样的事情。我在谷歌上找到了这个也支持这一点的邮件存档:http://mail-archives.apache.org/mod_mbox/incubator-kafka-users/201206.mbox/%3CCAOEJIJHVHSR=[e-mail]%3e

这里有没有人把Kafka配置成对任何主题或消息进行优先排序？

Answer 1

Kafka是一个快速、可扩展、分布式的提交日志服务，它的设计是分区的、复制的，因此没有主题或消息的优先级。

我也面临着和你一样的问题。解决方法很简单。在Kafaka队列中创建主题，让我们说：

>

high_priority_queue

在high_priority_queue中发布高优先级消息，在medium_priority_queue中发布中等优先级消息。

现在您可以创建Kafaka消费者和开放流的所有主题。

  // this is scala code 
  val props = new Properties()
  props.put("group.id", groupId)
  props.put("zookeeper.connect", zookeeperConnect)
  val config = new ConsumerConfig(props)
  val connector = Consumer.create(config)
  val topicWithStreamCount = Map(
       "high_priority_queue" -> 1,
       "medium_priority_queue" ->  1, 
       "low_priority_queue" -> 1
  )
  val streamsMap = connector.createMessageStreams(topicWithStreamCount)

现在，如果主题没有任何消息，您可以首先读取high_priority_queue主题，然后回退到medium_priority_queue主题。如果medium_priority_queue为空，则读取low_priority queue。

这招对我很管用。也许对你有帮助！！。