Untuk migrasi cloud atau pengujian, Anda dapat mengaktifkan pembuatan Group otomatis agar Group dapat dibuat langsung dari kode Anda. Fitur ini menghilangkan kebutuhan untuk membuat Group secara manual di Konsol, sehingga menyederhanakan operasi dan meningkatkan efisiensi.
Prasyarat
Anda telah membeli dan menerapkan instans ApsaraMQ for Kafka. Instans tersebut harus memenuhi kondisi berikut:
Item | Description |
Status | Running. |
Version | Versi utama adalah 2.2.0, dan versi minor adalah yang terbaru. |
Anda dapat melihat status dan versi instans di bagian Basic Information pada halaman Instance Details di Konsol ApsaraMQ for Kafka.
Perhatian
Di lingkungan produksi, jangan biarkan fitur pembuatan Group otomatis tetap aktif dalam jangka waktu lama. Penggunaan yang tidak tepat oleh klien dapat menyebabkan konsumsi resource yang tidak terkendali, meningkatkan biaya O&M, dan berpotensi menyebabkan ketidakstabilan sistem. Buat Group secara manual di Konsol ApsaraMQ for Kafka atau dengan memanggil OpenAPI untuk mengelolanya secara terpusat. Untuk informasi selengkapnya, lihat Create a Group dan CreateConsumerGroup.
Prosedur
Masuk ke ApsaraMQ for Kafka console. Pada halaman Overview, pilih wilayah di bagian Resource Distribution.
Pada halaman Instances, klik nama instans target.
Di bagian Configuration Information, aktifkan sakelar Flexible Group Creation.
PentingNama Group kustom harus mengikuti Konvensi penamaan Group:
Panjang nama Group harus antara 3 hingga 128 karakter.
Nama Group hanya boleh terdiri dari huruf, angka, tanda hubung (-), dan garis bawah (_). Nama tersebut harus mengandung setidaknya satu huruf atau angka.
Jumlah Group yang dibuat secara otomatis tidak boleh melebihi batas spesifikasi instans ApsaraMQ for Kafka Anda. Jika batas tercapai, Group tidak dapat dibuat secara otomatis. Untuk informasi selengkapnya, lihat Limits.
Setelah Anda mengaktifkan pembuatan Group otomatis di Konsol ApsaraMQ for Kafka, Group yang dibuat secara otomatis akan ditampilkan di halaman Groups dengan deskripsi "Automatically created."
Untuk Group yang dibuat menggunakan fitur ini, informasi Group yang sesuai akan ditampilkan di halaman Groups di Konsol. Kolom Auto Creation diatur ke Yes.
Saat fitur Flexible Group Creation diaktifkan, ApsaraMQ for Kafka mengizinkan group yang tidak dibuat di Konsol untuk memanggil API guna melakukan operasi seperti konsumsi pesan dan commit offset. Jika fitur ini dinonaktifkan, group yang tidak dibuat di Konsol tidak dapat mengonsumsi pesan. Nonaktifkan fitur ini dengan hati-hati.
Menonaktifkan pembuatan Group otomatis adalah proses asinkron. Selama proses ini, node tidak direstart. Status instans berubah menjadi Upgrading. Setelah fitur dinonaktifkan, status kembali menjadi In Service. Hindari pembuatan Group baru secara otomatis selama proses penonaktifan fitur ini.
Jika Anda tidak mengaktifkan pembuatan Group otomatis tetapi menggunakan metode Assign untuk melakukan commit offset konsumen, Group yang sesuai tetap akan dibuat di kluster Kafka. Kemampuan ini diaktifkan secara default. Untuk menonaktifkannya, ajukan ticket.
Sisi server membersihkan Group yang dibuat secara otomatis setelah offset konsumennya kedaluwarsa.
Setelah Anda mengaktifkan penggunaan bebas untuk Group, Anda dapat memanggil API di sisi konsumen untuk menggunakan Group tersebut. Contoh kodenya sebagai berikut:
props.put(ConsumerConfig.GROUP_ID_CONFIG, "newConsumerGroup"); consumer.subscribe(Collections.singletonList("newTopicName")); // Jika Group belum ada dan namanya valid, Group tersebut akan dibuat secara otomatis. consumer.poll(Duration.ofSeconds(1));
Referensi
Setelah Anda menggunakan Group yang dibuat secara otomatis untuk berlangganan topik, Anda dapat melihat Group yang berlangganan ke topik tersebut di Konsol. Untuk informasi selengkapnya, lihat View Groups subscribed to a topic.
Untuk membuat Group menggunakan Konsol atau API, lihat Create a Group dan CreateConsumerGroup.