iss alloc 版本 官方 buffer enter AC 軟件 p s

簡介： CDH的parcel包中是沒有kafka的，kafka被剝離了出來，需要從新下載parcel包安裝。或者在線安裝，但是在線安裝都很慢，這裏使用下載parcel包離線安裝的方式。 PS:kafka有很多版本，CDH也有很多版本，那也許你會疑問如何知道你的CDH應該安裝什麽kafka版本。這個官方有介紹，文檔地址：https://www.cloudera.com/documentation/enterprise/release-notes/topics/rn_consolidated_pcm.html#pcm_kafka ，這裏截圖： 由於我的CDH是5.11，所以只支持kafka2.1.x的，所以我安裝的就是這個版本 一。安裝準備： 所需軟件： ①kafka csd包,下載地址：http://archive.cloudera.com/csds/kafka/ ②kafka parcel包： 地址：http://archive.cloudera.com/kafka/parcels/latest/，根據操作系統，下載對應的包 二。開始安裝 1.上傳kafka。 註意，以下操作，需要在你CDH的所有機器執行，不然待會檢測不到。 ①上傳CSD包KAFKA-1.2.0.jar，到服務器CDH目錄下，路徑為/opt/cloudera/csd ②上傳parcel包中的那3個文件，到目錄/opt/cloudera/parcel-repo下，註意如果有文件重名，如manifest那個文件，把以前的重命名為其他名字 2.分配，激活 進入CDH的管理界面，點擊主機->parcel->檢查新parcel 如果成功，則會看到你的kafka一項，並且有分配按鈕，點擊分配，等待，然後分配按鈕編程激活按鈕，點擊激活，等待，操作成功後如下 OK，kafka安裝完成 三。善後工作 安裝完成後，便可以在添加服務裏，添加kafka服務了。這裏如果遇到最後一步，啟動kafka的時候，失敗報錯如下： Fatal error during KafkaServerStartable startup. Prepare to shutdown java.lang.OutOfMemoryError: Java heap space at java.nio.HeapByteBuffer.<init>(HeapByteBuffer.java:57) at java.nio.ByteBuffer.allocate(ByteBuffer.java:335) at kafka.log.SkimpyOffsetMap.<init>(OffsetMap.scala:43) at kafka.log.LogCleaner$CleanerThread.<init>(LogCleaner.scala:186) at kafka.log.LogCleaner

anonfun$1.apply(LogCleaner.scala:83)atkafka.log.LogCleaneranonfun$1.apply(LogCleaner.scala:83)atkafka.log.LogCleaner anonfun$1.apply(LogCleaner.scala:83) 這是因為 Java Heap Size配置小了（奇怪的是安裝kafka的時候它也沒提示我設置啊，簡直怪了），這裏如下解決： 回到CDH主頁面，點擊kafka，進入配置頁面，修改 Java Heap Size of Broker為1G，如下：，然後保存，重啟KAFKA，OK，這下終於好了

CDH5.10 添加kafka服務