Language:
Format:

付録D プロデューサー設定パラメーター

key.serializer

型：クラス
のインポート： high

org.apache.kafka.common.serialization.Serializer インターフェースを実装するキーのシリアライザークラス。

value.serializer

型：クラス
のインポート： high

org.apache.kafka.common.serialization.Serializer インターフェースを実装する値のシリアライザークラス。

acks

型：文字列
デフォルト： 1
有効な値 [ all, -1, 0, 1]
重要性： high

リクエストの完了前に、プロデューサーがリーダーを受信する必要がある確認応答。これにより、送信されるレコードの持続性が制御されます。以下の設定が許可されます。

acks=0 ゼロに設定すると、プロデューサーはサーバーから送信をまったく待ちません。レコードは即座にソケットバッファーに追加され、送信済みとみなされます。この場合、サーバーがレコードを受信しないように保証はありません（通常障害を把握しないため）。retries各レコードに対して指定されたオフセットは常に -1 に設定されます。
acks=1 これは、リーダーがレコードをローカルログに書き込まれますが、すべてのフォロワーからの完全な確認応答を待たずに応答します。この場合、レコードの確認後、フォロワーでレプリケートされる前にリーダーがコミットに失敗しても、レコードが失われます。
acks=all これは、リーダーが in-Sync レプリカの完全なセットがレコードを認識しているのを待つことを意味します。これにより、1 つ以上の In-sync レプリカが動作している限り、レコードが失われなくなります。これは、最も強固な保証です。これは acks=-1 設定と同じです。

bootstrap.servers

type: list
デフォルト： ""
有効な値： non-null string
Importance: high

Kafka クラスターへの最初の接続を確立するために使用するホストとポートのペアの一覧。クライアントは、ブートストラップ用に指定されたすべてのサーバーに関係なく、サーバーの完全なセットを検出するために使用される初期ホストにのみ影響します。このリストは host1:port1,host2:port2,… の形式にする必要があります。これらのサーバーは、クラスターの完全なメンバーシップを検出するために最初の接続に使用されるため（動的に変更される可能性がある）、この一覧にはサーバーの完全セットを含める必要はありません（サーバーがダウンした場合など）。

buffer.memory

タイプ： long
デフォルト： 33554432
有効な値： [0,…]
Importance: high

プロデューサーがサーバーに送信されるまで待機するために使用できるメモリーの合計バイト。レコードがサーバーに配信可能よりも早く送信される場合、プロデューサーは max.block.ms のブロックされ、例外が発生します。

この設定は、プロデューサーが使用するメモリーの合計のみに対応する必要がありますが、プロデューサーが使用するすべてのメモリーがバッファーに使用されるわけではありません。一部の追加メモリーは圧縮に使用されます（圧縮が有効になっている場合）。またインフライトリクエストを維持するために使用されます。

compression.type

型：文字列
デフォルト： none
インポート： high

プロデューサーによって生成されたすべてのデータの圧縮タイプ。デフォルトは none です（圧縮なし）。有効な値は none、gzip、snappy、lz4、または zstd です。圧縮はデータの完全なバッチであるため、バッチ処理の効率が悪くなるため、圧縮率（バッチ処理がより改善）に影響を及ぼします。

retries

型： int
デフォルト： 2147483647
有効値： [0,…,2147483647]
Importance: high

値をゼロに設定すると、クライアントは、一時的なエラーで失敗したレコードを再送信します。この再試行は、クライアントがエラーの受信時にレコードを再入力する場合とは異なることに注意してください。max.in.flight.requests.per.connection を 1 に設定せずに再試行を許可すると、レコードの順序が変更する可能性があります。これは、2 つのバッチで 1 つのバッチに送信され、1 番目に再試行されるため、2 番目のバッチのレコードが最初に表示される可能性があります。確認が成功する前に、delivery.timeout.ms 期限切れで設定されるタイムアウトが最初に設定されると、再試行の数が使い切られる前にリクエストも失敗することに注意してください。通常は、この設定を未設定のままにし、代わりに delivery.timeout.ms を使用して再試行処理を制御することが推奨されます。

ssl.key.password