クラス ConsumerProperties

メソッドの詳細

• getTopics

  @Nullable public StringSE[] getTopics()

  構成されたトピックを返します。

  戻り値:

  トピック。

• getTopicPattern

  @Nullable public PatternSE getTopicPattern()

  構成されたトピックパターンを返します。

  戻り値:

  トピックパターン。

• getTopicPartitions

  @Nullable public TopicPartitionOffset[] getTopicPartitions()

  構成済みの TopicPartitionOffset を返します。

  戻り値:

  トピック / パーティション。

  導入:

  2.5

• setPollTimeout

  public void setPollTimeout(long pollTimeout)

  レコードを待機しているコンシューマーでブロックする最大時間を設定します。

  パラメーター:

  pollTimeout - ミリ秒単位のタイムアウト。デフォルトの 5000L。

• getPollTimeout

  public long getPollTimeout()

• setGroupId

  public void setGroupId(StringSE groupId)

  このコンテナーのグループ ID を設定します。コンシューマーファクトリ構成によって提供される group.id プロパティをオーバーライドします。

  パラメーター:

  groupId - グループ ID。

• getGroupId

  @Nullable public StringSE getGroupId()

  コンテナーのグループ ID を返します。

  戻り値:

  グループ ID。

• getClientId

  public StringSE getClientId()

  クライアント ID を返します。

  戻り値:

  クライアント ID。

  関連事項:

  • setClientId(String)

• setClientId

  public void setClientId(StringSE clientId)

  クライアント ID を設定します。コンシューマーファクトリの client.id プロパティを上書きします。並行コンテナーで使用される場合、各コンシューマーに一意の値を提供するために "-n" という接尾辞が付けられます。

  パラメーター:

  clientId - クライアント ID。

• setConsumerRebalanceListener

  public void setConsumerRebalanceListener(org.apache.kafka.clients.consumer.ConsumerRebalanceListener consumerRebalanceListener)

  ユーザー定義の ConsumerRebalanceListener 実装を設定します。

  パラメーター:

  consumerRebalanceListener - ConsumerRebalanceListener インスタンス

• getConsumerRebalanceListener

  @Nullable public org.apache.kafka.clients.consumer.ConsumerRebalanceListener getConsumerRebalanceListener()

  リバランスリスナーを返します。

  戻り値:

  リスナー。

• setSyncCommitTimeout

  public void setSyncCommitTimeout(@Nullable DurationSE syncCommitTimeout)

  commitSync 操作のタイムアウトを設定します（isSyncCommits() の場合。デフォルトの api タイムアウトプロパティをオーバーライドします。

  パラメーター:

  syncCommitTimeout - タイムアウト。

  関連事項:

  • setSyncCommits(boolean)

• getSyncCommitTimeout

  @Nullable public DurationSE getSyncCommitTimeout()

  同期コミットタイムアウトを返します。

  戻り値:

  タイムアウト。

• setCommitCallback

  public void setCommitCallback(org.apache.kafka.clients.consumer.OffsetCommitCallback commitCallback)

  コミットコールバックを設定します。デフォルトでは、単純なロギングコールバックを使用して、DEBUG レベルでの成功と ERROR レベルでの失敗をログに記録します。syncCommits が false の場合に使用されます。

  パラメーター:

  commitCallback - コールバック。

  関連事項:

  • setSyncCommits(boolean)

• setOffsetAndMetadataProvider

  public void setOffsetAndMetadataProvider(OffsetAndMetadataProvider offsetAndMetadataProvider)

  コミットコールバックに関連付けられたオフセットおよびメタデータプロバイダーを設定します。

  パラメーター:

  offsetAndMetadataProvider - オフセットおよびメタデータプロバイダー。

  導入:

  2.8.5

  関連事項:

  • setCommitCallback(OffsetCommitCallback)

• getCommitCallback

  @Nullable public org.apache.kafka.clients.consumer.OffsetCommitCallback getCommitCallback()

  コミットコールバックを返します。

  戻り値:

  コールバック。

• getOffsetAndMetadataProvider

  @Nullable public OffsetAndMetadataProvider getOffsetAndMetadataProvider()

  オフセットおよびメタデータプロバイダーを返します。

  戻り値:

  オフセットおよびメタデータプロバイダー。

• setSyncCommits

  public void setSyncCommits(boolean syncCommits)

  コンテナーがコミットを担当するときに consumer.commitSync() または commitAsync() を呼び出すかどうかを設定します。デフォルトは true です。

  パラメーター:

  syncCommits - commitSync() を使用するのは本当です。

  関連事項:

  • setSyncCommitTimeout(Duration)
  • setCommitCallback(OffsetCommitCallback)
  • setCommitLogLevel(org.springframework.kafka.support.LogIfLevelEnabled.Level)
  • setCommitRetries(int)

• isSyncCommits

  public boolean isSyncCommits()

• getCommitLogLevel

  public LogIfLevelEnabled.Level getCommitLogLevel()

  オフセットコミットをログに記録するレベル。

  戻り値:

  レベル。

• setCommitLogLevel

  public void setCommitLogLevel(LogIfLevelEnabled.Level commitLogLevel)

  オフセットコミットをログに記録するレベルを設定します。デフォルト: DEBUG。

  パラメーター:

  commitLogLevel - レベル。

• getKafkaConsumerProperties

  public PropertiesSE getKafkaConsumerProperties()

  コンシューマーファクトリによって提供されるコンシューマープロパティとマージされるコンシューマープロパティを取得します。ここのプロパティは、コンシューマーファクトリの同じ名前のプロパティに優先します。文字列値以外のプロパティを追加できますが、プロパティ名（ハッシュテーブルキー）は文字列である必要があります。他のすべては無視されます。group.id と client.id は無視されます。

  戻り値:

  プロパティ。

  関連事項:

  • ConsumerConfig
  • setGroupId(String)
  • setClientId(String)

• setKafkaConsumerProperties

  public void setKafkaConsumerProperties(PropertiesSE kafkaConsumerProperties)

  コンシューマーファクトリによって提供されるコンシューマープロパティとマージされるコンシューマープロパティを設定します。ここのプロパティは、コンシューマーファクトリ内の同じ名前を持つものに取って代わります。group.id と client.id は無視されます。プロパティキーは StringSE である必要があります。

  パラメーター:

  kafkaConsumerProperties - プロパティ。

  関連事項:

  • ConsumerConfig
  • setGroupId(String)
  • setClientId(String)

• getAuthExceptionRetryInterval

  @Nullable public DurationSE getAuthExceptionRetryInterval()

  認証 / 認可の再試行間隔を取得します。

  戻り値:

  間隔。

• setAuthExceptionRetryInterval

  public void setAuthExceptionRetryInterval(DurationSE authExceptionRetryInterval)

  AuthenticationException または org.apache.kafka.common.errors.AuthorizationException が KafkaConsumer によってスローされた後の再試行の間隔を設定します。デフォルトでは、フィールドは null であり、再試行は無効になっています。そのような場合、コンテナーは停止されます。間隔は、max.poll.interval.ms コンシューマープロパティよりも小さくする必要があります。

  パラメーター:

  authExceptionRetryInterval - 再試行間の期間

  導入:

  2.8

• getCommitRetries

  public int getCommitRetries()

  true に設定された setSyncCommits(boolean) を使用しているときに、コンシューマーによって RetriableCommitFailedException がスローされたときに許可される再試行の回数。

  戻り値:

  再試行の回数。

  導入:

  2.3.9

  関連事項:

  • setSyncCommits(boolean)

• setCommitRetries

  public void setCommitRetries(int commitRetries)

  true に設定された setSyncCommits(boolean) を使用しているときに、コンシューマーによって RetriableCommitFailedException がスローされたときに許可される再試行回数を設定します。デフォルトの 3 (4 は合計を試行します）。

  パラメーター:

  commitRetries - commitRetries。

  導入:

  2.3.9

  関連事項:

  • setSyncCommits(boolean)

• isFixTxOffsets

  public boolean isFixTxOffsets()

  最終的なトランザクションオフセットを修正するかどうか。

  戻り値:

  修正するのは本当です。

  導入:

  2.5.6

  関連事項:

  • setFixTxOffsets(boolean)

• setFixTxOffsets

  public void setFixTxOffsets(boolean fixTxOffsets)

  トランザクションプロデューサーによって生成されたレコードを消費し、コンシューマーがパーティションの最後に配置されている場合、トランザクションのコミット / ロールバックと、場合によっては存在を示すために使用される疑似レコードが原因で、ラグがゼロより大きいと誤って報告される可能性があります。ロールバックされたレコードの。これは関数にはコンシューマーに影響を与えませんが、一部のユーザーは「ラグ」がゼロ以外であることに関心事を表明しています。これを true に設定すると、コンテナーはそのような誤って報告されたオフセットを修正します。チェックは、コミット処理が大幅に複雑になるのを防ぐために、次のポーリングの前に実行されます。重要: これを書いている時点では、コンシューマーが isolation.level=read_committed で構成されていて、max.poll.records が 1 より大きい場合にのみ、ラグが修正されます。詳細については、https://issues.apache.org/jira/browse/KAFKA-10683 を参照してください。

  パラメーター:

  fixTxOffsets - true の場合、オフセットを修正します。

  導入:

  2.5.6

• isCheckDeserExWhenKeyNull

  public boolean isCheckDeserExWhenKeyNull()

  null キーを使用した逆直列化例外ヘッダーを常に確認してください。

  戻り値:

  チェックするのは本当です。

  導入:

  2.8.1

• setCheckDeserExWhenKeyNull

  public void setCheckDeserExWhenKeyNull(boolean checkDeserExWhenKeyNull)

  null キーを受信したときに、常に DeserializationException ヘッダーをチェックするには、true に設定します。委譲デシリアライザーを使用している場合など、コンシューマーコードが ErrorHandlingDeserializer が構成されていることを判別できない場合に役立ちます。

  パラメーター:

  checkDeserExWhenKeyNull - 常にチェックするために true。

  導入:

  2.8.1

• isCheckDeserExWhenValueNull

  public boolean isCheckDeserExWhenValueNull()

  null 値の逆直列化例外ヘッダーを常に確認してください。

  戻り値:

  チェックするのは本当です。

  導入:

  2.8.1

• setCheckDeserExWhenValueNull

  public void setCheckDeserExWhenValueNull(boolean checkDeserExWhenValueNull)

  null 値を受け取ったときに、常に DeserializationException ヘッダーをチェックするには、true に設定します。委譲デシリアライザーを使用している場合など、コンシューマーコードが ErrorHandlingDeserializer が構成されていることを判別できない場合に役立ちます。

  パラメーター:

  checkDeserExWhenValueNull - 常にチェックするために true。

  導入:

  2.8.1

• toString

  public StringSE toString()

  オーバーライド:

  クラス ObjectSE の toString 

• renderProperties

  protected final StringSE renderProperties()