0

[2018-10-18 14:12:01,340] WARN [ReplicaFetcherThread-0-3], Error in fetch kafka.server.ReplicaFetcherThread$FetchRequest@785b3ea5 (kafka.server.ReplicaFetcherThread)
java.io.IOException: Connection to 3 was disconnected before the response was read
        at kafka.utils.NetworkClientBlockingOps$.$anonfun$blockingSendAndReceive$3(NetworkClientBlockingOps.scala:114)
        at kafka.utils.NetworkClientBlockingOps$.$anonfun$blockingSendAndReceive$3$adapted(NetworkClientBlockingOps.scala:112)
        at scala.Option.foreach(Option.scala:257)
        at kafka.utils.NetworkClientBlockingOps$.$anonfun$blockingSendAndReceive$1(NetworkClientBlockingOps.scala:112)
        at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:136)
        at kafka.utils.NetworkClientBlockingOps$.pollContinuously$extension(NetworkClientBlockingOps.scala:142)
        at kafka.utils.NetworkClientBlockingOps$.blockingSendAndReceive$extension(NetworkClientBlockingOps.scala:108)
        at kafka.server.ReplicaFetcherThread.sendRequest(ReplicaFetcherThread.scala:249)
        at kafka.server.ReplicaFetcherThread.fetch(ReplicaFetcherThread.scala:234)
        at kafka.server.ReplicaFetcherThread.fetch(ReplicaFetcherThread.scala:42)
        at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:118)
        at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:103)
        at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63)
[2018-10-18 14:12:03,959] INFO [GroupCoordinator 4]: Preparing to restabilize group 8017 with old generation 11 (kafka.coordinator.GroupCoordinator)
[2018-10-18 14:12:03,958] ERROR Processor got uncaught exception. (kafka.network.Processor)
java.lang.OutOfMemoryError: Java heap space
[2018-10-18 14:12:02,156] ERROR [KafkaApi-4] Error when handling request {replica_id=-1,max_wait_time=100,min_bytes=1,topics=[{topic=**********,partitions=[{partition=9,fetch_offset=3610091552,max_bytes=1048576},{partition=13,fetch_offset=3673665102,max_bytes=1048576},{partition=1,fetch_offset=3685463160,max_bytes=1048576},{partition=10,fetch_offset=3628517926,max_bytes=1048576},{partition=5,fetch_offset=3653905643,max_bytes=1048576}]}]} (kafka.server.KafkaApis)
java.lang.OutOfMemoryError: Java heap space
[2018-10-18 14:12:02,155] ERROR Processor got uncaught exception. (kafka.network.Processor)
java.lang.OutOfMemoryError: Java heap space
[2018-10-18 14:12:01,342] ERROR [ExpirationReaper-4], Error due to  (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)

|