2017-07-13 39 views
0

我面临的一个奇怪的问题,在我的制片代码卡夫卡producer.close()不执行代码之后

producer.flush(); 
logger.info("Closing producer"); 
producer.close(); 
logger.info("successfully closed producer"); 

我上面的代码片断作为守则的一部分,问题是,我只能看到以下输出

Closing producer 

在我的日志中,最后一行没有出现。 如果我注释掉producer.close()它确实出现在日志中。 任何想法,为什么这样?

回答

0

生产者话题的名称是什么?我问,因为据我所知有一个当前打开的bug阻止客户端线程,如果主题名称包含单引号。你可以检查吗?

+0

主题名称是测试。它没有任何特殊字符 –