通常需要創(chuàng)建自定義分區(qū)的topic 可以使用以下方法創(chuàng)建名稱為test,12個分區(qū)3份副本的topic
成都創(chuàng)新互聯(lián)公司是一家專業(yè)提供青海企業(yè)網(wǎng)站建設(shè),專注與成都網(wǎng)站建設(shè)、網(wǎng)站建設(shè)、HTML5、小程序制作等業(yè)務(wù)。10年已為青海眾多企業(yè)、政府機構(gòu)等服務(wù)。創(chuàng)新互聯(lián)專業(yè)網(wǎng)絡(luò)公司優(yōu)惠進行中。
from kafka.admin import KafkaAdminClient, NewTopic
c = KafkaAdminClient(bootstrap_servers="localhost:9092")
topic_list = []
topic_list.append(NewTopic(name="test", num_partitions=12, replication_factor=3))
c.create_topics(new_topics=topic_list, validate_only=False)
當(dāng)前名稱:使用python創(chuàng)建自定義分區(qū)的topic
標(biāo)題路徑:http://sd-ha.com/article44/jgijhe.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供云服務(wù)器、標(biāo)簽優(yōu)化、小程序開發(fā)、網(wǎng)站設(shè)計、網(wǎng)站營銷、建站公司
聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請盡快告知,我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場,如需處理請聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時需注明來源: 創(chuàng)新互聯(lián)