すべてのプロダクト
Search
ドキュメントセンター

ApsaraMQ for RocketMQ:パラメーター

最終更新日:Jul 09, 2024

このトピックでは、SDK for JavaのCommunity Editionを使用してApsaraMQ for RocketMQに接続するときに設定する必要があるパラメーターについて説明します。

共通パラメーター

パラメーター

説明

NAMESRV_ADDR

TCPエンドポイント。 エンドポイントは、ApsaraMQ for RocketMQコンソール[インスタンスの詳細] ページで取得できます。

アクセスキー(AccessKey)

認証に使用されるAccessKey ID。 AccessKey IDの取得方法については、「AccessKeyペアの作成」をご参照ください。

SecretKey

認証に使用されるAccessKeyシークレット。 AccessKeyシークレットの取得方法については、「AccessKeyペアの作成」をご参照ください。

AccessChannel

クラウドでメッセージトレース機能を使用するかどうかを指定します。 クラウドでメッセージトレース機能を使用する場合は、このパラメーターをcloudに設定します。

メッセージ送信用のパラメータ

パラメーター

説明

producerGroup

プロデューサーグループのID。 複数のプロデューサが同じアプリケーションに属し、同じメッセージを送信する場合、プロデューサは同じグループに属すると見なされます。 ApsaraMQ for RocketMQコンソールでプロデューサーグループのIDを取得できます。 詳細については、「Terms」をご参照ください。

sendMsgTimeout

メッセージを送信するためのタイムアウト期間。 単位:ミリ秒。

compressMsgBodyOverHowmuch

圧縮するメッセージのボディサイズのしきい値を指定します。 メッセージの本体サイズがしきい値を超える場合、メッセージは圧縮され、消費者による受信時に解凍される。 デフォルト値: 4。 (単位:KB)

retryTimesWhenSendFailed

メッセージの送信に失敗した場合にメッセージに対して実行できる再試行の最大数。 このパラメーターは、同期モードで送信されたメッセージに対してのみ有効です。

maxMessageSize

クライアントによって指定された最大メッセージサイズ。 メッセージのサイズがこのパラメーターで指定された値を超えると、エラーが報告されます。 ブローカはまた、メッセージサイズに制限を課す。 このパラメーターは、ブローカーの対応するパラメーターと一緒に使用する必要があります。 デフォルト値: 4。 単位:MB。

メッセージサブスクリプションのパラメータ

パラメーター

説明

consumerGroup

コンシューマーグループの ID です。 複数のコンシューマが同じアプリケーションに属し、同じメッセージにサブスクライブし、同じメッセージ消費ロジックを使用する場合、これらのコンシューマは同じグループに属していると見なされます。 ApsaraMQ for RocketMQコンソールでコンシューマーグループのIDを取得できます。 詳細については、「Terms」をご参照ください。

consumeFromWhere

コンシューマーグループの開始後にメッセージが消費されるオフセット。 デフォルトでは、メッセージは最新のオフセットから消費されます。

consumeThreadMin

コンシューマースレッドプール内のスレッドの最小数。 デフォルト値は 20 です。

consumeThreadMax

コンシューマースレッドプール内のスレッドの最大数。 デフォルト値は 20 です。 スレッドの最大数は、スレッドの最小数と一致している必要があります。

consumeConcurrentlyMaxSpan

メッセージがキューで同時に消費されるときに許可される最大オフセットスパン。 有効な値: -1 から 65535 デフォルト値: 2000。

pullThresholdForQueue

メッセージがプルされたときにローカルキューにキャッシュできるメッセージの最大数。 有効な値: -1 から 65535 デフォルト値は 1000 です。

pullThresholdSizeForQueue

メッセージがプルされたときにローカルキューにキャッシュできるメッセージの合計サイズ。 有効な値: 1 ~ 1024 デフォルト値:100 単位:MB。

maxReconsumeTimes

リトライの最大回数は 10 回です。 デフォルト値: 16。

suspendCurrentQueueTimeMillis

順序付けられたメッセージの2回の連続した再試行間の最小時間間隔。 有効な値: 10 ~ 30000 デフォルト値は 1000 です。 単位:ミリ秒。

関連ドキュメント