Membuat topik di ApsaraMQ for RocketMQ. Topik adalah kontainer utama untuk transmisi dan penyimpanan pesan. Topik digunakan untuk mengategorikan pesan yang memiliki logika bisnis yang sama. Dalam model produsen-konsumen, produsen mengirim pesan ke topik, dan konsumen berlangganan ke topik tersebut untuk mengonsumsi pesan.
Coba sekarang
Test
RAM authorization
|
Action |
Access level |
Resource type |
Condition key |
Dependent action |
|
rocketmq:CreateTopic |
create |
*Topic
|
None | None |
Sintaks permintaan
POST /instances/{instanceId}/topics/{topicName} HTTP/1.1
Path Parameters
|
Parameter |
Type |
Required |
Description |
Example |
| instanceId |
string |
Yes |
ID instance tempat topik tersebut berada. |
rmq-cn-7e22ody**** |
| topicName |
string |
Yes |
Nama topik yang akan dibuat. Nama tersebut mengidentifikasi topik dan harus unik secara global. Nama harus memenuhi persyaratan berikut:
Untuk informasi tentang karakter yang dicadangkan, lihat Batas parameter. |
topic_test |
Parameter permintaan
|
Parameter |
Type |
Required |
Description |
Example |
| body |
object |
No |
Informasi tentang topik. |
|
| messageType |
string |
Yes |
Jenis pesan dari topik yang akan dibuat. Penting
Jenis topik harus sesuai dengan jenis pesan yang dikirim ke topik tersebut. Misalnya, jika Anda membuat topik untuk pesan berurutan, topik tersebut hanya dapat digunakan untuk mengirim dan menerima pesan berurutan. Anda tidak dapat menggunakannya untuk jenis pesan lain. Valid values:
|
NORMAL |
| remark |
string |
No |
Keterangan pada topik yang akan dibuat. |
This is the remark for test. |
| maxSendTps |
integer |
No |
Transaksi maksimum per detik (TPS) untuk mengirim pesan. |
1500 |
| liteTopicExpiration |
integer |
No |
Time-to-live (TTL) untuk lite topic, dalam menit. Nilai yang valid: 30 hingga 720. Nilai default adalah -1, yang menunjukkan bahwa topik tidak pernah kedaluwarsa. |
60 |
Elemen respons
|
Element |
Type |
Description |
Example |
|
object |
Hasil |
||
| requestId |
string |
ID permintaan. Setiap permintaan memiliki ID unik yang dapat digunakan untuk memecahkan masalah dan menemukan lokasi masalah. |
AF9A8B10-C426-530F-A0DD-96320B39**** |
| success |
boolean |
Menunjukkan apakah pemanggilan berhasil. |
true |
| data |
boolean |
Hasil yang dikembalikan. |
true |
| code |
string |
Kode kesalahan. |
Topic.Existed |
| message |
string |
Pesan kesalahan. |
The topic already exists. |
| httpStatusCode |
integer |
Kode status HTTP. |
400 |
| dynamicCode |
string |
Kode kesalahan dinamis. |
TopicName |
| dynamicMessage |
string |
Pesan kesalahan dinamis. |
topicName |
Contoh
Respons sukses
JSONformat
{
"requestId": "AF9A8B10-C426-530F-A0DD-96320B39****",
"success": true,
"data": true,
"code": "Topic.Existed",
"message": "The topic already exists.",
"httpStatusCode": 400,
"dynamicCode": "TopicName",
"dynamicMessage": "topicName"
}
Kode kesalahan
Lihat Error Codes untuk daftar lengkap.
Catatan rilis
Lihat Release Notes untuk daftar lengkap.