<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 閱讀(265) 評論(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

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


    網站導航:
     

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

    Copyright © 陜西BOY

    主站蜘蛛池模板: 亚洲最新在线视频| av无码久久久久不卡免费网站| 亚洲欧洲另类春色校园网站| 亚洲中文字幕久久精品无码APP| 久久不见久久见免费影院| 免费无码H肉动漫在线观看麻豆| 苍井空亚洲精品AA片在线播放| 亚洲国产美女在线观看| 国产亚洲av片在线观看播放 | 久久亚洲国产午夜精品理论片| 日本成人免费在线| h视频在线免费看| 国产精品免费福利久久| 成在人线av无码免费高潮水| 边摸边吃奶边做爽免费视频网站| 亚洲国产欧洲综合997久久| 亚洲人和日本人jizz| 77777_亚洲午夜久久多人| 亚洲AV综合色区无码一区 | 羞羞网站在线免费观看| 亚洲自偷自偷在线成人网站传媒| 亚洲熟妇色自偷自拍另类| 亚洲男人天堂av| 久久精品夜色国产亚洲av| 亚洲精品无码mv在线观看网站| 红杏亚洲影院一区二区三区| 亚洲日韩中文字幕日韩在线| 免费v片在线观看| 亚洲av无码专区在线观看素人| 免费被黄网站在观看| 在线免费观看国产视频| 在线永久免费观看黄网站| 国产免费拔擦拔擦8x| 免费一级毛片一级毛片aa| 亚洲黄黄黄网站在线观看| 亚洲区日韩区无码区| 亚洲国产综合久久天堂| 日韩亚洲变态另类中文| 亚洲精品你懂的在线观看| 无码乱人伦一区二区亚洲一| 亚洲一二成人精品区|