Hi, We have been using kafka_2.11-0.9.0.1. We’re seeing the following 2 warning messages in kafka.server.ReplicaFetcherThread whenever there is large read by spark. It’s always accompanied by Shrinking ISR and Expanding ISR messages. It seems that Spark is still receiving data. However, it’s unclear to me what is the repercussion of these warning messages, why they occur, and how to get rid of them. I appreciate any insight on this. Thank you.
Dan [2016-08-31 02:15:56,918] WARN [ReplicaFetcherThread-0-112], Error in fetch kafka.server.ReplicaFetcherThread$FetchRequest@5e5f9e6. Possible cause: java.io.IOException: Connection to 112 was disconnected before the response was read (kafka.server.ReplicaFetcherThread) [2016-08-31 02:16:10,036] WARN [ReplicaFetcherThread-0-111], Error in fetch kafka.server.ReplicaFetcherThread$FetchRequest@5dd468b5. Possible cause: java.net.SocketTimeoutException: No response received within 30000 ms (kafka.server.ReplicaFetcherThread) [2016-08-31 02:15:56,968] INFO Partition [prod_metrics,78] on broker 110: Shrinking ISR for partition [prod_metrics,78] from 110,112 to 110 (kafka.cluster.Partition) [2016-08-31 02:15:57,053] INFO Partition [prod_metrics,82] on broker 110: Shrinking ISR for partition [prod_metrics,82] from 110,113 to 110 (kafka.cluster.Partition)
