0
我面临的一个奇怪的问题,在我的制片代码卡夫卡producer.close()不执行代码之后
producer.flush();
logger.info("Closing producer");
producer.close();
logger.info("successfully closed producer");
我上面的代码片断作为守则的一部分,问题是,我只能看到以下输出
Closing producer
在我的日志中,最后一行没有出现。 如果我注释掉producer.close()它确实出现在日志中。 任何想法,为什么这样?
主题名称是测试。它没有任何特殊字符 –