Periksa status operasional sebuah instans - ApsaraMQ for Kafka

Jika klien SDK tidak dapat mengirim atau menerima pesan, atau gagal terhubung ke instans, gunakan tool Pemeriksaan kesehatan Kafka untuk memverifikasi kesehatan instans tersebut. Tool ini memeriksa konektivitas jaringan dan status instans. Jika tool mengonfirmasi bahwa instans dalam kondisi sehat, periksa koneksi jaringan dan konfigurasi kode pada klien Anda.

Prasyarat

JDK 1.8 atau versi yang lebih baru telah diinstal.
Unduh dan ekstrak tool pemeriksaan kesehatan kafka-checker.zip.
Buat topik dan kelompok konsumen untuk menguji pengiriman dan konsumsi pesan.

Uji konektivitas jaringan

Dapatkan titik akhir (endpoint).
1. Masuk ke ApsaraMQ for Kafka console.
2. Di bagian Resource Distribution pada halaman Overview, pilih wilayah.
3. Pada halaman Instances, klik nama instans target.
4. Di bagian Endpoint Information pada halaman Instance Details, dapatkan titik akhir untuk instans Anda.
  
  Bagian ini menampilkan tiga jenis titik akhir: VPC default endpoint (jaringan VPC, protokol PLAINTEXT), internet SSL endpoint (internet, protokol SASL_SSL), dan VPC SASL endpoint (jaringan VPC, protokol SASL_PLAINTEXT). Pilih dan salin domain titik akhir sesuai dengan kebutuhan koneksi Anda.
  
  Catatan
  Untuk informasi selengkapnya mengenai perbedaan antar titik akhir, lihat Comparison of endpoints.
Jalankan uji telnet untuk memverifikasi konektivitas titik akhir. Contoh berikut menggunakan sistem operasi Linux.
1. Masuk ke sistem Linux Anda dan buka direktori tempat tool KafkaChecker.jar berada.
```
cd /usr/opt/kafka-checker
```
  Ganti /usr/opt/kafka-checker dengan path lokal aktual.
2. Jalankan perintah berikut untuk menguji koneksi ke ApsaraMQ for Kafka.
```
java -jar KafkaChecker.jar telnet -s <endpoint-string>
```
  Sebagai contoh, jika klien Anda terhubung ke ApsaraMQ for Kafka melalui VPC default endpoint, jalankan perintah berikut: 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
  Saat Anda terhubung menggunakan titik akhir Virtual Private Cloud (VPC), perangkat Anda harus berada dalam VPC yang sama dengan instans tersebut.
  Output seperti berikut menunjukkan koneksi jaringan berhasil.
```
telnet xxx 9092  success
telnet xxx:xxx:xxx 9092  success
telnet xxx:xxx:xxx 9092  success
```
  Jika output berikut dikembalikan, daftar putih belum dikonfigurasi untuk instans ApsaraMQ for Kafka. Untuk informasi selengkapnya, lihat Configure a whitelist.
  
  telnet xxx 9092 failure, please add ip to white list in Alikafka console telnet xxx 9092 failure, please add ip to white list in Alikafka console telnet xxx 9092 failure, please add ip to white list in Alikafka console

Uji pengiriman pesan

Catatan

Pengiriman pesan akan menghasilkan data uji. Untuk menghindari dampak pada data produksi, buat topik khusus untuk pengujian pemeriksaan kesehatan.

Jalankan perintah sesuai jenis titik akhir Anda untuk mengirim pesan.

Terhubung melalui VPC default endpoint pada Port 9092:
```
java -jar KafkaChecker.jar send -s <endpoint-domain>:9092 --topic <topic-name>
```
Contoh: java -jar KafkaChecker.jar send -s alikafka-pre-cn-zv**********-1-vpc.alikafka.aliyuncs.com:9092 --topic test
Terhubung melalui internet SSL endpoint pada Port 9093. SASL mendukung otentikasi dengan mekanisme PLAIN atau SCRAM-SHA-256. Jalankan perintah sesuai mekanisme otentikasi Anda.
Catatan
- Di lingkungan internet, pengguna SASL default sebuah instans menggunakan mekanisme PLAIN untuk otentikasi.
- Anda dapat membuat pengguna SASL untuk kontrol akses yang lebih granular dan mengonfigurasi mekanisme otentikasi menjadi PLAIN atau SCRAM-SHA-256. Untuk informasi selengkapnya, lihat Grant permissions to SASL users.
Mekanisme PLAIN
```
java -jar KafkaChecker.jar send -sm PLAIN -ss true -u <username> -psw <password> -s <endpoint-domain>:9093 --topic <topic-name>
```
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 <endpoint-domain>:9093 --topic <topic-name>
```
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
Terhubung melalui VPC SASL endpoint pada Port 9094. SASL mendukung otentikasi dengan mekanisme PLAIN atau SCRAM-SHA-256. Jalankan perintah sesuai mekanisme otentikasi Anda.
Mekanisme PLAIN
```
java -jar KafkaChecker.jar send -sm PLAIN -sp true -u <username> -psw <password> -s <endpoint-domain>:9094 --topic <topic-name>
```
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 <endpoint-domain>:9094 --topic <topic-name>
```
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

Output seperti berikut menunjukkan bahwa pesan berhasil dikirim.

[2021-08-27 11:29:18.838]Produce ok number:0 p:2 offset:21 response:test-2@21 cost:1342 ms
[2021-08-27 11:29:19.252]Produce ok number:1 p:2 offset:22 response:test-2@22 cost:410 ms
[2021-08-27 11:29:19.254]Produce ok number:1 p:6 offset:9 response:test-6@9 cost:412 ms
[2021-08-27 11:29:19.301]Produce ok number:2 p:5 offset:25 response:test-5@25 cost:47 ms
[2021-08-27 11:29:19.302]Produce ok number:2 p:4 offset:20 response:test-4@20 cost:48 ms
[2021-08-27 11:29:19.347]Produce ok number:3 p:1 offset:19 response:test-1@19 cost:45 ms
[2021-08-27 11:29:19.348]Produce ok number:3 p:8 offset:17 response:test-8@17 cost:46 ms

Uji konsumsi pesan

Jalankan perintah sesuai jenis titik akhir Anda untuk mengonsumsi pesan.

Terhubung melalui VPC default endpoint pada Port 9092:
```
java -jar KafkaChecker.jar pull -s <endpoint-domain>:9092 --topic <topic-name> --group <group-name> --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
Terhubung melalui internet SSL endpoint pada Port 9093. SASL mendukung otentikasi dengan mekanisme PLAIN atau SCRAM-SHA-256. Jalankan perintah sesuai mekanisme otentikasi Anda.
Catatan
- Di lingkungan internet, pengguna SASL default sebuah instans menggunakan mekanisme PLAIN untuk otentikasi.
- Anda dapat membuat pengguna SASL untuk kontrol akses yang lebih granular dan mengonfigurasi mekanisme otentikasi menjadi PLAIN atau SCRAM-SHA-256. Untuk informasi selengkapnya, lihat Grant permissions to SASL users.
Mekanisme PLAIN
```
java -jar KafkaChecker.jar pull -sm PLAIN -ss true -u <username> -psw <password> -s <endpoint-domain>:9093 --topic <topic-name> --group <group-name> --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 <endpoint-domain>:9093 --topic <topic-name> --group <group-name> --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
Terhubung melalui VPC SASL endpoint pada Port 9094. SASL mendukung otentikasi dengan mekanisme PLAIN atau SCRAM-SHA-256. Jalankan perintah sesuai mekanisme otentikasi Anda.
Mekanisme PLAIN
```
java -jar KafkaChecker.jar pull -sm PLAIN -sp true -u <username> -psw <password> -s <endpoint-domain>:9094 --topic <topic-name> --group <group-name> --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 <endpoint-domain>:9094 --topic <topic-name> --group <group-name> --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

Output seperti berikut menunjukkan bahwa pesan berhasil dikonsumsi.

[2021-08-27 11:32:37.917]Pull Succ topic:test partition:0 offset:0 key:demo value: time:2021-08-10 15:08:10.629 cha:1455867288
[2021-08-27 11:32:37.918]Pull Succ topic:test partition:0 offset:1 key:demo value: time:2021-08-10 15:16:08.386 cha:1455389532
[2021-08-27 11:32:37.918]Pull Succ topic:test partition:0 offset:2 key:demo value: time:2021-08-10 15:16:50.374 cha:1455347544
[2021-08-27 11:32:37.918]Pull Succ topic:test partition:0 offset:3 key:null value: time:2021-08-18 21:08:23.532 cha:743054386
[2021-08-27 11:32:37.918]Pull Succ topic:test partition:0 offset:4 key:null value: time:2021-08-18 21:08:23.778 cha:743054140
[2021-08-27 11:32:37.918]Pull Succ topic:test partition:0 offset:5 key:null value: time:2021-08-18 21:08:23.892 cha:743054026
[2021-08-27 11:32:37.918]Pull Succ topic:test partition:0 offset:6 key:null value: time:2021-08-18 21:08:24.352 cha:743053566
[2021-08-27 11:32:37.919]Pull Succ topic:test partition:0 offset:7 key:null value: time:2021-08-18 21:08:24.452 cha:743053467

Dokumen terkait

Untuk informasi mengenai paket SDK terkait, lihat SDK overview.

Prasyarat

Uji konektivitas jaringan

Uji pengiriman pesan

Mekanisme PLAIN

Mekanisme SCRAM-SHA-256

Mekanisme PLAIN

Mekanisme SCRAM-SHA-256

Uji konsumsi pesan

Mekanisme PLAIN

Mekanisme SCRAM-SHA-256

Mekanisme PLAIN

Mekanisme SCRAM-SHA-256

Dokumen terkait