ドキュメント

ブローカー設定についての詳細はscalaクラスkafka.server.KafkaConfigの中で見つけることができます。

3.1.1ブローカー設定の更新

• read-only: 更新のためにブローカーの再起動を必要とします
• per-broker: 各ブローカーについて動的に更新することができます
• cluster-wide: クラスタ全体のデフォルトとして動的に更新することができます。テストのためにブローカー毎の値として更新することもできます。

  > bin/kafka-configs.sh --bootstrap-server localhost:9092 --entity-type brokers --entity-name 0 --alter --add-config log.cleaner.threads=2

  > bin/kafka-configs.sh --bootstrap-server localhost:9092 --entity-type brokers --entity-name 0 --describe

  > bin/kafka-configs.sh --bootstrap-server localhost:9092 --entity-type brokers --entity-name 0 --alter --delete-config log.cleaner.threads

  > bin/kafka-configs.sh --bootstrap-server localhost:9092 --entity-type brokers --entity-default --alter --add-config log.cleaner.threads=2

  > bin/kafka-configs.sh --bootstrap-server localhost:9092 --entity-type brokers --entity-default --describe

• ZooKeeperに格納された動的なブローカー毎の設定
• ZooKeeperに格納された動的なクラスタ全体のデフォルト設定
• server.propertiesからの静的なブローカー設定
• Kafkaのデフォルトは、ブローカーの設定を見てください

動的にパスワードの設定を更新

動的に更新されたパスワードの設定値はZooKeeperに格納される前に暗号化されます。ブローカーの設定 password.encoder.secret はパスワード設定の動的な更新を有効にするためにserver.propertiesの中で設定されなければなりません。secret は異なるブローカーでは異なるかもしれません。

パスワードの符号化に使われるsecretはブローカーのローリング再起動と共にローテートされるかもしれません。ZooKeeper内の現在のところパスワードの符号化に使われた古いsecretは静的なブローカーの設定password.encoder.old.secret内で提供され、新しいsecretはpassword.encoder.secret内で提供されなければなりません。ZooKeeper内に格納されている全ての動的なパスワードの設定はブローカーが起動する時に新しいsecretを使って再符号化されるでしょう。

Kafka 1.1.xでは、パスワード設定が変更されていない場合でさえも、kafka-configs.sh を使って設定を更新した時に、各変更リクエストの中で全ての動的に更新されるパスワードの設定は提供されなければなりません。この制約は将来のリリースで削除されるでしょう。

ブローカーの開始前にZooKeeper内のパスワード設定を更新する

  > bin/kafka-configs.sh --zookeeper localhost:2182 --zk-tls-config-file zk_tls_config.properties --entity-type brokers --entity-name 0 --alter --add-config
    'listener.name.internal.ssl.key.password=key-password,password.encoder.secret=secret,password.encoder.iterations=8192'

既存のlistenerのSSL キーストアの更新

• ssl.keystore.type
• ssl.keystore.location
• ssl.keystore.password
• ssl.key.password

既存のlistenerのSSL トラストストアの更新

• ssl.truststore.type
• ssl.truststore.location
• ssl.truststore.password

デフォルトのトピックの設定の更新

• log.segment.bytes
• log.roll.ms
• log.roll.hours
• log.roll.jitter.ms
• log.roll.jitter.hours
• log.index.size.max.bytes
• log.flush.interval.messages
• log.flush.interval.ms
• log.retention.bytes
• log.retention.ms
• log.retention.minutes
• log.retention.hours
• log.index.interval.bytes
• log.cleaner.delete.retention.ms
• log.cleaner.min.compaction.lag.ms
• log.cleaner.max.compaction.lag.ms
• log.cleaner.min.cleanable.ratio
• log.cleanup.policy
• log.segment.delete.delay.ms
• unclean.leader.election.enable
• min.insync.replicas
• max.message.bytes
• compression.type
• log.preallocate
• log.message.timestamp.type
• log.message.timestamp.difference.max.ms

  > bin/zookeeper-shell.sh localhost
  rmr /controller

ログ クリーナーの設定の更新

• log.cleaner.threads
• log.cleaner.io.max.bytes.per.second
• log.cleaner.dedupe.buffer.size
• log.cleaner.io.buffer.size
• log.cleaner.io.buffer.load.factor
• log.cleaner.backoff.ms

スレッド設定の更新

• num.network.threads
• num.io.threads
• num.replica.fetchers
• num.recovery.threads.per.data.dir
• log.cleaner.threads
• background.threads

ConnectionQuota 設定の更新

• max.connections.per.ip
• max.connections.per.ip.overrides

listenerの追加と削除

listener は動的に追加あるいは削除されるかもしれません。新しいlistenerを追加する時、listenerのセキュリティ設定がlistenerプリフィックスlistener.name.{listenerName}.を使ってlistener設定として提供されなければなりません。もし新しいlistenerがSASLを使う場合、listenerのJAAS設定がlistenerと仕組みのプリフィックスを持つJAAS設定プロパティsasl.jaas.configを使って提供されなければなりません。詳細はKafkaブローカーのためのJAAS 設定 を見てください。

Kafka バージョン 1.1.x では、内部ブローカー listenerによって使われるlistenerは動的に更新されないかもしれません。新しいlistenerへの内部ブローカーlistenerを更新するために、新しいlistenerがブローカーの再起動無しに全てのブローカー上で追加されるかもしれません。inter.broker.listener.nameを更新するためにローリング再起動が必要とされます。

• リスナー
• advertised.listeners
• listener.security.protocol.map

3.2トピックレベルの設定

  > bin/kafka-topics.sh --bootstrap-server localhost:9092 --create --topic my-topic --partitions 1 \
      --replication-factor 1 --config max.message.bytes=64000 --config flush.messages=1

  > bin/kafka-configs.sh --bootstrap-server localhost:9092 --entity-type topics --entity-name my-topic
      --alter --add-config max.message.bytes=128000

  > bin/kafka-configs.sh --bootstrap-server localhost:9092 --entity-type topics --entity-name my-topic --describe

  > bin/kafka-configs.sh --bootstrap-server localhost:9092  --entity-type topics --entity-name my-topic
      --alter --delete-config max.message.bytes

• cleanup.policy

  A string that is either "delete" or "compact" or both. この文字列は古いログセグメント上で使用する保持ポリシーを指定します。デフォルトのポリシー ("delete") は保持期間あるいはサイズの制限に到達した時に古いセグメントを破棄するでしょう。"compact" 設定はトピックでのlog のコンパクション を有効にするでしょう。

  Type:	list
  デフォルト:	delete
  有効な値:	[compact, delete]
  サーバのデフォルトのプロパティ:	log.cleanup.policy
  重要:	medium

• compression.type

  指定されたトピックのための最終的な圧縮タイプを指定する。この設定は標準的な圧縮コーディック('gzip', 'snappy', 'lz4', 'zstd')を受け付けます。更に、非圧縮に相当する 'uncompressed'; プロデューサによって設定された元の圧縮コーディックを保持することを意味する'producer' を受け付けます。

  Type:	文字列
  デフォルト:	producer
  有効な値:	[uncompressed, zstd, lz4, snappy, gzip, producer]
  サーバのデフォルトのプロパティ:	compression.type
  重要:	medium

• delete.retention.ms

  log compacted トピックのための削除の墓石の目印を維持するための総時間。もし最終のステージの有効なスナップショットを取得するためにオフセット0から始める場合は、この設定はコンシューマが読み込みを完了させる時間の境界も与えます (そうでなければ、削除の墓石はそれらが走査を完了する前に集められるかもしれません)。

  Type:	long
  デフォルト:	86400000 (1 日)
  有効な値:	[0,...]
  サーバのデフォルトのプロパティ:	log.cleaner.delete.retention.ms
  重要:	medium

• file.delete.delay.ms

  ファイルシステムからファイルを削除するまでの待ち時間

  Type:	long
  デフォルト:	60000 (1 分)
  有効な値:	[0,...]
  サーバのデフォルトのプロパティ:	log.segment.delete.delay.ms
  重要:	medium

• flush.messages

  この設定はログに書かれるデータのfsyncを強制する間隔を指定することができます。例えば、もしこれが1に設定された場合、各メッセージの後にfsyncされるでしょう; もし5であれば各5メッセージ毎にfsyncするでしょう。一般的には、これを使わずに、耐久性のためにリプリケーションを使い、オペレーティングシステムのバックグラウンドフラッシュ機能のほうがもっと効率的なためそれにさせることをお勧めします。この設定はトピック毎ベースで上書きすることができます(トピック毎の設定の章を見てください)。

  Type:	long
  デフォルト:	9223372036854775807
  有効な値:	[0,...]
  サーバのデフォルトのプロパティ:	log.flush.interval.messages
  重要:	medium

• flush.ms

  この設定はログに書かれるデータのfsyncを強制する時間を指定することができます。例えば、これが1000に設定された場合、1000ms過ぎた後でfsyncするでしょう。一般的には、これを使わずに、耐久性のためにリプリケーションを使い、オペレーティングシステムのバックグラウンドフラッシュ機能のほうがもっと効率的なためそれにさせることをお勧めします。

  Type:	long
  デフォルト:	9223372036854775807
  有効な値:	[0,...]
  サーバのデフォルトのプロパティ:	log.flush.interval.ms
  重要:	medium

• follower.replication.throttled.replicas

  ログのリプリケーションがフォロワー側で絞られなければならないレプリカのリスト。リストは [PartitionId]:[BrokerId],[PartitionId]:[BrokerId]:... の形式のレプリカのセットを表さなければなりません。あるいはこのトピックについての全てのレプリカを絞るためにワイルドカード '*' を使うことができます。

  Type:	list
  デフォルト:	""
  有効な値:	[partitionId]:[brokerId],[partitionId]:[brokerId],...
  サーバのデフォルトのプロパティ:	follower.replication.throttled.replicas
  重要:	medium

• index.interval.bytes

  この設定はKafkaがオフセットインデックスにエントリを追加する頻度を制御します。デフォルトの設定はおおよそ各4096バイトごとにメッセージをインデックスすることを保証します。もっとインデックスを増やすことでログの正確な場所の近くに読み込みをジャンプすることができますが、インデックスが大きくなります。おそらくこれを変更する必要はないでしょう。

  Type:	ｄint
  デフォルト:	4096 (4 kibibytes)
  有効な値:	[0,...]
  サーバのデフォルトのプロパティ:	log.index.interval.bytes
  重要:	medium

• leader.replication.throttled.replicas

  ログのリプリケーションがリーダー側で絞られなければならないレプリカのリスト。リストは [PartitionId]:[BrokerId],[PartitionId]:[BrokerId]:... の形式のレプリカのセットを表さなければなりません。あるいはこのトピックについての全てのレプリカを絞るためにワイルドカード '*' を使うことができます。

  Type:	list
  デフォルト:	""
  有効な値:	[partitionId]:[brokerId],[partitionId]:[brokerId],...
  サーバのデフォルトのプロパティ:	leader.replication.throttled.replicas
  重要:	medium

• max.compaction.lag.ms

  メッセージがログで圧縮の対象外となる最大時間。圧縮されているログについてのみ適用可能です。

  Type:	long
  デフォルト:	9223372036854775807
  有効な値:	[1,...]
  サーバのデフォルトのプロパティ:	log.cleaner.max.compaction.lag.ms
  重要:	medium

• max.message.bytes

  Kafkaで可能な最も大きなレコードのバッチサイズ (圧縮が有効な場合は圧縮後)。これが増え、0.10.2より古いコンシューマがある場合、コンシューマがこの大きさのレコードバッチを取得できるようにコンシューマの取得サイズも増やす必要があります。最新のメッセージフォーマットのバージョンでは、効率化のためにレコードは常にバッチにグループ化されます。以前のメッセージフォーマットのバージョンでは、圧縮されていないレコードはバッチにグループ化されず、この制限は1つのレコードにのみ適用されます。

  Type:	ｄint
  デフォルト:	1048588
  有効な値:	[0,...]
  サーバのデフォルトのプロパティ:	message.max.bytes
  重要:	medium

• message.format.version

  ブローカーがログにメッセージを追加する時に使うメッセージフォーマットを指定します。値は有効なApiVersionでなければなりません。いくつかの例: 0.8.2, 0.9.0.0, 0.10.0, 詳細はApiVersionを調べてください。特定のメッセージフォーマットバージョンを指定することで、ユーザはディスク上の既存の全てのメッセージが指定のバージョン以下であることを保証します。この値を間違って設定すると、古いバージョンのコンシューマが理解できないフォーマットを使ってメッセージを受信するため、それらは壊してしまうでしょう。

  Type:	文字列
  デフォルト:	2.7-IV2
  有効な値:	[0.8.0, 0.8.1, 0.8.2, 0.9.0, 0.10.0-IV0, 0.10.0-IV1, 0.10.1-IV0, 0.10.1-IV1, 0.10.1-IV2, 0.10.2-IV0, 0.11.0-IV0, 0.11.0-IV1, 0.11.0-IV2, 1.0-IV0, 1.1-IV0, 2.0-IV0, 2.0-IV1, 2.1-IV0, 2.1-IV1, 2.1-IV2, 2.2-IV0, 2.2-IV1, 2.3-IV0, 2.3-IV1, 2.4-IV0, 2.4-IV1, 2.5-IV0, 2.6-IV0, 2.7-IV0, 2.7-IV1, 2.7-IV2]
  サーバのデフォルトのプロパティ:	log.message.format.version
  重要:	medium

• message.timestamp.difference.max.ms

  ブローカーがメッセージを付け取った時のタイムスタンプと、その中で指定されたタイムスタンプとの間で許される最大の差異。message.timestamp.type=CreateTime であれば、タイムスタンプの違いがこの閾値を超えた場合にメッセージは却下されるでしょう。もし message.timestamp.type=LogAppendTime であれば、この設定は無視されます。

  Type:	long
  デフォルト:	9223372036854775807
  有効な値:	[0,...]
  サーバのデフォルトのプロパティ:	log.message.timestamp.difference.max.ms
  重要:	medium

• message.timestamp.type

  メッセージ内のタイムスタンプが、メッセージが生成された時間か、ログが追加された時間かどうかを定義します。値は `CreateTime` あるいは `LogAppendTime` のどちらかでなければなりません。

  Type:	文字列
  デフォルト:	CreateTime
  有効な値:	[CreateTime, LogAppendTime]
  サーバのデフォルトのプロパティ:	log.message.timestamp.type
  重要:	medium

• min.cleanable.dirty.ratio

  この設定はログの圧縮機がログを掃除しようとする頻度を制御します(log compaction が有効であると仮定)。デフォルトでは、ログの50%以上がコンパクト化された場所にあるログを掃除することを避けるでしょう。この率はデュープリケートによってログ内で消費される領域の最大を制限します(50%ではログの最大50%がデュープリケートされるかも知れません)。率を高くすることは、より少なく、より効率的な掃除を意味しますが、ログ内のより多くの消費される領域を意味するでしょう。max.compaction.lag.ms または the min.compaction.lag.ms 設定も指定されている場合、ログの圧縮器は次のいずれかですぐにログを圧縮できると見なします: (i) 少なくとも min.compaction.lag.ms の間、ダーティ率の閾値に達し、ログにダーティ (非圧縮) のレコードがあった、または (ii) ログにダーティ (非圧縮) レコードが最大で max.compaction.lag.ms の間あった。

  Type:	double
  デフォルト:	0.5
  有効な値:	[0,...,1]
  サーバのデフォルトのプロパティ:	log.cleaner.min.cleanable.ratio
  重要:	medium

• min.compaction.lag.ms

  メッセージがログ内で圧縮されずにいる最小時間。圧縮されているログについてのみ適用可能です。

  Type:	long
  デフォルト:	0
  有効な値:	[0,...]
  サーバのデフォルトのプロパティ:	log.cleaner.min.compaction.lag.ms
  重要:	medium

• min.insync.replicas

  プロデューサがackを "all" (あるいは "-1") に設定する場合、この設定は書き込みが成功したと見なされるように書き込みを知らせる必要があるレプリカの最小数を指定します。この最小限に一致しない場合、プロデューサは例外(NotEnoughReplicas あるいは NotEnoughReplicasAfterAppendのどちらか)を上げるでしょう。
  一緒に使った場合、min.insync.replicas と acksは素晴らしい耐久性の保証を強化することができます。典型的なシナリオは、3つのレプリケーション ファクターを持つトピックを生成し、min.insync.replicas を 2 に設定し、"all" のacksを使って生成します。これは、もしレプリカの過半数が書き込みを受け取らなかった場合にプロデューサが例外を上げることを保証するでしょう。

  Type:	ｄint
  デフォルト:	1
  有効な値:	[1,...]
  サーバのデフォルトのプロパティ:	min.insync.replicas
  重要:	medium

• preallocate

  新しいログのセグメントを生成する時にディスク上にファイルをあらかじめ割り当てる必要がある場合はTrue。

  Type:	boolean
  デフォルト:	false
  有効な値:
  サーバのデフォルトのプロパティ:	log.preallocate
  重要:	medium

• retention.bytes

  この設定は、"delete" 維持ポリシーを使う場合は空間を解放するために古いログのセグメントを削除する前までのパーティション(ログのセグメントからなります)が成長する最大のサイズを制御します。デフォルトでは時間の制限だけでサイズの制限はありません。この制限はパーティションレベルで強制されるため、トピックの維持をバイトで計算するにはそれにパーティションの数を掛けてください。

  Type:	long
  デフォルト:	-1
  有効な値:
  サーバのデフォルトのプロパティ:	log.retention.bytes
  重要:	medium

• retention.ms

  この設定は、"delete" 維持ポリシーを使う場合は空間を解放するために古いログのセグメントを削除する前にログを保持するだろう最大の時間を制御します。これはコンシューマがデータをどれだけ早く読まなければならないかのSLAを表します。-1に設定される場合、時間の制限無しが適用されます。

  Type:	long
  デフォルト:	604800000 (7 日)
  有効な値:	[-1,...]
  サーバのデフォルトのプロパティ:	log.retention.ms
  重要:	medium

• segment.bytes

  この設定はログのためのセグメントファイルサイズを制御します。維持と掃除は常にファイルに一度に行われます。つまり、大きなセグメントサイズは少ないファイルを意味しますが、維持の制御の粒度が小さくなります。

  Type:	ｄint
  デフォルト:	1073741824 (1 gibibyte)
  有効な値:	[14,...]
  サーバのデフォルトのプロパティ:	log.segment.bytes
  重要:	medium

• segment.index.bytes

  この設定はオフセットをファイルの場所にマップするインデックスのサイズを制御します。このインデックスファイルはあらかじめ割り当てられていて、ログがロールした後でのみ縮小されます。通常この設定を変更する必要はありません。

  Type:	ｄint
  デフォルト:	10485760 (10 mebibytes)
  有効な値:	[0,...]
  サーバのデフォルトのプロパティ:	log.index.size.max.bytes
  重要:	medium

• segment.jitter.ms

  立て続けのセグメントのローリングを避けるためにスケジュールされたセグメントロール時間から引かれるランダムなズレの最大

  Type:	long
  デフォルト:	0
  有効な値:	[0,...]
  サーバのデフォルトのプロパティ:	log.roll.jitter.ms
  重要:	medium

• segment.ms

  この設定は、保持の仕組みが古いデータを削除あるいは圧縮できるように、セグメントファイルが一杯では無い場合でもKafkaがログをロールするまでの時間を制御します。

  Type:	long
  デフォルト:	604800000 (7 日)
  有効な値:	[1,...]
  サーバのデフォルトのプロパティ:	log.roll.ms
  重要:	medium

• unclean.leader.election.enable

  データの喪失に繋がるとしても、最後の手段としてリーダーとして選出されるように設定されたISRに無いレプリカを有効にするかどうかを示す。

  Type:	boolean
  デフォルト:	false
  有効な値:
  サーバのデフォルトのプロパティ:	unclean.leader.election.enable
  重要:	medium

• message.downconversion.enable

  この設定はコンシューマのリクエストを満たすためにメッセージ形式のダウン-コンバージョンが有効にされるかどうかを制御します。falseに設定された場合、ブローカーは古いメッセージ形式を期待するコンシューマのためのダウン-コンバージョンを行わないでしょう。そのような古いクライアントからのコンシューマリクエストについては、ブローカーはUNSUPPORTED_VERSION エラーで応答します。この設定はフォロワーへのレプリケーションに必要とされるかもしれないメッセージ形式の変換に適用されません。

  Type:	boolean
  デフォルト:	true
  有効な値:
  サーバのデフォルトのプロパティ:	log.message.downconversion.enable
  重要:	low

3.3プロデューサの設定

• key.serializer

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

  Type:	クラス
  デフォルト:
  有効な値:
  重要:	high

• value.serializer

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

  Type:	クラス
  デフォルト:
  有効な値:
  重要:	high

• acks

  リクエストが完了したと見なす前にリーダーが受け取ることをプロデューサが要求する通知の数。これは送信されたレコードの持続性を制御します。以下の設定が可能です:

  • acks=0 0に設定されるとプロデューサはサーバからの承認を全く待たないでしょう。レコードはすぐにソケットバッファに追加され、送信されたものと見なされます。この場合サーバがレコードを受け取ったかどうかの保証はできません。そしてretries 設定は効果が無いでしょう (クライアントは一般的に障害を知らないため)。各レコードについて返されるオフセットは常に -1 に設定されるでしょう。
  • acks=1 これは、リーダーはレコードをローカルログに書き込むが、すべてのフォロワーからの完全な応答を待たずに応答するでしょう。この場合、リーダは通知の直後でフォロワーがリプリケートする前に失敗すべきで、その後レコードが喪失するでしょう。
  • acks=all これは、リーダーはレコードに応答するためにin-syncレプリカの完全なセットを待つだろうことを意味します。これは、少なくとも1つのin-syncレプリカが生きている限りレコードは失われないだろうことを保証します。これはもっとも強力な利用可能な保証です。これは acks=-1 設定と同じです。

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

• bootstrap.servers

  Kafkaクラスタへの初期の接続を確立するために使うホスト/ポートのペアのリスト。クライアントはブートストラッピングのためにここでどのサーバが指定されたかに関わらず全てのサーバを利用するでしょう — このリストはサーバの完全なセットを見つけるために使われる初期のホストにのみ影響を与えます。このリストはhost1:port1,host2:port2,...の形式でなければなりません。これらのサーバは完全なクラスタの会員(動的に変わるかも知れません)を見つけるための初期接続に使われるため、このリストはサーバの完全なセットを含む必要はありません (しかし、サーバがダウンした場合のために1つ以上が望まれるかも知れません)。

  Type:	list
  デフォルト:	""
  有効な値:	non-null string
  重要:	high

• buffer.memory

  プロデューサがサーバに送られるのを待っているレコードをバッファするために使うことができるメモリの総バイト数。サーバに配送することができるより早くレコードが送信された場合、プロデューサは例外を投げた後で max.block.ms の間ブロックするでしょう。

  この設定は大まかにプロデューサが利用しようとする総メモリに対応しますが、プロデューサが使用する全てのメモリがバッファリングに使われるわけではないためハードバウンドではありません。いくつかの追加のメモリが圧縮(圧縮が有効な場合)と、やってきているリクエストを保持するために使われるでしょう。

  Type:	long
  デフォルト:	33554432
  有効な値:	[0,...]
  重要:	high

• compression.type

  プロデューサによって生成された全てのデータのための圧縮タイプ。デフォルトは none (つまり、非圧縮)。有効な値は、none, gzip, snappy, lz4 あるいは zstd です。圧縮はデータの完全なバッチです。つまりバッチの効果は圧縮率にも影響するでしょう (多くのバッチ化はより良い圧縮を意味します)。

  Type:	文字列
  デフォルト:	none
  有効な値:
  重要:	high

• retries

  0より大きい値を設定すると、クライアントは一時的なエラーによる障害による送信の全てのレコードを再送信するでしょう。この再試行はクライアントがエラーを受け取る時にレコードを再送するのと変わらないことに注意してください。max.in.flight.requests.per.connection を1に設定せずに再試行を許すと、もし2つのバッチが1つのパーティションに送信され、最初が失敗して2つ目が成功したが再試行し、2つ目のバッチのレコードが最初に現れるかもしれないため、レコードの順番が変わるかもしれません。さらに、delivery.timeout.msで設定されるタイムアウトが正常に確認される前に期限切れになる場合、再試行の回数を使い果たす前に生成のリクエストが失敗することに注意してください。ユーザは通常この設定を未設定のままにしておき、代わりに再試行の挙動を制御するためにdelivery.timeout.msを使うことをお勧めします。

  Type:	ｄint
  デフォルト:	2147483647
  有効な値:	[0,...,2147483647]
  重要:	high

• ssl.key.password

  The password of the private key in the key store file orthe PEM key specified in `ssl.keystore.key'. This is required for clients only if two-way authentication is configured.

  Type:	password
  デフォルト:	null
  有効な値:
  重要:	high

• ssl.keystore.certificate.chain

  Certificate chain in the format specified by 'ssl.keystore.type'. Default SSL engine factory supports only PEM format with a list of X.509 certificates

  Type:	password
  デフォルト:	null
  有効な値:
  重要:	high

• ssl.keystore.key

  Private key in the format specified by 'ssl.keystore.type'. Default SSL engine factory supports only PEM format with PKCS#8 keys. If the key is encrypted, key password must be specified using 'ssl.key.password'

  Type:	password
  デフォルト:	null
  有効な値:
  重要:	high

• ssl.keystore.location

  キーストアーファイルの場所。これはクライアントについては任意で、クライアントのための相互認証のために使うことができます。

  Type:	文字列
  デフォルト:	null
  有効な値:
  重要:	high

• ssl.keystore.password

  キーストアーファイルのためのストアパスワード。This is optional for client and only needed if 'ssl.keystore.location' is configured. Key store password is not supported for PEM format.

  Type:	password
  デフォルト:	null
  有効な値:
  重要:	high

• ssl.truststore.certificates

  Trusted certificates in the format specified by 'ssl.truststore.type'. Default SSL engine factory supports only PEM format with X.509 certificates.

  Type:	password
  デフォルト:	null
  有効な値:
  重要:	high

• ssl.truststore.location

  トラストストアーファイルの場所。

  Type:	文字列
  デフォルト:	null
  有効な値:
  重要:	high

• ssl.truststore.password

  トラストストアーファイルのパスワード。If a password is not set, trust store file configured will still be used, but integrity checking is disabled. Trust store password is not supported for PEM format.

  Type:	password
  デフォルト:	null
  有効な値:
  重要:	high

• batch.size

  多数のレコードが同じパーティションに送信される時はいつもプロデューサはバッチのレコードをより少ないリクエストにまとめようとするでしょう。これはクライアントとサーバの両方でパフォーマンスを助けます。この設定はデフォルトのバッチサイズをバイトで制御します。

  このサイズより大きいバッチレコードには何も試行されないでしょう。

  ブローカーに送信されるリクエストは複数のバッチを含むでしょう。各パーティションについて1つの送信することが可能なデータを持つバッチです。

  小さなバッチサイズはバッチ化を一般的でなくし、スループットを下げるかもしれません(バッチサイズ 0はバッチ化を完全に無効にするでしょう)。大きなバッチサイズは追加のレコードに備えて指定されたバッチサイズのバッチを常に割り当てるため、メモリを幾分贅沢に使うかもしれません。

  Type:	ｄint
  デフォルト:	16384
  有効な値:	[0,...]
  重要:	medium

• client.dns.lookup

  クライアントがどのようにDNSルックアップを使うかを制御します。use_all_dns_ips に設定された場合、正常な接続が確立されるまで、返された各 IP アドレスに順番に接続します。切断後に、次の IP が使われます。全ての IP が一度使われると、クライアントはホスト名から IP を再度解決します (ただし、JVM と OS の両方が DNS 名のルックアップをキャッシュします)。resolve_canonical_bootstrap_servers_only に設定されると、各ブートストラップアドレスを正規の名前のリストに解決します。ブートストラップの段階の後で、これは use_all_dns_ips と同じように動作します。default (非推奨)に設定されると、ルックアップが複数の IP アドレスを返す場合でも、ルックアップで返された最初の IP アドレスに接続しようとします。

  Type:	文字列
  デフォルト:	use_all_dns_ips
  有効な値:	[default, use_all_dns_ips, resolve_canonical_bootstrap_servers_only]
  重要:	medium

• client.id

  リクエストする時にサーバに渡されるid文字列。これの目的は、サーバ側のリクエストのログに論理アプリケーション名を追加することで、ip/portを超えたリクエストのソースの追跡をすることです。

  Type:	文字列
  デフォルト:	""
  有効な値:
  重要:	medium

• connections.max.idle.ms

  この設定によって指定されるミリ秒後にアイドルの接続を閉じます。

  Type:	long
  デフォルト:	540000 (9 分)
  有効な値:
  重要:	medium

• delivery.timeout.ms

  send() の呼び出しが返された後、成功または失敗を報告する時間の上限。これは、送信前にレコードが遅延する合計時間、ブローカーからの確認応答を待機する時間(予想される場合)、そして再試行可能な送信障害に許可される時間を制限します。プロデューサは、回復不可能なエラーが発生した場合、再試行が使い果たされた場合、あるいはレコードが以前の配送有効期限に達したバッチに追加された場合に、この設定よりも前にレコードを送信できないことを報告するかもしれません。この設定の値は、request.timeout.ms と linger.ms の合計以上にする必要があります。

  Type:	ｄint
  デフォルト:	120000 (2 minutes)
  有効な値:	[0,...]
  重要:	medium

• linger.ms

  プロデューサグループはリクエストの転送間に到着した全てのレコードを1つのバッチリクエストにまとめます。通常、これはレコードが送信できるように早く到着した時に負荷を受けてのみ起こります。しかし、ある状況では、クライアントは控えめな負荷の場合でもリクエストの数を減らしたいと思うかも知れません。この設定は少しの人為的な遅延によってこれを成し遂げます - つまり、すぐにレコードを送信するのではなく、プロデューサは一緒にバッチ化されることができるように他のレコードが送信されるように指定された遅延まで待つでしょう。これはTCPでのNagleアルゴリズムへの相似として考えることができます。この設定ではバッチ処理の遅延の上限が与えられます: パーティションについて一旦batch.size分のレコードを取得すると、それはこの設定に関係なく即座に送信されるでしょう。しかしもしこのパーティションについて集約されたバイトがこれより少ない場合、より多くのレコードが現れるまで指定された時間だけ'残る'でしょう。この設定のデフォルトは 0 です (つまり、遅延はありません)。例えば、linger.ms=5に設定すると、送信されるリクエストの数を減らす効果がありますが、負荷が無い時にレコードの送信に5msのレイテンシを追加するでしょう。

  Type:	long
  デフォルト:	0
  有効な値:	[0,...]
  重要:	medium

• max.block.ms

  The configuration controls how long the KafkaProducer's send(), partitionsFor(), initTransactions(), sendOffsetsToTransaction(), commitTransaction() and abortTransaction() methods will block. For send() this timeout bounds the total time waiting for both metadata fetch and buffer allocation (blocking in the user-supplied serializers or partitioner is not counted against this timeout). For partitionsFor() this timeout bounds the time spent waiting for metadata if it is unavailable. The transaction-related methods always block, but may timeout if the transaction coordinator could not be discovered or did not respond within the timeout.

  Type:	long
  デフォルト:	60000 (1 分)
  有効な値:	[0,...]
  重要:	medium

• max.request.size

  リクエストの最大バイトサイズ。この設定は大きなリクエストを送信することを避けるためにプロデューサが1つのリクエスト内で送信するレコードのバッチの数を制限するでしょう。これは未圧縮の最大レコードバッチサイズの効果的なキャップでもあります。サーバはこれとは異なるかも知れないレコードバッチサイズ(圧縮が有効な場合は圧縮後)上の独自のキャップを持つことに注意してください。

  Type:	ｄint
  デフォルト:	1048576
  有効な値:	[0,...]
  重要:	medium

• partitioner.class

  org.apache.kafka.clients.producer.Partitioner インタフェースを実装するパーティショナークラス。

  Type:	クラス
  デフォルト:	org.apache.kafka.clients.producer.internals.DefaultPartitioner
  有効な値:
  重要:	medium

• receive.buffer.bytes

  データを読み込む時に使われるTCPレシーバーバッファ (SO_RCVBUF) のサイズ。値が -1 であれば、OSのデフォルトが使われるでしょう。

  Type:	ｄint
  デフォルト:	32768 (32 kibibytes)
  有効な値:	[-1,...]
  重要:	medium

• request.timeout.ms

  この設定はクライアントがリクエストの応答を待つ総時間の最大を制御します。タイムアウトの時間が経過する前に応答が受信されない場合は、必要であればクライアントはリクエストを再送信するでしょう。あるいは再試行が使い尽くされた場合は失敗するでしょう。不必要なプロデューサの再試行によるメッセージの重複の可能性を減らすために、これは replica.lag.time.max.ms (ブローカーの設定) より大きくなければなりません。

  Type:	ｄint
  デフォルト:	30000 (30 秒)
  有効な値:	[0,...]
  重要:	medium

• sasl.client.callback.handler.class

  AuthenticateCallbackHandler インタフェースを実装するSASLクライアント コールバック ハンドラ クラスの完全修飾名。

  Type:	クラス
  デフォルト:	null
  有効な値:
  重要:	medium

• sasl.jaas.config

  JAAS設定ファイル内で使われる形式のSASL接続のためのJAAS login コンテキスト パラメータ。JAAS 設定ファイルのフォーマットはここで説明されます。値の形式は: 'loginModuleClass controlFlag (optionName=optionValue)*;'。ブローカーについては、設定はlistenerのプリフィックスを前に付ける必要があり、SASL機構名は小文字でなければなりません。例えば、listener.name.sasl_ssl.scram-sha-256.sasl.jaas.config=com.example.ScramLoginModule が必要です;

  Type:	password
  デフォルト:	null
  有効な値:
  重要:	medium

• sasl.kerberos.service.name

  Kafkaが実行するKerbrosプリンシパル名。これはKafkaのJAAS設定あるいはKafkaの設定のどちらかで定義することができます。

  Type:	文字列
  デフォルト:	null
  有効な値:
  重要:	medium

• sasl.login.callback.handler.class

  AuthenticateCallbackHandler インタフェースを実装するSASL ログイン コールバック ハンドラ クラスの完全修飾名。ブローカーについては、ログインのコールバックハンドラ設定はlistenerのプリフィックスを前に付ける必要があり、SASL機構名は小文字でなければなりません。例えば、listener.name.sasl_ssl.scram-sha-256.sasl.login.callback.handler.class=com.example.CustomScramLoginCallbackHandler

  Type:	クラス
  デフォルト:	null
  有効な値:
  重要:	medium

• sasl.login.class

  Loginインタフェースを実装するクラスの完全修飾名。ブローカーについては、ログイン設定はlistenerのプリフィックスを前に付ける必要があり、SASL機構名は小文字でなければなりません。例えば、listener.name.sasl_ssl.scram-sha-256.sasl.login.class=com.example.CustomScramLogin

  Type:	クラス
  デフォルト:	null
  有効な値:
  重要:	medium

• sasl.mechanism

  クライアント接続で使われるSASL機構。これはセキュリティプロバイダが利用可能な全ての機構です。GSSAPI がデフォルトの機構です。

  Type:	文字列
  デフォルト:	GSSAPI
  有効な値:
  重要:	medium

• security.protocol

  ブローカーと通信するために使われるプロトコル。有効な値は: PLAINTEXT, SSL, SASL_PLAINTEXT, SASL_SSL。

  Type:	文字列
  デフォルト:	PLAINTEXT
  有効な値:
  重要:	medium

• send.buffer.bytes

  データを送信する時に使われるTCP送信バッファ (SO_SNDBUF)のサイズ。値が -1 であれば、OSのデフォルトが使われるでしょう。

  Type:	ｄint
  デフォルト:	131072 (128 kibibytes)
  有効な値:	[-1,...]
  重要:	medium

• socket.connection.setup.timeout.max.ms

  The maximum amount of time the client will wait for the socket connection to be established. The connection setup timeout will increase exponentially for each consecutive connection failure up to this maximum. To avoid connection storms, a randomization factor of 0.2 will be applied to the timeout resulting in a random range between 20% below and 20% above the computed value.

  Type:	long
  デフォルト:	127000 (127 seconds)
  有効な値:
  重要:	medium

• socket.connection.setup.timeout.ms

  The amount of time the client will wait for the socket connection to be established. If the connection is not built before the timeout elapses, clients will close the socket channel.

  Type:	long
  デフォルト:	10000 (10 秒)
  有効な値:
  重要:	medium

• ssl.enabled.protocols

  SSL接続のために有効にされるプロトコルのリスト。デフォルトは、Java 11以降で実行する場合は 'TLSv1.2,TLSv1.3'、それ以外の場合は、'TLSv1.2' です。Java 11 のデフォルト値では、クライアントとサーバはどちらもサポートする場合は TLSv1.3 を優先し、そうでない場合は TLSv1.2 にフォールバックしますjj(両方が少なくと TLSv1.2 をサポートする場合)。このデフォルトはほとんどの場合で十分です。`ssl.protocol` の設定ドキュメントも見てください。

  Type:	list
  デフォルト:	TLSv1.2
  有効な値:
  重要:	medium

• ssl.keystore.type

  キーストアファイルのファイル形式。これはクライアントについては任意です。

  Type:	文字列
  デフォルト:	JKS
  有効な値:
  重要:	medium

• ssl.protocol

  SSLContextを生成するために使われるSSLプロトコル。デフォルトは、Java 11以降で実行する場合は 'TLSv1.3'、それ以外の場合は、'TLSv1.2' です。この値はほとんどの使い方で十分です。最近の JVM での許容れる値は、'TLSv1.2' と 'TLSv1.3' です。'TLS'、'TLSv1.1'、'SSL'、'SSLv2'、'SSLv3' は古いJVMではサポートされるかも知れませんが、これらの使用は既知のセキュリティ脆弱性のため推奨されません。この構成のデフォルト値と 'ssl.enabled.protocols' では、サーバが 'TLSv1.3' をサポートしない場合は、クライアントは 'TLSv1.2' にダウングレードします。この構成が 'TLSv1.2' に設定されている場合、ssl.enabled.protocols の値のうちの1つで、サーバが 'TLSv1.3' だけをサポートする場合でも、クライアントは 'TLSv1.3' を使いません。

  Type:	文字列
  デフォルト:	TLSv1.2
  有効な値:
  重要:	medium

• ssl.provider

  SSL接続のために使われるセキュリティプロバイダの名前。デフォルト値はJVMのデフォルトのセキュリティプロバイダです。

  Type:	文字列
  デフォルト:	null
  有効な値:
  重要:	medium

• ssl.truststore.type

  トラストストアファイルのファイル形式。

  Type:	文字列
  デフォルト:	JKS
  有効な値:
  重要:	medium

• enable.idempotence

  'true' に設定されると、プロデューサは各メッセージの確実に1回のコピーがストリームに書かれることを保証するでしょう。'false' の場合、プロデューサはブローカーの障害などによる再試行でストリーム内に再試行のメッセージの重複を書き込むかもしれません。等冪を有効にするには max.in.flight.requests.per.connection を5以下に設定する必要があり、retries は0より大きく、acksは 'all' でなければならないことに注意してください。これらの値がユーザによって明示的に設定されない場合、適切な値が選択されるでしょう。互換性の無い値が設定された場合、ConfigException が投げられるでしょう。

  Type:	boolean
  デフォルト:	false
  有効な値:
  重要:	low

• interceptor.classes

  インタセプタとして使われるクラスのリスト。org.apache.kafka.clients.producer.ProducerInterceptor インタフェースの実装により、Kafkaクラスタに発行される前にプロデューサによって受け取られるレコードを捉え(そしておそらく変化す)ることができます。デフォルトでは、インタセプタはありません。

  Type:	list
  デフォルト:	""
  有効な値:	non-null string
  重要:	low

• max.in.flight.requests.per.connection

  クライアントがブロックされる前に1つの接続上で送信するだろう、返事の無いリクエストの最大数。この設定が1より大きく設定され、失敗した送信がある場合は、再試行(つまり、再試行が有効な場合)により、メッセージの再注文の可能性があります。

  Type:	ｄint
  デフォルト:	5
  有効な値:	[1,...]
  重要:	low

• metadata.max.age.ms

  パーティションのリーダーシップが新しいブローカーあるいはパーティションを前もって見つけるために変更されたのを見ていないとしても、メタデータのリフレッシュを強制するミリ秒単位の時間。

  Type:	long
  デフォルト:	300000 (5 分)
  有効な値:	[0,...]
  重要:	low

• metadata.max.idle.ms

  プロデューサがアイドル状態のトピックのメタデータをキャッシュする期間を制御します。トピックが最後に生成されてからの経過時間がメタデータのアイドル時間を超えた場合、トピックのメタデータは忘れられ、次のアクセスによりメタデータフェッチリクエストが強制されます。

  Type:	long
  デフォルト:	300000 (5 分)
  有効な値:	[5000,...]
  重要:	low

• metric.reporters

  メトリクス レポーターとして使われるクラスのリスト。org.apache.kafka.common.metrics.MetricsReporter インタフェースの実装により、新しいメトリックの生成を知らせるクラスをプラグインすることができます。JMX統計を登録するために常に JmxReporter が含まれます。

  Type:	list
  デフォルト:	""
  有効な値:	non-null string
  重要:	low

• metrics.num.samples

  メトリクスを計算するために保持される標本の数。

  Type:	ｄint
  デフォルト:	2
  有効な値:	[1,...]
  重要:	low

• metrics.recording.level

  メトリクスのための最も高い記録レベル。

  Type:	文字列
  デフォルト:	INFO
  有効な値:	[INFO, DEBUG, TRACE]
  重要:	low

• metrics.sample.window.ms

  メトリクスの標本が計算されるための時間の窓。

  Type:	long
  デフォルト:	30000 (30 秒)
  有効な値:	[0,...]
  重要:	low

• reconnect.backoff.max.ms

  接続が繰り返し失敗するブローカーへの再接続時に待つミリ秒単位の総最大時間。指定された場合、ホスト毎のバックオフはそれぞれの連続する失敗ごとにこの最大まで指数関数的に増加するでしょう。バックオフの計算を増加した後で、接続の嵐を避けるために20%のランダムなジッターが追加されます。

  Type:	long
  デフォルト:	1000 (1 秒)
  有効な値:	[0,...]
  重要:	low

• reconnect.backoff.ms

  指定されたホストに再接続しようとするまで待機する基本的な総時間。これにより短いループ内でホストに繰り返し接続することを防ぎます。このbackoffはクライアントによってブローカーに送信される全ての接続に適用されます。

  Type:	long
  デフォルト:	50
  有効な値:	[0,...]
  重要:	low

• retry.backoff.ms

  指定されたトピックパーティションへの失敗したリクエストを再試行しようとするまで待機する総時間。これにより短いループ内で幾つかの失敗のシナリオがある場合に繰り返しリクエストすることを防ぎます。

  Type:	long
  デフォルト:	100
  有効な値:	[0,...]
  重要:	low

• sasl.kerberos.kinit.cmd

  Kerberos kinit コマンドライン パス。

  Type:	文字列
  デフォルト:	/usr/bin/kinit
  有効な値:
  重要:	low

• sasl.kerberos.min.time.before.relogin

  リフレッシュ試行間のログインスレッドのスリープ時間。

  Type:	long
  デフォルト:	60000
  有効な値:
  重要:	low

• sasl.kerberos.ticket.renew.jitter

  更新時間に追加されるランダムなジッターのパーセンテージ。

  Type:	double
  デフォルト:	0.05
  有効な値:
  重要:	low

• sasl.kerberos.ticket.renew.window.factor

  最後にリフレッシュされてからチケットの期限切れまでの時間が指定されたウィンドウ要素になるまで、ログインスレッドはスリープします。そしてその時間にチケットを更新しようとするでしょう。

  Type:	double
  デフォルト:	0.8
  有効な値:
  重要:	low

• sasl.login.refresh.buffer.seconds

  証明書をリフレッシュする時に証明書の有効期限を維持するバッファ時間の秒数。そうでなければ、バッファの秒数よりも有効期限の近くで更新が発生する場合、可能な限り多くのバッファ時間を維持するために、更新が上に移動されます。有効な値は0から3600(1時間); 値が指定されない場合はデフォルトの値 300 (5分)が使われます。この値と sasl.login.refresh.min.period.seconds は、もしそれらの合計が証明書の残りの生存期間を超える場合に両方とも無視されます。現在のところは OAUTHBEARER にのみ適用されます。

  Type:	short
  デフォルト:	300
  有効な値:	[0,...,3600]
  重要:	low

• sasl.login.refresh.min.period.seconds

  証明書をリフレッシュする前にログイン フレッシュ スレッドが待つ望ましい最小の時間の秒数。有効な値は0から900 (15分); 値が指定されない場合はデフォルトの値60(1分)が使われます。この値と sasl.login.refresh.buffer.seconds は、もしそれらの合計が証明書の残りの生存期間を超える場合に両方とも無視されます。現在のところは OAUTHBEARER にのみ適用されます。

  Type:	short
  デフォルト:	60
  有効な値:	[0,...,900]
  重要:	low

• sasl.login.refresh.window.factor

  ログイン フレッシュ スレッドは、証明書の生存期間に関連した指定されたウィンドウ ファクタに達するまでスリープしようとします。その時点で証明書をリフレッシュしようとするでしょう。有効な値は0.5 (50%)以上と1.0 (100%)以下の間です; 値が指定されない場合はデフォルトの値 0.8 (80%)が使われます。現在のところは OAUTHBEARER にのみ適用されます。

  Type:	double
  デフォルト:	0.8
  有効な値:	[0.5,...,1.0]
  重要:	low

• sasl.login.refresh.window.jitter

  ログイン スレッドのスリープ時間に追加された証明書の生存期間に対するランダム ジッタの最大量。有効な値は 0以上と0.25 (25%)以下の間です; 値が指定されない場合はデフォルトの値 0.05 (5%) が使われます。現在のところは OAUTHBEARER にのみ適用されます。

  Type:	double
  デフォルト:	0.05
  有効な値:	[0.0,...,0.25]
  重要:	low

• security.providers

  セキュリティアルゴリズムを実装するプロバイダをそれぞれ返す構成可能なクリエイタクラスのリスト。これらのクラスは、org.apache.kafka.common.security.auth.SecurityProviderCreator インスタンスを実装しなければなりません。

  Type:	文字列
  デフォルト:	null
  有効な値:
  重要:	low

• ssl.cipher.suites

  cipher スイーツのリストこれはTLSあるいはSSLネットワークプロトコルを使うネットワーク接続のためのセキュリティ設定を取り決めるために使われる、認証、暗号化、MACおよびキー交換アルゴリズムの名前の組み合わせです。デフォルトでは全ての利用可能なcipherスイーツがサポートされます。

  Type:	list
  デフォルト:	null
  有効な値:
  重要:	low

• ssl.endpoint.identification.algorithm

  サーバの証明書を使ってサーバのホスト名を検証するためのエンドポイント識別アルゴリズム。

  Type:	文字列
  デフォルト:	https
  有効な値:
  重要:	low

• ssl.engine.factory.class

  SSLEngine オブジェクトを提供するための org.apache.kafka.common.security.auth.SslEngineFactory 型のクラス。デフォルト値は、org.apache.kafka.common.security.ssl.DefaultSslEngineFactory です

  Type:	クラス
  デフォルト:	null
  有効な値:
  重要:	low

• ssl.keymanager.algorithm

  SSL接続のためにキーマネージャーファクトリーによって使われるアルゴリズム。デフォルト値はJava仮想マシーンのために設定されたキーマネージャーファクトリーアルゴリズムです。

  Type:	文字列
  デフォルト:	SunX509
  有効な値:
  重要:	low

• ssl.secure.random.implementation

  SSL暗号化操作のために使われる SecureRandom PRNG 実装。

  Type:	文字列
  デフォルト:	null
  有効な値:
  重要:	low

• ssl.trustmanager.algorithm

  SSL接続のためにトラストマネージャーファクトリーによって使われるアルゴリズム。デフォルト値はJava仮想マシーンのために設定されトラストーマネージャーファクトリーアルゴリズムです。

  Type:	文字列
  デフォルト:	PKIX
  有効な値:
  重要:	low

• transaction.timeout.ms

  The maximum amount of time in ms that the transaction coordinator will wait for a transaction status update from the producer before proactively aborting the ongoing transaction.If this value is larger than the transaction.max.timeout.ms setting in the broker, the request will fail with a InvalidTxnTimeoutException error.

  Type:	ｄint
  デフォルト:	60000 (1 分)
  有効な値:
  重要:	low

• transactional.id

  トランザクションの配送のために使うTransactionalId。これは、クライアントに新しいトランザクションが開始される前に同じトランザクションidを使っているトランザクションを保証するため、複数のプロデューサセッションにまたがる信頼性セマンティクスを有効にします。TransactionalId が指定されない場合、プロデューサは等冪な配送に制限されます。TransactionalId が構成されている場合、enable.idempotence が暗黙指定されます。デフォルトでは、TransactionId は構成されていません。つまり、トランザクションは使われません。トランザクションはデフォルトでプロダクションのための設定に推奨される少なくとも3つのブローカーのクラスタを必要とすることに注意してください; 開発のためにブローカーの設定 transaction.state.log.replication.factorを調整することでこれを変更することができます。

  Type:	文字列
  デフォルト:	null
  有効な値:	空では無い文字列
  重要:	low

3.4コンシューマの設定

• key.deserializer

  org.apache.kafka.common.serialization.Deserializerインタフェースを実装するキーのためのDeserializerクラス。

  Type:	クラス
  デフォルト:
  有効な値:
  重要:	high

• value.deserializer

  org.apache.kafka.common.serialization.Deserializerインタフェースを実装する値のためのDeserializerクラス。

  Type:	クラス
  デフォルト:
  有効な値:
  重要:	high

• bootstrap.servers

  Kafkaクラスタへの初期の接続を確立するために使うホスト/ポートのペアのリスト。クライアントはブートストラッピングのためにここでどのサーバが指定されたかに関わらず全てのサーバを利用するでしょう — このリストはサーバの完全なセットを見つけるために使われる初期のホストにのみ影響を与えます。このリストはhost1:port1,host2:port2,...の形式でなければなりません。これらのサーバは完全なクラスタの会員(動的に変わるかも知れません)を見つけるための初期接続に使われるため、このリストはサーバの完全なセットを含む必要はありません (しかし、サーバがダウンした場合のために1つ以上が望まれるかも知れません)。

  Type:	list
  デフォルト:	""
  有効な値:	non-null string
  重要:	high

• fetch.min.bytes

  サーバが各フェッチリクエストについて返さなければならないデータの最小量。十分なデータが利用可能では無い場合、リクエストはリクエストに返答する前に多くのデータを集めるのを待つでしょう。デフォルトの設定の1バイトは、データの1バイトが利用可能、あるいはデータの到着を待っているフェッチリクエストがタイムアウトするとすぐにフェッチリクエストに応答することを意味します。これを1より大きいものに設定すると、データの大部分をサーバが待つようになり、ある程度の追加のレイテンシを犠牲にして少しだけサーバのスループットを改善するでしょう。

  Type:	ｄint
  デフォルト:	1
  有効な値:	[0,...]
  重要:	high

• group.id

  このコンシューマが所属するコンシューマグループを識別するユニークな文字列。このプロパティは、もしコンシューマがsubscribe(topic)を使ってグループの管理機能、あるいはKafkaベースのオフセットの管理戦略を使う場合に必須です。

  Type:	文字列
  デフォルト:	null
  有効な値:
  重要:	high

• heartbeat.interval.ms

  Kafkaのグループ管理機能を使う時に、コンシューマのコーディネータへのハートビート間に期待する時間。ハートビートはコンシューマのセッションが活動中であることを保証し、新しいコンシューマがグループに参加あるいは離れる時のリバランスを円滑にするために使われます。値はsession.timeout.msより小さくなければなりませんが、一般的にはその値の1/3より大きく設定されなければなりません。通常の再バランスについては、期待する時間を制御するために少し小さく調整されるかも知れません。

  Type:	ｄint
  デフォルト:	3000 (3 秒)
  有効な値:
  重要:	high

• max.partition.fetch.bytes

  サーバが返すパーティションあたりのデータの最大総量。レコードはコンシューマによってバッチ内で取得されます。取得の最初の空では無いパーティション内の最初のレコードバッチはこの制限よりも大きく、コンシューマが進めることができるようにバッチはまだ返されるでしょう。ブローカーに受け付けられる最大レコードバッチサイズは message.max.bytes (ブローカー設定) あるいは max.message.bytes (トピック設定) によって定義されます。コンシューマのリクエストサイズの制限については、fetch.max.bytes を見てください。

  Type:	ｄint
  デフォルト:	1048576 (1 mebibyte)
  有効な値:	[0,...]
  重要:	high

• session.timeout.ms

  Kafkaのグループ管理機能を使う時に、クライアントの障害を検知するために使われるタイムアウト。クライアントはその生存をブローカーに示すために定期的なハートビートを送信します。このセッションのタイムアウトが期限切れになる前にハートビートがブローカーによって受け取られない場合は、ブローカーはグループからこのクライアントを削除しリバランスを初期化するでしょう。値は group.min.session.timeout.ms とgroup.max.session.timeout.msによって設定されるブローカーの設定内で設定される可能な範囲内でなければならないことに注意してください。

  Type:	ｄint
  デフォルト:	10000 (10 秒)
  有効な値:
  重要:	high

• ssl.key.password

  The password of the private key in the key store file orthe PEM key specified in `ssl.keystore.key'. This is required for clients only if two-way authentication is configured.

  Type:	password
  デフォルト:	null
  有効な値:
  重要:	high

• ssl.keystore.certificate.chain

  Certificate chain in the format specified by 'ssl.keystore.type'. Default SSL engine factory supports only PEM format with a list of X.509 certificates

  Type:	password
  デフォルト:	null
  有効な値:
  重要:	high

• ssl.keystore.key

  Private key in the format specified by 'ssl.keystore.type'. Default SSL engine factory supports only PEM format with PKCS#8 keys. If the key is encrypted, key password must be specified using 'ssl.key.password'

  Type:	password
  デフォルト:	null
  有効な値:
  重要:	high

• ssl.keystore.location

  キーストアーファイルの場所。これはクライアントについては任意で、クライアントのための相互認証のために使うことができます。

  Type:	文字列
  デフォルト:	null
  有効な値:
  重要:	high

• ssl.keystore.password

  キーストアーファイルのためのストアパスワード。This is optional for client and only needed if 'ssl.keystore.location' is configured. Key store password is not supported for PEM format.

  Type:	password
  デフォルト:	null
  有効な値:
  重要:	high

• ssl.truststore.certificates

  Trusted certificates in the format specified by 'ssl.truststore.type'. Default SSL engine factory supports only PEM format with X.509 certificates.

  Type:	password
  デフォルト:	null
  有効な値:
  重要:	high

• ssl.truststore.location

  トラストストアーファイルの場所。

  Type:	文字列
  デフォルト:	null
  有効な値:
  重要:	high

• ssl.truststore.password

  トラストストアーファイルのパスワード。If a password is not set, trust store file configured will still be used, but integrity checking is disabled. Trust store password is not supported for PEM format.

  Type:	password
  デフォルト:	null
  有効な値:
  重要:	high

• allow.auto.create.topics

  トピックの購読あるいは割り当て時に、ブローカーでのトピックの自動生成を許可します。購読しているトピックは、ブローカーが `auto.create.topics.enable` ブローカー設定を使って許可している場合のみ、自動的に生成されます。この設定は 0.11.0 より古いブローカーを使っている場合に `false` に設定する必要があります。

  Type:	boolean
  デフォルト:	true
  有効な値:
  重要:	medium

• auto.offset.reset

  Kafkaの初期オフセットが無い場合、あるいは現在のオフセットがサーバ上にもうない場合(例えば、データが削除された)に、何をするか？:

  • earliest: 自動的にオフセットを最も早いものに再設定
  • latest: 自動的にオフセットを最も遅いオフセットに再設定
  • none: コンシューマグループについて以前のオフセットが無い場合はコンシューマに例外を投げる
  • いずれでも無い場合: コンシューマに例外を投げます。

  Type:	文字列
  デフォルト:	latest
  有効な値:	[latest, earliest, none]
  重要:	medium

• client.dns.lookup

  クライアントがどのようにDNSルックアップを使うかを制御します。use_all_dns_ips に設定された場合、正常な接続が確立されるまで、返された各 IP アドレスに順番に接続します。切断後に、次の IP が使われます。全ての IP が一度使われると、クライアントはホスト名から IP を再度解決します (ただし、JVM と OS の両方が DNS 名のルックアップをキャッシュします)。resolve_canonical_bootstrap_servers_only に設定されると、各ブートストラップアドレスを正規の名前のリストに解決します。ブートストラップの段階の後で、これは use_all_dns_ips と同じように動作します。default (非推奨)に設定されると、ルックアップが複数の IP アドレスを返す場合でも、ルックアップで返された最初の IP アドレスに接続しようとします。

  Type:	文字列
  デフォルト:	use_all_dns_ips
  有効な値:	[default, use_all_dns_ips, resolve_canonical_bootstrap_servers_only]
  重要:	medium

• connections.max.idle.ms

  この設定によって指定されるミリ秒後にアイドルの接続を閉じます。

  Type:	long
  デフォルト:	540000 (9 分)
  有効な値:
  重要:	medium

• default.api.timeout.ms

  クライアント API のタイムアウト (ミリ秒)を指定します。この設定は timeoutパラメータを指定しない、全てのクライアント操作のデフォルトのタイムアウトとして使われます。

  Type:	ｄint
  デフォルト:	60000 (1 分)
  有効な値:	[0,...]
  重要:	medium

• enable.auto.commit

  trueの場合、コンシューマのオフセットはバックグラウンドで定期的にコミットされるでしょう。

  Type:	boolean
  デフォルト:	true
  有効な値:
  重要:	medium

• exclude.internal.topics

  購読されたパターンに一致する内部トピックを購読から除外すべきかどうか。内部トピックを明示的に購読することは常に可能です。

  Type:	boolean
  デフォルト:	true
  有効な値:
  重要:	medium

• fetch.max.bytes

  サーバが各フェッチリクエストについて返さなければならないデータの最大量。レコードはコンシューマによってバッチ内で取得されます。もし最初の空では無いパーティション内の最初のメッセージがこの値より大きい場合、コンシューマが進めることができるようにレコードのバッチはまだ返されるでしょう。このように、これは絶対的な最大ではありません。ブローカーに受け付けられる最大レコードバッチサイズは message.max.bytes (ブローカー設定) あるいは max.message.bytes (トピック設定) によって定義されます。コンシューマは並行して複数の取得を行うことに注意してください。

  Type:	ｄint
  デフォルト:	52428800 (50 mebibytes)
  有効な値:	[0,...]
  重要:	medium

• group.instance.id

  エンドユーザによって提供されるコンシューマ インスタンスの一意の識別子。空では無い文字列のみが許可されます。設定されている場合、コンシューマは静的なメンバーとして扱われます。常にこのIDを持つ1つのインスタンスだけがコンシューマ グループ内で許可されます。より大きなセッションタイムアウトと組み合わせて使うことで、(プロセスの再起動など)一時的な利用不可によって起こるグループのリバランスを回避することができます。設定されていない場合、コンシューマは動的なメンバーとしてグループに参加します。これは従来の挙動です。

  Type:	文字列
  デフォルト:	null
  有効な値:
  重要:	medium

• isolation.level

  トランザクション的に書き込まれるメッセージをどうやって読むかを制御します。read_committed に設定された場合、consumer.poll() はコミットされたトランザクション的なメッセージのみを返すでしょう。read_uncommitted (デフォルト) に設定された場合、consumer.poll() は破棄されたトランザクション的なメッセージであっても全てのメッセージを返すでしょう。どちらのモードでも非トランザクション的なメッセージは無条件に返されるでしょう。

  メッセージは常にオフセットの順番で返されるでしょう。従って、read_committed モードでは、consumer.poll() は最後の安定したオフセット (LSO) までのメッセージのみを返すでしょう。これは最初に開いたトランザクションのオフセットに他なりません。特に実行中のトランザクションに所属するメッセージの後に現れる全てのメッセージは、関係するトランザクションが完了するまで保留されるでしょう。結果として、read_committed コンシューマは実行中のトランザクションの高いウォーターマークまで読み込むことができないでしょう。

  さらに、read_committedの場合、seekToEnd メソッドはLSOを返します。

  Type:	文字列
  デフォルト:	read_uncommitted
  有効な値:	[read_committed, read_uncommitted]
  重要:	medium

• max.poll.interval.ms

  コンシューマグループ管理を使う時の poll() の起動間の最大の遅延。これはコンシューマがより多くのレコードを取得する前に仕事をしないでいられる総時間に上限を置きます。poll() がこのタイムアウトの期限切れの前に呼ばれなかった場合、コンシューマは失敗したと見なされ、グループはパーティションを他のメンバーに割り当てるためにリバランスするでしょう。このタイムアウトに達する null 以外の group.instance.id を使っているコンシューマの場合、パーティションはすぐに再割り当てされません。代わりに、コンシューマはハートビートの送信を停止し、パーティションは session.timeout.ms の有効期限が切れるとパーティションが再割り当てされます。これは、シャットダウンした静的なコンシューマの動作を反映します。

  Type:	ｄint
  デフォルト:	300000 (5 分)
  有効な値:	[1,...]
  重要:	medium

• max.poll.records

  poll()への1つの呼び出しで返されるレコードの最大数。

  Type:	ｄint
  デフォルト:	500
  有効な値:	[1,...]
  重要:	medium

• partition.assignment.strategy

  グループ管理が使われる場合に、クライアントがコンシューマインスタンス間でパーティションの所有権を分散するために使う、サポートされるパーティション割り当て戦略の優先度順のクラス名とクラスの型のリスト。

  以下で指定されるデフォルトのクラスに加えて、org.apache.kafka.clients.consumer.RoundRobinAssignorクラスを使って、コンシューマへのパーティションのラウンドロビン割り当てを行うことができます。

  org.apache.kafka.clients.consumer.ConsumerPartitionAssignor インタフェースを実装することにより、カスタム割り当て戦略をプラグインすることができます。

  Type:	list
  デフォルト:	class org.apache.kafka.clients.consumer.RangeAssignor
  有効な値:	non-null string
  重要:	medium

• receive.buffer.bytes

  データを読み込む時に使われるTCPレシーバーバッファ (SO_RCVBUF) のサイズ。値が -1 であれば、OSのデフォルトが使われるでしょう。

  Type:	ｄint
  デフォルト:	65536 (64 kibibytes)
  有効な値:	[-1,...]
  重要:	medium

• request.timeout.ms

  この設定はクライアントがリクエストの応答を待つ総時間の最大を制御します。タイムアウトの時間が経過する前に応答が受信されない場合は、必要であればクライアントはリクエストを再送信するでしょう。あるいは再試行が使い尽くされた場合は失敗するでしょう。

  Type:	ｄint
  デフォルト:	30000 (30 秒)
  有効な値:	[0,...]
  重要:	medium

• sasl.client.callback.handler.class

  AuthenticateCallbackHandler インタフェースを実装するSASLクライアント コールバック ハンドラ クラスの完全修飾名。

  Type:	クラス
  デフォルト:	null
  有効な値:
  重要:	medium

• sasl.jaas.config

  JAAS設定ファイル内で使われる形式のSASL接続のためのJAAS login コンテキスト パラメータ。JAAS 設定ファイルのフォーマットはここで説明されます。値の形式は: 'loginModuleClass controlFlag (optionName=optionValue)*;'。ブローカーについては、設定はlistenerのプリフィックスを前に付ける必要があり、SASL機構名は小文字でなければなりません。例えば、listener.name.sasl_ssl.scram-sha-256.sasl.jaas.config=com.example.ScramLoginModule が必要です;

  Type:	password
  デフォルト:	null
  有効な値:
  重要:	medium

• sasl.kerberos.service.name

  Kafkaが実行するKerbrosプリンシパル名。これはKafkaのJAAS設定あるいはKafkaの設定のどちらかで定義することができます。

  Type:	文字列
  デフォルト:	null
  有効な値:
  重要:	medium

• sasl.login.callback.handler.class

  AuthenticateCallbackHandler インタフェースを実装するSASL ログイン コールバック ハンドラ クラスの完全修飾名。ブローカーについては、ログインのコールバックハンドラ設定はlistenerのプリフィックスを前に付ける必要があり、SASL機構名は小文字でなければなりません。例えば、listener.name.sasl_ssl.scram-sha-256.sasl.login.callback.handler.class=com.example.CustomScramLoginCallbackHandler

  Type:	クラス
  デフォルト:	null
  有効な値:
  重要:	medium

• sasl.login.class

  Loginインタフェースを実装するクラスの完全修飾名。ブローカーについては、ログイン設定はlistenerのプリフィックスを前に付ける必要があり、SASL機構名は小文字でなければなりません。例えば、listener.name.sasl_ssl.scram-sha-256.sasl.login.class=com.example.CustomScramLogin

  Type:	クラス
  デフォルト:	null
  有効な値:
  重要:	medium

• sasl.mechanism

  クライアント接続で使われるSASL機構。これはセキュリティプロバイダが利用可能な全ての機構です。GSSAPI がデフォルトの機構です。

  Type:	文字列
  デフォルト:	GSSAPI
  有効な値:
  重要:	medium

• security.protocol

  ブローカーと通信するために使われるプロトコル。有効な値は: PLAINTEXT, SSL, SASL_PLAINTEXT, SASL_SSL。

  Type:	文字列
  デフォルト:	PLAINTEXT
  有効な値:
  重要:	medium

• send.buffer.bytes

  データを送信する時に使われるTCP送信バッファ (SO_SNDBUF)のサイズ。値が -1 であれば、OSのデフォルトが使われるでしょう。

  Type:	ｄint
  デフォルト:	131072 (128 kibibytes)
  有効な値:	[-1,...]
  重要:	medium

• socket.connection.setup.timeout.max.ms

  The maximum amount of time the client will wait for the socket connection to be established. The connection setup timeout will increase exponentially for each consecutive connection failure up to this maximum. To avoid connection storms, a randomization factor of 0.2 will be applied to the timeout resulting in a random range between 20% below and 20% above the computed value.

  Type:	long
  デフォルト:	127000 (127 seconds)
  有効な値:
  重要:	medium

• socket.connection.setup.timeout.ms

  The amount of time the client will wait for the socket connection to be established. If the connection is not built before the timeout elapses, clients will close the socket channel.

  Type:	long
  デフォルト:	10000 (10 秒)
  有効な値:
  重要:	medium

• ssl.enabled.protocols

  SSL接続のために有効にされるプロトコルのリスト。デフォルトは、Java 11以降で実行する場合は 'TLSv1.2,TLSv1.3'、それ以外の場合は、'TLSv1.2' です。Java 11 のデフォルト値では、クライアントとサーバはどちらもサポートする場合は TLSv1.3 を優先し、そうでない場合は TLSv1.2 にフォールバックしますjj(両方が少なくと TLSv1.2 をサポートする場合)。このデフォルトはほとんどの場合で十分です。`ssl.protocol` の設定ドキュメントも見てください。

  Type:	list
  デフォルト:	TLSv1.2
  有効な値:
  重要:	medium

• ssl.keystore.type

  キーストアファイルのファイル形式。これはクライアントについては任意です。

  Type:	文字列
  デフォルト:	JKS
  有効な値:
  重要:	medium

• ssl.protocol

  SSLContextを生成するために使われるSSLプロトコル。デフォルトは、Java 11以降で実行する場合は 'TLSv1.3'、それ以外の場合は、'TLSv1.2' です。この値はほとんどの使い方で十分です。最近の JVM での許容れる値は、'TLSv1.2' と 'TLSv1.3' です。'TLS'、'TLSv1.1'、'SSL'、'SSLv2'、'SSLv3' は古いJVMではサポートされるかも知れませんが、これらの使用は既知のセキュリティ脆弱性のため推奨されません。この構成のデフォルト値と 'ssl.enabled.protocols' では、サーバが 'TLSv1.3' をサポートしない場合は、クライアントは 'TLSv1.2' にダウングレードします。この構成が 'TLSv1.2' に設定されている場合、ssl.enabled.protocols の値のうちの1つで、サーバが 'TLSv1.3' だけをサポートする場合でも、クライアントは 'TLSv1.3' を使いません。

  Type:	文字列
  デフォルト:	TLSv1.2
  有効な値:
  重要:	medium

• ssl.provider

  SSL接続のために使われるセキュリティプロバイダの名前。デフォルト値はJVMのデフォルトのセキュリティプロバイダです。

  Type:	文字列
  デフォルト:	null
  有効な値:
  重要:	medium

• ssl.truststore.type

  トラストストアファイルのファイル形式。

  Type:	文字列
  デフォルト:	JKS
  有効な値:
  重要:	medium

• auto.commit.interval.ms

  もしenable.auto.commit が true に設定されている場合に、コンシューマのオフセットがKafkaに自動コミットされる頻度のミリ秒。

  Type:	ｄint
  デフォルト:	5000 (5 秒)
  有効な値:	[0,...]
  重要:	low

• check.crcs

  消費されるレコードのCRC32を自動的にチェックする。これにより、通信上あるいはディスク上でメッセージの改竄が無いことを保証します。この調査はいくらかの負荷があるため、極度にパフォーマンスを求めている場合は無効にされているかも知れません。

  Type:	boolean
  デフォルト:	true
  有効な値:
  重要:	low

• client.id

  リクエストする時にサーバに渡されるid文字列。これの目的は、サーバ側のリクエストのログに論理アプリケーション名を追加することで、ip/portを超えたリクエストのソースの追跡をすることです。

  Type:	文字列
  デフォルト:	""
  有効な値:
  重要:	low

• client.rack

  このクライアントのラック識別子。これはこのクライアントが物理的に配置されている場所を示す任意の文字列値にすることができます。ブローカー設定の 'broker.rack' に対応します。

  Type:	文字列
  デフォルト:	""
  有効な値:
  重要:	low

• fetch.max.wait.ms

  すぐに指定されたfetch.min.bytes の要求を満たす十分なデータが無い場合に、サーバがフェッチリクエストに応答する前にブロックする最大の時間。

  Type:	ｄint
  デフォルト:	500
  有効な値:	[0,...]
  重要:	low

• interceptor.classes

  インタセプタとして使われるクラスのリスト。org.apache.kafka.clients.consumer.ConsumerInterceptor インタフェースを実装することにより、コンシューマによって受け取られるレコードを捕らえ(そしておそらく変化)することができます。デフォルトでは、インタセプタはありません。

  Type:	list
  デフォルト:	""
  有効な値:	non-null string
  重要:	low

• metadata.max.age.ms

  パーティションのリーダーシップが新しいブローカーあるいはパーティションを前もって見つけるために変更されたのを見ていないとしても、メタデータのリフレッシュを強制するミリ秒単位の時間。

  Type:	long
  デフォルト:	300000 (5 分)
  有効な値:	[0,...]
  重要:	low

• metric.reporters

  メトリクス レポーターとして使われるクラスのリスト。org.apache.kafka.common.metrics.MetricsReporter インタフェースの実装により、新しいメトリックの生成を知らせるクラスをプラグインすることができます。JMX統計を登録するために常に JmxReporter が含まれます。

  Type:	list
  デフォルト:	""
  有効な値:	non-null string
  重要:	low

• metrics.num.samples

  メトリクスを計算するために保持される標本の数。

  Type:	ｄint
  デフォルト:	2
  有効な値:	[1,...]
  重要:	low

• metrics.recording.level

  メトリクスのための最も高い記録レベル。

  Type:	文字列
  デフォルト:	INFO
  有効な値:	[INFO, DEBUG, TRACE]
  重要:	low

• metrics.sample.window.ms

  メトリクスの標本が計算されるための時間の窓。

  Type:	long
  デフォルト:	30000 (30 秒)
  有効な値:	[0,...]
  重要:	low

• reconnect.backoff.max.ms

  接続が繰り返し失敗するブローカーへの再接続時に待つミリ秒単位の総最大時間。指定された場合、ホスト毎のバックオフはそれぞれの連続する失敗ごとにこの最大まで指数関数的に増加するでしょう。バックオフの計算を増加した後で、接続の嵐を避けるために20%のランダムなジッターが追加されます。

  Type:	long
  デフォルト:	1000 (1 秒)
  有効な値:	[0,...]
  重要:	low

• reconnect.backoff.ms

  指定されたホストに再接続しようとするまで待機する基本的な総時間。これにより短いループ内でホストに繰り返し接続することを防ぎます。このbackoffはクライアントによってブローカーに送信される全ての接続に適用されます。

  Type:	long
  デフォルト:	50
  有効な値:	[0,...]
  重要:	low

• retry.backoff.ms

  指定されたトピックパーティションへの失敗したリクエストを再試行しようとするまで待機する総時間。これにより短いループ内で幾つかの失敗のシナリオがある場合に繰り返しリクエストすることを防ぎます。

  Type:	long
  デフォルト:	100
  有効な値:	[0,...]
  重要:	low

• sasl.kerberos.kinit.cmd

  Kerberos kinit コマンドライン パス。

  Type:	文字列
  デフォルト:	/usr/bin/kinit
  有効な値:
  重要:	low

• sasl.kerberos.min.time.before.relogin

  リフレッシュ試行間のログインスレッドのスリープ時間。

  Type:	long
  デフォルト:	60000
  有効な値:
  重要:	low

• sasl.kerberos.ticket.renew.jitter

  更新時間に追加されるランダムなジッターのパーセンテージ。

  Type:	double
  デフォルト:	0.05
  有効な値:
  重要:	low

• sasl.kerberos.ticket.renew.window.factor

  最後にリフレッシュされてからチケットの期限切れまでの時間が指定されたウィンドウ要素になるまで、ログインスレッドはスリープします。そしてその時間にチケットを更新しようとするでしょう。

  Type:	double
  デフォルト:	0.8
  有効な値:
  重要:	low

• sasl.login.refresh.buffer.seconds

  証明書をリフレッシュする時に証明書の有効期限を維持するバッファ時間の秒数。そうでなければ、バッファの秒数よりも有効期限の近くで更新が発生する場合、可能な限り多くのバッファ時間を維持するために、更新が上に移動されます。有効な値は0から3600(1時間); 値が指定されない場合はデフォルトの値 300 (5分)が使われます。この値と sasl.login.refresh.min.period.seconds は、もしそれらの合計が証明書の残りの生存期間を超える場合に両方とも無視されます。現在のところは OAUTHBEARER にのみ適用されます。

  Type:	short
  デフォルト:	300
  有効な値:	[0,...,3600]
  重要:	low

• sasl.login.refresh.min.period.seconds

  証明書をリフレッシュする前にログイン フレッシュ スレッドが待つ望ましい最小の時間の秒数。有効な値は0から900 (15分); 値が指定されない場合はデフォルトの値60(1分)が使われます。この値と sasl.login.refresh.buffer.seconds は、もしそれらの合計が証明書の残りの生存期間を超える場合に両方とも無視されます。現在のところは OAUTHBEARER にのみ適用されます。

  Type:	short
  デフォルト:	60
  有効な値:	[0,...,900]
  重要:	low

• sasl.login.refresh.window.factor

  ログイン フレッシュ スレッドは、証明書の生存期間に関連した指定されたウィンドウ ファクタに達するまでスリープしようとします。その時点で証明書をリフレッシュしようとするでしょう。有効な値は0.5 (50%)以上と1.0 (100%)以下の間です; 値が指定されない場合はデフォルトの値 0.8 (80%)が使われます。現在のところは OAUTHBEARER にのみ適用されます。

  Type:	double
  デフォルト:	0.8
  有効な値:	[0.5,...,1.0]
  重要:	low

• sasl.login.refresh.window.jitter

  ログイン スレッドのスリープ時間に追加された証明書の生存期間に対するランダム ジッタの最大量。有効な値は 0以上と0.25 (25%)以下の間です; 値が指定されない場合はデフォルトの値 0.05 (5%) が使われます。現在のところは OAUTHBEARER にのみ適用されます。

  Type:	double
  デフォルト:	0.05
  有効な値:	[0.0,...,0.25]
  重要:	low

• security.providers

  セキュリティアルゴリズムを実装するプロバイダをそれぞれ返す構成可能なクリエイタクラスのリスト。これらのクラスは、org.apache.kafka.common.security.auth.SecurityProviderCreator インスタンスを実装しなければなりません。

  Type:	文字列
  デフォルト:	null
  有効な値:
  重要:	low

• ssl.cipher.suites

  cipher スイーツのリストこれはTLSあるいはSSLネットワークプロトコルを使うネットワーク接続のためのセキュリティ設定を取り決めるために使われる、認証、暗号化、MACおよびキー交換アルゴリズムの名前の組み合わせです。デフォルトでは全ての利用可能なcipherスイーツがサポートされます。

  Type:	list
  デフォルト:	null
  有効な値:
  重要:	low

• ssl.endpoint.identification.algorithm

  サーバの証明書を使ってサーバのホスト名を検証するためのエンドポイント識別アルゴリズム。

  Type:	文字列
  デフォルト:	https
  有効な値:
  重要:	low

• ssl.engine.factory.class

  SSLEngine オブジェクトを提供するための org.apache.kafka.common.security.auth.SslEngineFactory 型のクラス。デフォルト値は、org.apache.kafka.common.security.ssl.DefaultSslEngineFactory です

  Type:	クラス
  デフォルト:	null
  有効な値:
  重要:	low

• ssl.keymanager.algorithm

  SSL接続のためにキーマネージャーファクトリーによって使われるアルゴリズム。デフォルト値はJava仮想マシーンのために設定されたキーマネージャーファクトリーアルゴリズムです。

  Type:	文字列
  デフォルト:	SunX509
  有効な値:
  重要:	low

• ssl.secure.random.implementation

  SSL暗号化操作のために使われる SecureRandom PRNG 実装。

  Type:	文字列
  デフォルト:	null
  有効な値:
  重要:	low

• ssl.trustmanager.algorithm

  SSL接続のためにトラストマネージャーファクトリーによって使われるアルゴリズム。デフォルト値はJava仮想マシーンのために設定されトラストーマネージャーファクトリーアルゴリズムです。

  Type:	文字列
  デフォルト:	PKIX
  有効な値:
  重要:	low