python - python-kafka：消费者是否可以根据消息属性跳过消息？

Question

给定一组消息，每个消息都有一个优先级属性。消费者是否可以跳过或忽略优先级属性不够高的消息？

一开始我反序列化了 kafka-python 消费者消费的消息，检查了优先级并丢弃了那些不符合要求的优先级的消息。

但我担心如果消息很大，将浪费大量时间来反序列化不会进一步处理的消息。从kafka队列中读取是否有办法做到这一点？

Answer 1

Kafka 目前不支持这种方式的自定义元数据，因此消费者过滤某些消息的唯一方法是读取有效负载。然而，有一个改进提案正在讨论中，可以解决这种情况，可能值得关注。