Perintah penciptaan topik Kafka yang biasa digunakan

1. Cipta topik menggunakan baris arahan

kafka-topics --create --topic test --partitions 3 --replication-factor 2

Arahan ini akan mencipta topik bernama "ujian" dengan 3 partition dan 2 faktor replikasi. Ini bermakna data akan direplikasi 3 kali pada 2 broker yang berbeza untuk memastikan lebihan dan ketersediaan tinggi.

2. Cipta topik menggunakan Java API

Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092");
AdminClient adminClient = AdminClient.create(props);

NewTopic topic = new NewTopic("test", 3, (short) 2);
adminClient.createTopics(Arrays.asList(topic));

Kod ini akan mencipta topik bernama "ujian" dengan 3 partition dan 2 faktor replikasi.

3 Cipta topik menggunakan API Python

from kafka import KafkaAdminClient

admin_client = KafkaAdminClient(bootstrap_servers="localhost:9092")

topic_list = [
    kafka.admin.NewTopic(name="test", num_partitions=3, replication_factor=2)
]

admin_client.create_topics(new_topics=topic_list, validate_only=False)

Kod ini akan mencipta topik bernama "ujian" dengan 3 partition dan 2 faktor replikasi.

4 Cipta topik menggunakan REST API

curl -X POST -H "Content-Type: application/json" -d '{"name": "test", "partitions": 3, "replication_factor": 2}' http://localhost:8083/topics

Arahan ini akan mencipta topik bernama "ujian" dengan 3 partition dan 2 faktor replikasi.

5 Cipta topik menggunakan UI Kafka

1. Buka UI Kafka di http://localhost:8083.
2. Klik pada tab "Tema".
3. Klik butang "Buat Tema".
4. Dalam medan Nama, masukkan nama untuk tema anda.
5. Dalam medan "Number of Partition", masukkan bilangan partition.
6. Dalam medan "Faktor Replikasi", masukkan faktor replikasi.
7. Klik butang "Buat".

Tema akan dibuat dan anda akan melihatnya dalam senarai tema.

Pilihan lain

Selain kaedah di atas, anda juga boleh mencipta topik menggunakan pilihan berikut:

• Menggunakan [Kafka REST Proxy](https://kafka.apache.org/documentation/#rest_proxy )
• Menggunakan [Pakej Sawa Kafka](https://github.com/dpkp/kafka-python)
• Menggunakan [Pakej Kafka Go](https://github.com/Shopify/sarama)
• Menggunakan [Kafka Pakej Node.js](https://github.com/segmentio/kafka-node)

Nota

• Apabila membuat topik, anda perlu memastikan bahawa nama topik itu unik.
• Anda juga mesti memastikan bahawa bilangan partition dan faktor replikasi adalah serasi dengan keperluan aplikasi anda.
• Jika anda mencipta topik dengan bilangan partition yang banyak, anda mungkin mengalami masalah prestasi.
• Jika anda mencipta topik dengan faktor replikasi yang besar, anda boleh meningkatkan overhed storan.

Atas ialah kandungan terperinci Perintah penciptaan topik Kafka yang biasa digunakan. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!