我有下面的用例，我必须订阅股票交易系统。
我需要从上游交易数据是：时间戳，股票，价格，买入或卖出，数量
作为下游，我对所有股票不感兴趣，只对存储在SQLServer表中的股票列表感兴趣。
那么我应该用哪种方法，为什么更好呢？
1.在kafka中创建一个股票主题，并要求上游系统将交易数据发布到该主题，一旦加载到我的系统中，我就在我的端应用一个过滤器
2、创建多个主题，每个主题都是我感兴趣的股票，并订阅所有这些主题。
哪种方式更现实更好？