producer.close() nicht ausgeführt den Code danach

Question

Ich bin vor ein seltsames Problem in meinem Produzenten-Code für kafka

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

ich über Code-Schnipsel haben als Teil eines Codes, das Problem ist, dass ich bin nur in der Lage, die folgende Ausgabe zu sehen

Closing producer 

in meinen Protokollen erscheint die letzte Zeile nicht. Wenn ich producer.close() auskommentiere, erscheint es in Protokollen. Irgendwelche Ideen, warum das so ist?

Answer 1

Wie lautet der Name des Themas beim Hersteller? Ich fragte, denn soweit ich weiß, gibt es derzeit eine offene bug, die den Client-Thread blockieren, wenn der Themenname einfache Anführungszeichen enthält. Kannst du das überprüfen?