今天是:125年6月11日 星期三 歡迎光臨郝學武的blog。

          kafka配置舉例

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

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


          網(wǎng)站導(dǎo)航:
           

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

          Copyright © 陜西BOY

          主站蜘蛛池模板: 南京市| 库伦旗| 泸水县| 平阳县| 寿宁县| 建水县| 平湖市| 寿光市| 鄂伦春自治旗| 辉南县| 五华县| 昌黎县| 河北省| 会泽县| 个旧市| 沅陵县| 凤山县| 铅山县| 临沭县| 平潭县| 延寿县| 环江| 康乐县| 井研县| 平湖市| 竹北市| 民县| 阿合奇县| 永善县| 哈尔滨市| 榆中县| 南乐县| 乐东| 黄浦区| 青岛市| 大足县| 于田县| 望都县| 保德县| 石城县| 鄢陵县|