这家伙太懒,什么都没留下
嗯,注意要最后结束的时候掉下close(官方例子有,不要漏了)。如果不想调close,就加一些休眠时间。(因为有些消息是还在缓存中,没来得及发送到kafka的时候,进程就结束了)
感觉楼上说的对 但是这个问题 搜遍全网 也没人具体分析解决下