1. 使用命令列建立主題
kafka-topics --create --topic test --partitions 3 --replication-factor 2
此命令將建立一個名為「test」的主題,該主題具有3 個分區和2 個副本因子。這意味著資料將在 2 個不同的代理程式上複製 3 次,以確保冗餘和高可用性。
2. 使用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));
此程式碼將建立一個名為「test」的主題,該主題具有3 個分割區和2 個副本因子。
3. 使用Python API 建立主題
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)
此程式碼將建立一個名為「test」的主題,該主題具有3 個分割區和2 個副本因子。
4. 使用REST API 建立主題
curl -X POST -H "Content-Type: application/json" -d '{"name": "test", "partitions": 3, "replication_factor": 2}' http://localhost:8083/topics
此指令將建立一個名為「test」的主題,該主題具有3 個分割區和2 個副本因子。
5. 使用 Kafka UI 建立主題
主題將被創建,您將在主題清單中看到它。
其他選項
除了上述方法之外,您還可以使用下列選項建立主題:
注意事項
以上是常用的Kafka主題創建指令的詳細內容。更多資訊請關注PHP中文網其他相關文章!