Langkah-langkah untuk mencipta topik Kafka: Menggunakan arahan Kafka

Langkah untuk mencipta topik menggunakan arahan Kafka

1. Mulakan perkhidmatan ZooKeeper dan Kafka

zookeeper-server-start.sh config/zookeeper.properties
kafka-server-start.sh config/server.properties

2. Reee

Buat topik

4. Lihat topik

kafka-topics.sh --create --topic my-topic --partitions 3 --replication-factor 1

5. Hantar ke topik Messages

kafka-topics.sh --list

Ambil mesej daripada topik

kafka-console-producer.sh --topic my-topic --message "Hello, world!"

Contoh kod khusus

• kafka-console-consumer.sh --topic my-topic --from-beginning

• Catatan nama topik yang anda perlukan
• , yang bilangan partition, dan bilangan replika.
• Bilangan partition menentukan bilangan mesej yang boleh dikendalikan oleh topik secara serentak.
• Bilangan salinan menentukan bilangan salinan data topik yang ada.

Apabila menghantar mesej ke topik, anda perlu menentukan kunci dan nilai mesej. 🎜🎜Apabila menggunakan mesej daripada topik, anda boleh menentukan kumpulan pengguna. Pengguna dalam kumpulan pengguna akan bersama-sama menggunakan mesej dalam topik tersebut. 🎜🎜

Atas ialah kandungan terperinci Langkah-langkah untuk mencipta topik Kafka: Menggunakan arahan Kafka. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!