47134777,max_byt
> es=1048576}]}]}
> java.lang.OutOfMemoryError: Java heap space
>
> Even after increasing the HEAP size (KAFKA_HEAP_OPTS) to 5G, still the same
> error is coming (below is the error log)
>
> Can you please help on this issue. The no. of partitions used is
tions=[{partition=1,fetch_offset=847134777,max_bytes=1048576}]}]}
java.lang.OutOfMemoryError: Java heap space
Even after increasing the HEAP size (KAFKA_HEAP_OPTS) to 5G, still the same
error is coming (below is the error log)
Can you please help on this issue. The no. of partitions used is 3, an
09,785] WARN [ConsumerFetcherThread-perf-
> consumer-14195_kafka-cluster-3098529006 <(309)%20852-9006>
> -zeidk-1484174043509-46a51434-2-0], Error in fetch kafka.consumer.
> ConsumerFetcherThread$FetchRequest@54fb48b6 (kafka.consumer.
> ConsumerFetcherThread)
> java.lan
quest@54fb48b6
> (kafka.consumer.ConsumerFetcherThread)
> java.lang.OutOfMemoryError: Java heap space
> at java.nio.HeapByteBuffer.(HeapByteBuffer.java:57)
> at java.nio.ByteBuffer.allocate(ByteBuffer.java:335)
> at org.apache.
r-3098529006 <(309)%20852-9006>
-zeidk-1484174043509-46a51434-2-0], Error in fetch kafka.consumer.
ConsumerFetcherThread$FetchRequest@54fb48b6 (kafka.consumer.
ConsumerFetcherThread)
java.lang.OutOfMemoryError: Java heap space
at java.nio.HeapByteBuffer.(HeapByteBuffer.java:57)
eConsumer. I know that the SSL patch is on its
> way
> > but need to set up a prototype hence went ahead with Raja's version.
> >
> > So when I run my spark job to retrieve data from 1 topic with just 1
> > partition I get a OutOfMemoryError.
> >
> > Here is
eption in thread "main" java.lang.OutOfMemoryError: Java heap space
> at java.nio.HeapByteBuffer.(HeapByteBuffer.java:57)
> at java.nio.ByteBuffer.allocate(ByteBuffer.java:335)
> at
>
> kafka.network.BoundedByteBufferReceive.byteBufferAllocate(BoundedByteBufferRec
rom 1 topic with just 1
partition I get a OutOfMemoryError.
Here is the stack trace:
Exception in thread "main" java.lang.OutOfMemoryError: Java heap space
at java.nio.HeapByteBuffer.(HeapByteBuffer.java:57)
at java.nio.ByteBuffer.allocate(ByteBuffer.j
