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

如何使用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條評論
主站蜘蛛池模板: 四虎国产精品一区二区 | 最新国产在线视频 | 四虎影视永久免费视频观看 | 爱操视频在线观看 | 就要爱综合 | 日韩欧美一区二区在线观看 | chinese国产人妖视频网站 | 99久久免费国产精品热 | 操日日 | 欧美一区二区影院 | 国产97公开成人免费视频 | 国内精品免费网站牛牛 | 国产成人亚洲综合a∨婷婷 国产成人亚洲综合欧美一部 | 一级成人毛片免费观看欧美 | 天天干天天操天天干 | 天天干天天拍天天射天天添天天爱 | 八戒久久精品一区二区三区 | 欧美jizzhd欧美巨大 | 66精品综合久久久久久久 | 成人欧美视频 | 五月天婷婷在线免费观看 | 日韩久久一区二区三区 | 高清国产性色视频在线 | 国产精品亚洲专区在线观看 | 国产一级淫片a视频免费观看 | 99成人| 久久国产精品-国产精品 | 国产精品入口麻豆高清在线 | 日本免费新一区二区三区 | 牛牛色婷婷在线视频播放 | 日韩精品欧美成人 | 可以免费观看的一级毛片 | 亚洲午夜在线观看 | 久久人视频 | 国产在线激情 | 免费国产午夜在线观看 | 色婷婷色婷婷 | 国产精品1区2区3区 国产精品1区2区3区在线播放 | 成 人 黄 色| 久久一本热 | 鲁丝丝国产一区二区 |