我也遇到过这个问题。我的问题是运行时间设置得太短。动物园管理员没有足够的时间正确关闭。看看下面的代码:
builder.createTopology()); try { Thread.sleep(20000); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } cluster.shutdown(); }
您应该在调用cluster.shutdown()之前设置足够的时间。首先,我设置Thread.sleep(1000),然后出现与您相同的问题。在我改变时间之后,这个问题再也没有出现过了。