亚洲免费在线-亚洲免费在线播放-亚洲免费在线观看-亚洲免费在线观看视频-亚洲免费在线看-亚洲免费在线视频

如何使用python編程創建kafka的topic

系統 3222 0
閱讀更多

You can programmatically create topics either using? kafka-python ?or? confluent_kafka ?client which is a lightweight wrapper around?librdkafka.

Using? kafka-python

              
                
                  from
                
                
                   kafka
                
                
                  .
                
                
                  admin 
                
                
                  import
                
                
                  KafkaAdminClient
                
                
                  ,
                
                
                  NewTopic
                
                
                  
admin_client 
                
                
                  =
                
                
                  KafkaAdminClient
                
                
                  (
                
                
                  bootstrap_servers
                
                
                  =
                
                
                  "localhost:9092"
                
                
                  ,
                
                
                   client_id
                
                
                  =
                
                
                  'test'
                
                
                  )
                
                
                  

topic_list 
                
                
                  =
                
                
                  []
                
                
                  
topic_list
                
                
                  .
                
                
                  append
                
                
                  (
                
                
                  NewTopic
                
                
                  (
                
                
                  name
                
                
                  =
                
                
                  "example_topic"
                
                
                  ,
                
                
                   num_partitions
                
                
                  =
                
                
                  1
                
                
                  ,
                
                
                   replication_factor
                
                
                  =
                
                
                  1
                
                
                  ))
                
                
                  
admin_client
                
                
                  .
                
                
                  create_topics
                
                
                  (
                
                
                  new_topics
                
                
                  =
                
                
                  topic_list
                
                
                  ,
                
                
                   validate_only
                
                
                  =
                
                
                  False
                
                
                  )
                
              
            

Using? confluent_kafka

              
                
                  from
                
                
                   confluent_kafka
                
                
                  .
                
                
                  admin 
                
                
                  import
                
                
                  AdminClient
                
                
                  ,
                
                
                  NewTopic
                
                
                  
admin_client 
                
                
                  =
                
                
                  AdminClient
                
                
                  ({
                
                
                  "bootstrap_servers"
                
                
                  :
                
                
                  "localhost:9092"
                
                
                  })
                
                
                  

topic_list 
                
                
                  =
                
                
                  []
                
                
                  
topic_list
                
                
                  .
                
                
                  append
                
                
                  (
                
                
                  NewTopic
                
                
                  (
                
                
                  "example_topic"
                
                
                  ,
                
                
                  1
                
                
                  ,
                
                
                  1
                
                
                  ))
                
                
                  
admin_client
                
                
                  .
                
                
                  create_topics
                
                
                  (
                
                
                  topic_list
                
                
                  )
                
              
            
?

更多文章、技術交流、商務合作、聯系博主

微信掃碼或搜索:z360901061

微信掃一掃加我為好友

QQ號聯系: 360901061

您的支持是博主寫作最大的動力,如果您喜歡我的文章,感覺我的文章對您有幫助,請用微信掃描下面二維碼支持博主2元、5元、10元、20元等您想捐的金額吧,狠狠點擊下面給點支持吧,站長非常感激您!手機微信長按不能支付解決辦法:請將微信支付二維碼保存到相冊,切換到微信,然后點擊微信右上角掃一掃功能,選擇支付二維碼完成支付。

【本文對您有幫助就好】

您的支持是博主寫作最大的動力,如果您喜歡我的文章,感覺我的文章對您有幫助,請用微信掃描上面二維碼支持博主2元、5元、10元、自定義金額等您想捐的金額吧,站長會非常 感謝您的哦?。。?/p>

發表我的評論
最新評論 總共0條評論
主站蜘蛛池模板: 欧美精品videossex最新 | 国产成人综合久久综合 | 在线免费观看一区二区三区 | 国产成人a视频在线观看 | 国产精品久久久久毛片真精品 | 久久精品国产eeuss | 国产免费一级高清淫曰本片 | 成人久久18免费网 | 中文字幕一区二区区免 | 国产一区亚洲一区 | 国产精品香蕉在线观看不卡 | 欧美亚洲综合在线 | 成在线人永久免费播放视频 | 四虎国产精品一区二区 | 国产911情侣拍拍在线播放 | 九九99久久精品午夜剧场免费 | 国产精品久久久久一区二区 | 亚洲成人在线观看视频 | 福利精品| 免费的毛片网站 | 淫综合网| 国产综合视频在线 | 欧美日韩高清观看一区二区 | 国产成人毛片精品不卡在线 | 国产精品免费视频能看 | 国产蜜汁tv福利在线 | 欧美性色福利视频在线观看 | 亚洲黑人巨大videos0 | 五月天婷婷视频 | 欧美孕妇乱大交xxxxx | 97视频在线 | 99热这里只有精品88 | 一本色道久久综合狠狠躁 | 久久伊人中文字幕有码 | 欧美成人亚洲 | 色综合激情网 | 国产高清精品自在久久 | 一级毛片欧美一级日韩黄 | 香蕉视频亚洲一级 | 久久久久综合网 | 久久日精品 |