在Kafka中，可以使用命令行工具kafka-console-consumer.sh来消费消息并进行过滤
计算
安全
数据库
网络和加速
企业服务
kafka-console-consumer.sh --bootstrap-server <kafka-broker-address> --topic <topic-name> --from-beginning --filter "your_filter_expression"
其中：
<kafka-broker-address>：Kafka代理服务器的地址，例如localhost:9092。<topic-name>：要消费的主题名称。--from-beginning：从主题的开始位置消费消息。--filter：用于过滤消息的表达式。--filter参数中，使用Kafka消息的键和值进行过滤。例如，如果要过滤键为key1且值为value1的消息，可以使用以下命令：kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic my-topic --from-beginning --filter "key='key1' AND value='value1'"
注意：在表达式中使用单引号，而不是双引号。
这样，消费者将只消费满足过滤条件的消息。
亿速云「云服务器」，即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘，价格低至29元/月。点击查看>>
推荐阅读：kafka命令行消费如何限流
