Kafka yapılandırma 5.5.2 küme

Question

benim mevcut CDH 5.5.2 küme üzerinde Kafka-2,0 yüklediğim, burada ben

1. CM
2. Seçilmiş Kafka gelen hizmetler ekleyin ardından neler prosedürü (olduğu Bundan önce ben indirilen ve dağıtır ve Ayna biriyle Kafka MirrorMaker için) tüm düğümlerde
3. Sonra ben güncellenmiş benim Hedef Broker listesi (bootstrap.servers) özelliğini KafkaBroker için
4. Seçilmiş 1 düğümleri ve 4 düğümleri kafka parsel aktive Kaynak Düğüm Listesi yanı sıra Maker düğümü (böylece VM yığın -: "Java yığın alanı java.lang.OutOfMemoryError" urce.bootstrap.servers) aynı düğüm ile hata Aşağıda

5. i() log dosyası

   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:331) 
       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) 
       at kafka.log.LogCleaner$$anonfun$1.apply(LogCleaner.scala:83) 
       at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:245) 
       at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:245) 
       at scala.collection.immutable.Range.foreach(Range.scala:166) 
       at scala.collection.TraversableLike$class.map(TraversableLike.scala:245) 
       at scala.collection.AbstractTraversable.map(Traversable.scala:104) 
       at kafka.log.LogCleaner.<init>(LogCleaner.scala:83) 
       at kafka.log.LogManager.<init>(LogManager.scala:64) 
       at kafka.server.KafkaServer.createLogManager(KafkaServer.scala:601) 
       at kafka.server.KafkaServer.startup(KafkaServer.scala:180) 
       at kafka.server.KafkaServerStartable.startup(KafkaServerStartable.scala:37) 
       at kafka.Kafka$.main(Kafka.scala:67) 
       at com.cloudera.kafka.wrap.Kafka$.main(Kafka.scala:76) 
       at com.cloudera.kafka.wrap.Kafka.main(Kafka.scala) 
   

Answer 1

yığın izleme gösterir alıyorum alan tükeniyor. /bin/kafka-server-start.sh dosyasında

'u ayarlayarak artırın.

Answer 2

broker_max_heap_size değerini atleast 1GB'a yükseltmeniz ve Cloudera Manager'dan kafka hizmetini yeniden başlatmanız gerekir. Hâlâ aynı sorunu yaşadığınız takdirde, ya ben bunu kontrol, ucu için küme yapılandırmaları göre