<rt id="bn8ez"></rt>
<label id="bn8ez"></label>

  • <span id="bn8ez"></span>

    <label id="bn8ez"><meter id="bn8ez"></meter></label>

    歡迎光臨郝學武的blog。

    kafka配置舉例

    Posted on 2014-01-08 12:08 陜西BOY 閱讀(267) 評論(0)  編輯  收藏 所屬分類: kafka
    ##broker標識,id為正數,且全局不得重復.  
    broker.id=0
    ##日志文件保存的目錄  推薦放到存儲大的盤目錄
    log.dirs=/opt/kafkadata/logs  
    ##broker需要使用zookeeper保存meata信息,因此broker為zk  
    ##此處為zookeeper集群的connectString,后面可以跟上path
    ##不過需要注意,path的全路徑需要有自己來創建(使用zookeeper腳本工具)  
    zookeeper.connect=hostname1:port1,hostname2:port2/kafka  
    ##用來偵聽鏈接的端口,prudcer或consumer將在此端口建立鏈接  
    port=10000
    ##指定broker實例綁定的網絡接口地址  
    host.name=ip  
    ##每個topic默認partition的個數,默認為1
    num.partitions=2  
    ##日志文件中每個segment文件的尺寸,默認為1G  
    ##log.segment.bytes=1024*1024*1024  
    ##滾動生成新的segment文件的最大時間  
    ##log.roll.hours=24*7  
    ##segment文件保留的最長時間,超時將被刪除  
    ##log.retention.hours=24*7  
    ##partiton中buffer中,消息的條數,達到閥值,將觸發flush到磁盤.  
    log.flush.interval.messages=30000  
    #消息buffer的時間,達到閥值,將觸發flush到磁盤.  
    log.flush.interval.ms=5000  
    ##partition leader等待follower同步消息的最大時間,  
    ##如果超時,leader將follower移除同步列表  
    replica.lag.time.max.ms=10000  
    ##消息的備份的個數,默認為1,通常使用在replication-cluster環境中  
    ##kafka-cluster已經具備自動故障轉移能力(>0.8V)  
    num.replica.fetchers=1

    只有注冊用戶登錄后才能發表評論。


    網站導航:
    博客園   IT新聞   Chat2DB   C++博客   博問  
     

    posts - 17, comments - 65, trackbacks - 0, articles - 28

    Copyright © 陜西BOY

    主站蜘蛛池模板: 一区二区三区亚洲视频| 一级午夜免费视频| 99热免费在线观看| 久久精品国产亚洲AV高清热| 免费萌白酱国产一区二区| 亚洲中文久久精品无码1| 国产成人精品免费视频动漫| 在线观看亚洲一区二区| 天天影院成人免费观看| 亚洲一区二区三区不卡在线播放| 久久久久久国产a免费观看黄色大片 | 亚洲三级电影网站| 十八禁无码免费网站| 亚洲色图校园春色| 我想看一级毛片免费的| 亚洲精品无码少妇30P| 免费看美女让人桶尿口| 男女交性无遮挡免费视频| 国产亚洲色视频在线| 久久久久久成人毛片免费看| 亚洲精品成人图区| 成人精品一区二区三区不卡免费看| 亚洲一区精品无码| 亚洲一区二区三区免费观看| 国产精品亚洲自在线播放页码 | 99久久精品日本一区二区免费| 亚洲国产电影在线观看| 全免费一级毛片在线播放| 一级特黄录像免费播放中文版| 久久精品国产亚洲av麻| 最新中文字幕免费视频| 中出五十路免费视频| 亚洲国产一区在线观看| 亚洲一区二区三区免费| 日韩欧美亚洲中文乱码| 亚洲精品无码久久一线| 亚洲三级高清免费| 一个人看的免费视频www在线高清动漫 | 精品国产亚洲一区二区三区| 国产妇乱子伦视频免费| 男人扒开添女人下部免费视频 |