Menggunakan alat skrip Apache Kafka open source untuk terhubung ke mesin streaming Lindorm -

API untuk mesin streaming Lindorm sepenuhnya kompatibel dengan API untuk Apache Kafka open source. Anda dapat menggunakan alat skrip Apache Kafka open source untuk terhubung ke mesin streaming Lindorm. Topik ini menjelaskan cara menggunakan alat skrip tersebut.

Prasyarat

Java Development Kit (JDK) versi 1.7 atau yang lebih baru telah diinstal.
Alamat IP klien Anda telah ditambahkan ke daftar putih instance ApsaraDB for Lindorm (Lindorm). Untuk informasi lebih lanjut, lihat Konfigurasi Daftar Putih.
Nilai Lindorm Stream Kafka Endpoint telah diperoleh. Untuk informasi lebih lanjut, lihat Lihat Titik Akhir.
Catatan
Lindorm Stream Kafka Endpoint menentukan sebuah titik akhir virtual private cloud (VPC) dari mesin streaming Lindorm Anda. Pastikan bahwa aplikasi Anda dan instance Lindorm Anda berada dalam VPC yang sama.

Prosedur

Klik di sini untuk mengunduh alat skrip Apache Kafka open source.
Ekstrak alat skrip Apache Kafka open source yang telah diunduh.
```
tar -zxf kafka_2.12-2.7.1.tgz
cd kafka_2.12-2.7.1
```

Buat sebuah topik.

./bin/kafka-topics.sh --bootstrap-server <Lindorm Stream Kafka Endpoint> --topic <Nama Topik> --partitions <Jumlah Partisi> --create

Lihat semua topik yang ada.

./bin/kafka-topics.sh --bootstrap-server <Lindorm Stream Kafka Endpoint> --list

Hapus sebuah topik. Jika Anda menghapus sebuah topik, data di dalam topik tersebut juga akan dihapus.

./bin/kafka-topics.sh --bootstrap-server <Lindorm Stream Kafka Endpoint> --topic <Nama Topik> --delete

Baca data dari sebuah topik.

./bin/kafka-console-consumer.sh --bootstrap-server <Lindorm Stream Kafka Endpoint> --topic <Nama Topik> --from-beginning --max-messages <Jumlah Pesan yang Dibaca>

Tulis data ke sebuah topik.

./bin/kafka-console-producer.sh --bootstrap-server <Lindorm Stream Kafka Endpoint> --topic <Nama Topik>

Periksa status konsumsi grup konsumen.

./bin/kafka-consumer-groups.sh --bootstrap-server <Lindorm Stream Kafka Endpoint> --group <Nama Grup> --describe