OnsConsumerResetOffset - - Alibaba Cloud Dokümantasyon Merkezi

Not

Bu işlemi, kuyrukta bekleyen mesajları temizlemek veya mesajların yeniden tüketilmesini sağlamak için çağırabilirsiniz. Kuyrukta bekleyen mesajları aşağıdaki yöntemlerden birini kullanarak temizleyebilirsiniz:

Belirtilen konudaki tüm kuyrukta bekleyen mesajları temizler.
Belirtilen bir zamandan önce belirtilen konuya yayınlanan mesajları temizler.

İstek sınırı

Her Alibaba Cloud hesabı bu işlemi saniyede en fazla 10 kez çağırabilir. Bir saniye içinde bu işlemi çağırmak için gönderdiğiniz istek sayısı istek sınırına ulaşırsa yeni istekler başarısız olur. Bu durum iş süreçlerinizi kesintiye uğratabilir. Her işlemin istek sınırı hakkında bilgi edinmek için bkz. API istek sınırları.

Yetkilendirme

Varsayılan olarak Alibaba Cloud hesapları bu işlemi çağırabilir. Bir Resource Access Management (RAM) kullanıcısı yalnızca gerekli izinler verildikten sonra bu işlemi çağırabilir. Aşağıdaki tabloda, bir RAM kullanıcısının bu işlemi çağırabilmesi için verilmesi gereken izinler açıklanmaktadır. İzinlerin nasıl verileceği hakkında bilgi edinmek için bkz. İlkeler.

API

Action

Ad alanı kullanan örnekteki Kaynak

Ad alanı kullanmayan örnekteki Kaynak

OnsConsumerResetOffset

mq:QueryInstanceBaseInfo

mq:ResetConsumerOffset

acs:mq:::{instanceId}%{topic}

acs:mq:::{topic}

İstek parametreleri

Parametre	Tür	Zorunlu	Örnek	Açıklama
Action	String	Evet	OnsConsumerResetOffset	Gerçekleştirmek istediğiniz işlem. Değeri OnsConsumerResetOffset olarak ayarlayın.
GroupId	String	Evet	GID_test_consumer_id	Tüketici ofsetini sıfırlamak istediğiniz tüketici grubunun ID'si.
Topic	String	Evet	test-mq-topic	Tüketici ofsetini sıfırlamak istediğiniz konunun adı.
Type	Integer	Evet	1	Kuyrukta bekleyen mesajları temizlemek için kullanmak istediğiniz yöntem. Geçerli değerler: 0: Belirtilen konudaki tüm kuyrukta bekleyen mesajlar temizlenir. Tüketilmeyen mesajlar yok sayılır. Belirtilen tüketici grubundaki tüketiciler yalnızca mevcut zamandan sonra konuya yayınlanan mesajları tüketir. "reconsumeLater" döndürülürse sistem mesajları tüketicilere göndermeyi yeniden denediğinden kuyrukta bekleyen mesajlar temizlenmez. 1: Belirtilen bir zamandan önce konuya yayınlanan mesajlar temizlenir. Bir zaman noktası belirtmeniz gerekir. Belirtilen tüketici grubundaki tüketiciler yalnızca belirtilen zamandan sonra konuya yayınlanan mesajları tüketir. Bir mesajın konuya ilk kez yayınlandığı en erken zaman ile konuya en son yayınlandığı zaman arasındaki zaman aralığında bir zaman noktası belirtebilirsiniz. İzin verilen zaman aralığının dışındaki zaman noktaları geçersizdir.
ResetTimestamp	Long	Hayır	1591153871000	Tüketici ofsetini sıfırlamak istediğiniz zaman noktası. Bu parametre yalnızca Type parametresini 1 olarak ayarladığınızda etkili olur. Birim: milisaniye.
InstanceId	String	Evet	MQ_INST_111111111111_DOxxxxxx	Belirtilen tüketici grubunu içeren Message Queue for Apache RocketMQ örneğinin ID'si.

Yanıt parametreleri

Parametre	Tür	Örnek	Açıklama
RequestId	String	D52C68F8-EC5D-4294-BFFF-1A6A25AF****	İsteğin ID'si. Sistem her istek için benzersiz bir ID oluşturur. Sorunları istek ID'sine göre giderebilirsiniz.

Örnekler

Örnek istekler

http(s)://ons.cn-hangzhou.aliyuncs.com/?Action=OnsConsumerResetOffset
&GroupId=GID_test_consumer_id
&InstanceId=MQ_INST_111111111111_DOxxxxxx
&Topic=test-mq-topic
&Type=1
&ResetTimestamp=1591153871000
&<Common request parameters>

Başarılı yanıt örnekleri

XML formatı

HTTP/1.1 200 OK
Content-Type:application/xml

<OnsConsumerResetOffsetResponse>
    <RequestId>D52C68F8-EC5D-4294-BFFF-1A6A25AF****</RequestId>
</OnsConsumerResetOffsetResponse>

JSON formatı

HTTP/1.1 200 OK
Content-Type:application/json

{
  "RequestId" : "D52C68F8-EC5D-4294-BFFF-1A6A25AF****"
}

Hata kodları

Hata kodlarının listesi için API Hata Merkezi adresini ziyaret edin.

Konsolda bir tüketici grubunun tüketici ofsetini sıfırlama

Message Queue for Apache RocketMQ konsolunda bir tüketici grubu için tüketici ofsetini sıfırlayabilirsiniz. Daha fazla bilgi için bkz. Tüketici ofsetlerini sıfırlama.