全部产品
Search

搜索本产品

    ApsaraMQ for Kafka：Lakukan pemeriksaan kesehatan pada instance ApsaraMQ for Kafka

    文档中心

    ApsaraMQ for Kafka：Lakukan pemeriksaan kesehatan pada instance ApsaraMQ for Kafka

    更新时间：Jul 06, 2025

    Jika pesan tidak dapat dikirim atau diterima, atau koneksi tidak dapat dibuat saat menggunakan SDK untuk terhubung ke instance ApsaraMQ for Kafka guna mengirim dan menerima pesan, Anda dapat menggunakan alat pemeriksaan mandiri yang disediakan oleh ApsaraMQ for Kafka untuk memeriksa kesehatan instance. Pemeriksaan ini membantu menentukan apakah jaringan terhubung, instance berfungsi dengan baik, dan konfigurasi kode klien sudah benar.

    Prasyarat

    • JDK 1.8 atau versi lebih baru telah diinstal. Untuk informasi lebih lanjut, lihat Java Downloads.

    • Alat pemeriksaan mandiri kafka-checker.zip telah diunduh dan diekstrak.

    • Sebuah topik dan grup konsumen telah dibuat pada instance ApsaraMQ for Kafka. Untuk informasi lebih lanjut, lihat Langkah 3: Buat Sumber Daya. Topik dan grup konsumen digunakan untuk menguji produksi dan konsumsi pesan.

    Uji konektivitas jaringan

    1. Dapatkan titik akhir dari instance ApsaraMQ for Kafka.

      1. Masuk ke Konsol ApsaraMQ for Kafka.

      2. Di bagian Resource Distribution pada halaman Overview, pilih wilayah tempat instance ApsaraMQ for Kafka yang ingin dikelola berada.

      3. Pada halaman Instances, klik nama instance yang ingin dikelola.

      4. Di bagian Endpoint Information pada halaman Instance Details, lihat titik akhir dari instance tersebut.

        endpoint

        Catatan

        Untuk informasi tentang perbedaan antar jenis titik akhir, lihat Perbandingan Antar Titik Akhir.

    2. Gunakan telnet untuk menguji konektivitas jaringan. Dalam contoh ini, sistem operasi Linux digunakan.

      1. Masuk ke sistem operasi Linux dan masukkan jalur tempat alat KafkaChecker.jar berada.

        cd /usr/opt/kafka-checker

        Ganti /usr/opt/kafka-checker dengan jalur lokal sebenarnya.

      2. Jalankan perintah berikut untuk menguji apakah klien dapat terhubung ke ApsaraMQ for Kafka:

        java -jar KafkaChecker.jar telnet -s Endpoint

        Sebagai contoh, jika klien terhubung ke instance ApsaraMQ for Kafka melalui virtual private cloud (VPC) menggunakan titik akhir default, jalankan java -jar KafkaChecker.jar telnet -s alikafka-pre-cn-zv**********-1-vpc.alikafka.aliyuncs.com:9092,alikafka-pre-cn-zv**********-2-vpc.alikafka.aliyuncs.com:9092,alikafka-pre-cn-zv**********-3-vpc.alikafka.aliyuncs.com:9092.

        Catatan

        Jika klien terhubung ke instance ApsaraMQ for Kafka melalui VPC menggunakan titik akhir default, pastikan bahwa klien dan instance berada dalam VPC yang sama.

        Jika informasi serupa dengan gambar berikut dikembalikan, jaringan terhubung.VPC

        Jika informasi serupa dengan gambar berikut dikembalikan, daftar putih titik akhir belum dikonfigurasikan untuk instance ApsaraMQ for Kafka. Untuk informasi tentang cara mengonfigurasi daftar putih, lihat Konfigurasikan Daftar Putih.WhiteList

    Uji pengiriman pesan

    Catatan

    Jika sebuah pesan dikirim, data uji nyata akan dihasilkan. Anda harus membuat topik yang secara khusus digunakan untuk pemeriksaan mandiri untuk mencegah dampak pada data bisnis nyata.

    Jalankan salah satu perintah berikut untuk mengirim pesan berdasarkan tipe jaringan:

    • Jika klien terhubung ke instance ApsaraMQ for Kafka menggunakan titik akhir default dan port 9092, jalankan perintah berikut:

      java -jar KafkaChecker.jar send -s endpoint: 9092 --topic Nama topik

      Contoh: java -jar KafkaChecker.jar send -s alikafka-pre-cn-zv**********-1-vpc.alikafka.aliyuncs.com:9092 --topic test

    • Jika klien terhubung ke instance ApsaraMQ for Kafka melalui Internet menggunakan titik akhir Secure Sockets Layer (SSL) dan port 9093, Simple Authentication and Security Layer (SASL) memungkinkan Anda menggunakan mekanisme PLAIN atau SCRAM-SHA-256 untuk otentikasi. Dalam hal ini, jalankan perintah yang sesuai dengan mekanisme otentikasi untuk mengirim pesan.

      Catatan

      • Jika klien terhubung ke instance ApsaraMQ for Kafka melalui Internet, pengguna SASL default dari instance menggunakan mekanisme PLAIN untuk otentikasi.

      • Anda dapat membuat pengguna Simple Authentication and Security Layer (SASL) untuk melakukan kontrol akses granular. Anda dapat menentukan mekanisme otentikasi sebagai PLAIN atau SCRAM-SHA-256. Untuk informasi lebih lanjut, lihat Berikan Izin kepada Pengguna SASL. Anda harus menjalankan perintah yang sesuai dengan mekanisme otentikasi untuk mengirim pesan.

      Mekanisme PLAIN

      java -jar KafkaChecker.jar send -sm PLAIN -ss true -u username -psw password -s Nama domain titik akhir:9093 --topic Nama topik

      Contoh: java -jar KafkaChecker.jar send -sm PLAIN -ss true -u test -psw test**** -s alikafka-pre-cn-zv**********-1.alikafka.aliyuncs.com:9093 --topic test

      Mekanisme SCRAM-SHA-256

      java -jar KafkaChecker.jar send -sm SCRAM-SHA-256 -ss true -u username -psw password -s Nama domain titik akhir:9093 --topic Nama topik

      Contoh: java -jar KafkaChecker.jar send -sm SCRAM-SHA-256 -ss true -u test -psw test**** -s alikafka-pre-cn-zv**********-1.alikafka.aliyuncs.com:9093 --topic test

    • Jika klien terhubung ke instance ApsaraMQ for Kafka melalui VPC menggunakan titik akhir SSL dan port 9094, SASL memungkinkan Anda menggunakan mekanisme PLAIN atau SCRAM-SHA-256 untuk otentikasi. Dalam hal ini, jalankan perintah yang sesuai dengan mekanisme otentikasi untuk mengirim pesan.

      Mekanisme PLAIN

      java -jar KafkaChecker.jar send -sm PLAIN -sp true -u username -psw password -s Nama domain titik akhir:9094 --topic Nama topik

      Contoh: java -jar KafkaChecker.jar send -sm PLAIN -sp true -u test -psw test**** -s alikafka-pre-cn-zv**********-1-vpc.alikafka.aliyuncs.com:9094 --topic test

      Mekanisme SCRAM-SHA-256

      java -jar KafkaChecker.jar send -sm SCRAM-SHA-256 -sp true -u username -psw password -s Nama domain titik akhir:9094 --topic Nama topik

      Contoh: java -jar KafkaChecker.jar send -sm SCRAM-SHA-256 -sp true -u test -psw test**** -s alikafka-pre-cn-zv**********-1-vpc.alikafka.aliyuncs.com:9094 --topic test

    Jika informasi serupa dengan gambar berikut dikembalikan, pesan telah dikirim.result

    Uji konsumsi pesan

    Jalankan salah satu perintah berikut untuk mengonsumsi pesan berdasarkan tipe jaringan:

    • Jika klien terhubung ke instance ApsaraMQ for Kafka menggunakan titik akhir default dan port 9092, jalankan perintah berikut:

      java -jar KafkaChecker.jar pull -s Nama domain titik akhir:9092 --topic Nama topik --group Nama grup --partition 0 --offset 0 --count 10

      Contoh: java -jar KafkaChecker.jar pull -s alikafka-pre-cn-zv**********-1-vpc.alikafka.aliyuncs.com:9092 --topic test --group test --partition 0 --offset 0 --count 10

    • Jika klien terhubung ke instance ApsaraMQ for Kafka melalui Internet menggunakan titik akhir SSL dan port 9093, SASL memungkinkan Anda menggunakan mekanisme PLAIN atau SCRAM-SHA-256 untuk otentikasi. Dalam hal ini, jalankan perintah yang sesuai dengan mekanisme otentikasi untuk mengonsumsi pesan.

      Catatan

      • Jika klien terhubung ke instance ApsaraMQ for Kafka melalui Internet, pengguna SASL default dari instance menggunakan mekanisme PLAIN untuk otentikasi.

      • Anda dapat membuat pengguna SASL untuk melakukan kontrol akses granular. Anda dapat menentukan mekanisme otentikasi sebagai PLAIN atau SCRAM-SHA-256. Untuk informasi lebih lanjut, lihat Berikan Izin kepada Pengguna SASL. Anda harus menjalankan perintah yang sesuai dengan mekanisme otentikasi untuk mengonsumsi pesan.

      Mekanisme PLAIN

      java -jar KafkaChecker.jar pull -sm PLAIN -ss true -u username -psw password -s Nama domain titik akhir:9093 --topic Nama topik --group Nama grup --partition 0 --offset 0 --count 10

      Contoh: java -jar KafkaChecker.jar pull -sm PLAIN -ss true -u test -psw test**** -s alikafka-pre-cn-zv**********-1.alikafka.aliyuncs.com:9093 --topic test --group test --partition 0 --offset 0 --count 10

      Mekanisme SCRAM-SHA-256

       java -jar KafkaChecker.jar pull -sm SCRAM-SHA-256 -ss true -u username -psw password -s Nama domain titik akhir:9093 --topic Nama topik --group Nama grup --partition 0 --offset 0 --count 10

      Contoh: java -jar KafkaChecker.jar pull -sm SCRAM-SHA-256 -ss true -u test -psw test**** -s alikafka-pre-cn-zv**********-1.alikafka.aliyuncs.com:9093 --topic test --group test --partition 0 --offset 0 --count 10

    • Jika klien terhubung ke instance ApsaraMQ for Kafka melalui VPC menggunakan titik akhir SSL dan port 9094, SASL memungkinkan Anda menggunakan mekanisme PLAIN atau SCRAM-SHA-256 untuk otentikasi. Dalam hal ini, jalankan perintah yang sesuai dengan mekanisme otentikasi untuk mengonsumsi pesan.

      Mekanisme PLAIN

      java -jar KafkaChecker.jar pull -sm PLAIN -sp true -u username -psw password -s Nama domain titik akhir:9094 --topic Nama topik --group Nama grup --partition 0 --offset 0 --count 10

      Contoh: java -jar KafkaChecker.jar pull -sm PLAIN -sp true -u test -psw test**** -s alikafka-pre-cn-zv**********-1-vpc.alikafka.aliyuncs.com:9094 --topic test --group test --partition 0 --offset 0 --count 10

      Mekanisme SCRAM-SHA-256

       java -jar KafkaChecker.jar pull -sm SCRAM-SHA-256 -sp true -u username -psw password -s Nama domain titik akhir:9094 --topic Nama topik --group Nama grup --partition 0 --offset 0 --count 10

      Contoh: java -jar KafkaChecker.jar pull -sm SCRAM-SHA-256 -sp true -u test -psw test**** -s alikafka-pre-cn-zv**********-1-vpc.alikafka.aliyuncs.com:9094 --topic test --group test --partition 0 --offset 0 --count 10

    Jika informasi serupa dengan gambar berikut dikembalikan, pesan telah dikonsumsi.consumer

    Referensi

    Untuk informasi tentang paket kode SDK terkait, lihat Gambaran Umum.