在处理Kafka日志消息时,经常需要对它们进行分类、过滤和排序。 但Kafka目前只支持按主题(topic)和分区(partition)来分配消息,无法按需分配到特定的队列。但现在,通过引入队列机制,可以满足由用户自定义队列,实现更加自由化的消息处理和路由方式。

这个被提出作为Kafka Improvement Proposal的KIP-932,通过将队列设置为主题的子选项,为了增加多个队列的支持,增强了Kafka日志管理的灵活性。这名提议者认为,这个发展将有助于Kafka被更广泛的人接受,并提升Kafka与其他消息中间件的竞争力。

如果这个提案被采纳,用户可以创建多个队列并将其与单个主题相关联。每个队列都会保持独立的状态,并接收消息通过自己的规则进行处理。而且这个提案旨在为Kafka轻松添加多个新特性。无论怎样,作为软件改进计划中的一个重要步骤,它将在开发和测试过后才能得出结论。

详情参考

了解更多有趣的事情:https://blog.ds3783.com/