カフカプロデューサーを閉じないとどうなるのですか？

Question

私はxmlを処理しています。最後のレコードを受け取ったときにレコードごとにメッセージを送信する必要があります。私はカフカプロデューサーを閉じます。カフカのプロデューサーは非同期なので、プロデューサーを閉じると時々java.lang.IllegalStateException: Cannot send after the producer is closed.が出て、私はプロデューサーを開いたままにすることができる場所を読みました。私の質問は¿は何を意味していますか？あるいは、この

---編集のためのよりよい解決策---

<list> 
    <element attr1="" att2="" attr3=""/> 
    <element attr1="" att2="" attr3=""/> 
    <element attr1="" att2="" attr3=""/> 
    <element attr1="" att2="" attr3=""/> 
    <element attr1="" att2="" attr3=""/> 
    <element attr1="" att2="" attr3=""/> 
    <element attr1="" att2="" attr3=""/> 
    <element attr1="" att2="" attr3=""/> 
... 
</list> 

があれば次のシナリオを想像：私たちは、タグを読んで、私たちはカフカのプロデューサーを作成

• を
• 各要素ごとに属性を読み取り、jsonオブジェクトを生成し、sendメソッドを使用してkafkaに送信します。我々は、プロデューサ

問題でcloseメソッドを呼び出し要素を読み取る -When要素の数は、我々は切断メソッドを呼び出すときに、時にはそれが非同期な方法でメッセージを送信し続け、従って80Kであることができます。だから我々は最初のflushメソッドを呼び出す必要がありますが、それに影響パフォーマンス

あなたはProducer.close()を呼び出す前Producer.flush()を呼び出す必要がありますあなたの

Answer 1

ありがとうございます。これはブロッキング呼び出しであり、すべてのレコードが送信される前ではありません。

close()を呼び出さないと、実装/言語によってはリソース/メモリリークが発生する可能性があります。