关于storm的输入源的一个问题？

假如我现在有个socket的接口，他是有一个类似于心跳的东西传数据过来，然后数据量挺大的，对数据处理速度远小于传送速度，传输的数据得自己解析，没有规定的协议，但有一个规范，这种情况解析是放在Kafka的生产者里面？还是到了storm的spout里去解析呢

重要提示：提问者不能发表回复，可以通过评论与回答者沟通，沟通后可以通过编辑功能完善问题描述，以便后续其他人能够更容易理解问题.