Rumah >Java >javaTutorial >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
Tema akan dibuat dan anda akan melihatnya dalam senarai tema.
Pilihan lain
Selain kaedah di atas, anda juga boleh mencipta topik menggunakan pilihan berikut:
Nota
Atas ialah kandungan terperinci Perintah penciptaan topik Kafka yang biasa digunakan. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!