已解决。哈哈,我犯傻了。其实直接用消费者 + 生产者就好了。不需要用kafkaStream。