已解决。哈哈,我犯傻了。其实直接用消费者 + 生产者就好了。不需要用kafkaStream。
 
                        
                        
                    
                    
                    
                    
                    
                    
                最后补充下问题解决方案:
将kafka集群的每个节点的配置文件中下面该属性注释放开,并修改对应的hostname,保存后重启kafka。
advertised.listeners=PLAINTEXT://dwtest-data2:9092
然后之前的那种情况就不会出现了。