producer.close() ne pas exécuter le code après

Question

je suis confronté à un problème étrange dans mon code de producteur pour kafka

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

J'ai ci-dessus extrait de code dans le cadre d'un code, le problème est que je suis seulement en mesure de voir la sortie suivante

Closing producer 

dans mes journaux la dernière ligne n'apparaît pas. Si je commente producteur.close() il apparaît dans les journaux. Des idées pourquoi c'est ainsi?

Answer 1

Quel est le nom du sujet sur le producteur? J'ai demandé, car pour autant que je sache, il existe actuellement un bug qui bloque le thread client si le nom du sujet contient des guillemets simples. Pouvez-vous vérifier cela?