1个使用消费者过滤器的Kafka主题与不使用消费者过滤器的许多主题

Dun*_*ebs 5 apache-kafka kafka-consumer-api

我正在尝试将Kafka技术用于分布式系统,该系统实时使用来自金融交易所的报价数据,并且不确定在这种用例中哪种方法最有意义:

我正在使用数千只股票的数据,每个消费者只关心使用最多100个符号的少数股票的数据。我最好是为每只股票创建一个主题,然后让消费者订阅它关心的主题列表吗?还是最好有一个主题发布所有的报价数据,并且消费者使用过滤器只消费它的消息?关心?

我不知道在Kafka中是否有像JMS这样的消息选择器,也不知道哪种选项可以提供更好的性能。感谢任何反馈或答案,目标是尽可能减少延迟。-邓肯