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

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

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

    隨筆-314  評論-209  文章-0  trackbacks-0
    一、前言
        早上醒來打開微信,同事反饋kafka集群從昨天凌晨開始寫入頻繁失敗,趕緊打開電腦查看了kafka集群的機器監控,日志信息,發現其中一個節點的集群負載從昨天凌晨突然掉下來了,和同事反饋的時間點大概一致,于是乎就登錄服務器開始干活。
    二、排錯
    1、查看機器監控,看是否能大概定位是哪個節點有異常
    技術分享
    2、根據機器監控大概定位到其中一個異常節點,登錄服務器查看kafka日志,發現有報錯日志,并且日志就停留在這個這個時間點:
    [2017-06-01 16:59:59,851] ERROR Processor got uncaught exception. (kafka.network.Processor)
    java.lang.OutOfMemoryError: Direct buffer memory
            at java.nio.Bits.reserveMemory(Bits.java:658)
            at java.nio.DirectByteBuffer.<init>(DirectByteBuffer.java:123)
            at java.nio.ByteBuffer.allocateDirect(ByteBuffer.java:306)
            at sun.nio.ch.Util.getTemporaryDirectBuffer(Util.java:174)
            at sun.nio.ch.IOUtil.read(IOUtil.java:195)
            at sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:379)
            at org.apache.kafka.common.network.PlaintextTransportLayer.read(PlaintextTransportLayer.java:108)
            at org.apache.kafka.common.network.NetworkReceive.readFromReadableChannel(NetworkReceive.java:97)
            at org.apache.kafka.common.network.NetworkReceive.readFrom(NetworkReceive.java:71)
            at org.apache.kafka.common.network.KafkaChannel.receive(KafkaChannel.java:160)
            at org.apache.kafka.common.network.KafkaChannel.read(KafkaChannel.java:141)
            at org.apache.kafka.common.network.Selector.poll(Selector.java:286)
            at kafka.network.Processor.run(SocketServer.scala:413)3、查看kafka進程和監聽端口情況,發現都正常,尼瑪假死了
    ps -ef |grep kafka        ## 查看kafka的進程
    netstat -ntlp |grep 9092  ##9092kafka的監聽端口4、既然已經假死了,只能重啟了
    ps -ef |grep kafka |grep -v grep |awk ‘{print $2}‘  | xargs kill -9  
    /usr/local/kafka/bin;nohup ./kafka-server-start.sh ../config/server.properties &5、重啟后在觀察該節點的kafka日志,在一頓index重建之后,上面的報錯信息在瘋狂的刷,最后谷歌一番,解決了該問題
    三、解決方案:
    /usr/local/kafka/binkafka-run-class.sh去掉
    -XX:+DisableExplicitGC添加
    -XX:MaxDirectMemorySize=512m在一次重啟kafka,問題解決。
    posted on 2018-03-08 16:35 xzc 閱讀(2177) 評論(0)  編輯  收藏 所屬分類: hadoop
    主站蜘蛛池模板: 100部毛片免费全部播放完整| 光棍天堂免费手机观看在线观看 | 国产精品玖玖美女张开腿让男人桶爽免费看 | 国产精品玖玖美女张开腿让男人桶爽免费看 | 亚洲国产成人久久精品大牛影视| 精品国产免费人成电影在线观看| 亚洲精品中文字幕麻豆| 91精品免费不卡在线观看| 亚洲精品白色在线发布| 国产精品免费网站| ASS亚洲熟妇毛茸茸PICS| 国产成人免费爽爽爽视频| 亚洲AV日韩综合一区尤物 | 在线人成精品免费视频| 亚洲自偷精品视频自拍| 成人免费大片免费观看网站| 亚洲H在线播放在线观看H| 女人让男人免费桶爽30分钟| 国产亚洲精品AAAA片APP| 暖暖日本免费在线视频 | 曰批全过程免费视频在线观看无码| 亚洲自偷自偷图片| 日本免费污片中国特一级| 久久亚洲精品成人AV| 国产四虎免费精品视频| 亚洲AV无码精品国产成人| 国产亚洲色婷婷久久99精品91| 青柠影视在线观看免费高清 | 亚洲啪啪免费视频| 亚洲中文无码卡通动漫野外| 免费v片在线观看无遮挡| 国产亚洲精品免费视频播放| 亚洲视频一区在线观看| 国产大片免费观看中文字幕| 国产免费区在线观看十分钟| 亚洲视频在线观看视频| 国产a不卡片精品免费观看| 男人都懂www深夜免费网站| 亚洲男人的天堂久久精品| 亚洲日本在线观看视频| 亚洲一级毛片免费观看|