[2019-10-10 06:22:00,143] WARN [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error in response for fetch request (type=FetchRequest, replicaId=4, maxWait=500, minBytes=1, maxBytes=10485760, fetchData={ie-lrx-rxer-audit-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), mft-hdfs-landing-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), it-sou-audit-evt-7=(offset=94819, logStartOffset=94819, maxBytes=1048576, currentLeaderEpoch=Optional[100]), intg-ie-lrx-rxer-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[78]), prod-pipelines-errors-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[117]), __consumer_offsets-36=(offset=3, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), panel-data-change-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), gdcp-notification-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), data-transfer-change-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), __consumer_offsets-11=(offset=15, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-heartbeat-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ukwhs-error-topic-1=(offset=8, logStartOffset=8, maxBytes=1048576, currentLeaderEpoch=Optional[105]), intg-ie-lrx-audit-evt-4=(offset=21, logStartOffset=21, maxBytes=1048576, currentLeaderEpoch=Optional[74]), __consumer_offsets-16=(offset=11329814, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), __consumer_offsets-31=(offset=3472033, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), ukpai-hdfs-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), mft-pflow-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), ukwhs-hdfs-landing-evt-01-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), it-sou-audit-evt-2=(offset=490084, logStartOffset=490084, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ie-lrx-pat-audit-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104])}, isolationLevel=READ_UNCOMMITTED, toForget=, metadata=(sessionId=919177392, epoch=INITIAL)) (kafka.server.ReplicaFetcherThread)
java.io.IOException: Connection to 2 was disconnected before the response was read
	at org.apache.kafka.clients.NetworkClientUtils.sendAndReceive(NetworkClientUtils.java:97)
	at kafka.server.ReplicaFetcherBlockingSend.sendRequest(ReplicaFetcherBlockingSend.scala:97)
	at kafka.server.ReplicaFetcherThread.fetchFromLeader(ReplicaFetcherThread.scala:190)
	at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:241)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:130)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:129)
	at scala.Option.foreach(Option.scala:257)
	at kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:129)
	at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:111)
	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:82)
[2019-10-10 06:23:54,603] INFO [GroupMetadataManager brokerId=4] Removed 0 expired offsets in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager)
[2019-10-10 06:24:02,264] INFO [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error sending fetch request (sessionId=919177392, epoch=INITIAL) to node 2: java.io.IOException: Connection to 2 was disconnected before the response was read. (org.apache.kafka.clients.FetchSessionHandler)
[2019-10-10 06:24:02,291] WARN [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error in response for fetch request (type=FetchRequest, replicaId=4, maxWait=500, minBytes=1, maxBytes=10485760, fetchData={ie-lrx-rxer-audit-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), mft-hdfs-landing-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), it-sou-audit-evt-7=(offset=94819, logStartOffset=94819, maxBytes=1048576, currentLeaderEpoch=Optional[100]), intg-ie-lrx-rxer-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[78]), prod-pipelines-errors-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[117]), __consumer_offsets-36=(offset=3, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), panel-data-change-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), gdcp-notification-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), data-transfer-change-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), __consumer_offsets-11=(offset=15, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-heartbeat-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ukwhs-error-topic-1=(offset=8, logStartOffset=8, maxBytes=1048576, currentLeaderEpoch=Optional[105]), intg-ie-lrx-audit-evt-4=(offset=21, logStartOffset=21, maxBytes=1048576, currentLeaderEpoch=Optional[74]), __consumer_offsets-16=(offset=11329814, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), __consumer_offsets-31=(offset=3472033, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), ukpai-hdfs-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), mft-pflow-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), ukwhs-hdfs-landing-evt-01-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), it-sou-audit-evt-2=(offset=490084, logStartOffset=490084, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ie-lrx-pat-audit-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104])}, isolationLevel=READ_UNCOMMITTED, toForget=, metadata=(sessionId=919177392, epoch=INITIAL)) (kafka.server.ReplicaFetcherThread)
java.io.IOException: Connection to 2 was disconnected before the response was read
	at org.apache.kafka.clients.NetworkClientUtils.sendAndReceive(NetworkClientUtils.java:97)
	at kafka.server.ReplicaFetcherBlockingSend.sendRequest(ReplicaFetcherBlockingSend.scala:97)
	at kafka.server.ReplicaFetcherThread.fetchFromLeader(ReplicaFetcherThread.scala:190)
	at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:241)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:130)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:129)
	at scala.Option.foreach(Option.scala:257)
	at kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:129)
	at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:111)
	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:82)
[2019-10-10 06:26:04,432] INFO [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error sending fetch request (sessionId=919177392, epoch=INITIAL) to node 2: java.io.IOException: Connection to 2 was disconnected before the response was read. (org.apache.kafka.clients.FetchSessionHandler)
[2019-10-10 06:26:04,432] WARN [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error in response for fetch request (type=FetchRequest, replicaId=4, maxWait=500, minBytes=1, maxBytes=10485760, fetchData={ie-lrx-rxer-audit-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), mft-hdfs-landing-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), it-sou-audit-evt-7=(offset=94819, logStartOffset=94819, maxBytes=1048576, currentLeaderEpoch=Optional[100]), intg-ie-lrx-rxer-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[78]), prod-pipelines-errors-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[117]), __consumer_offsets-36=(offset=3, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), panel-data-change-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), gdcp-notification-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), data-transfer-change-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), __consumer_offsets-11=(offset=15, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-heartbeat-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ukwhs-error-topic-1=(offset=8, logStartOffset=8, maxBytes=1048576, currentLeaderEpoch=Optional[105]), intg-ie-lrx-audit-evt-4=(offset=21, logStartOffset=21, maxBytes=1048576, currentLeaderEpoch=Optional[74]), __consumer_offsets-16=(offset=11329814, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), __consumer_offsets-31=(offset=3472033, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), ukpai-hdfs-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), mft-pflow-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), ukwhs-hdfs-landing-evt-01-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), it-sou-audit-evt-2=(offset=490084, logStartOffset=490084, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ie-lrx-pat-audit-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104])}, isolationLevel=READ_UNCOMMITTED, toForget=, metadata=(sessionId=919177392, epoch=INITIAL)) (kafka.server.ReplicaFetcherThread)
java.io.IOException: Connection to 2 was disconnected before the response was read
	at org.apache.kafka.clients.NetworkClientUtils.sendAndReceive(NetworkClientUtils.java:97)
	at kafka.server.ReplicaFetcherBlockingSend.sendRequest(ReplicaFetcherBlockingSend.scala:97)
	at kafka.server.ReplicaFetcherThread.fetchFromLeader(ReplicaFetcherThread.scala:190)
	at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:241)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:130)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:129)
	at scala.Option.foreach(Option.scala:257)
	at kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:129)
	at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:111)
	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:82)
[2019-10-10 06:28:06,562] INFO [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error sending fetch request (sessionId=919177392, epoch=INITIAL) to node 2: java.io.IOException: Connection to 2 was disconnected before the response was read. (org.apache.kafka.clients.FetchSessionHandler)
[2019-10-10 06:28:06,562] WARN [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error in response for fetch request (type=FetchRequest, replicaId=4, maxWait=500, minBytes=1, maxBytes=10485760, fetchData={ie-lrx-rxer-audit-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), mft-hdfs-landing-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), it-sou-audit-evt-7=(offset=94819, logStartOffset=94819, maxBytes=1048576, currentLeaderEpoch=Optional[100]), intg-ie-lrx-rxer-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[78]), prod-pipelines-errors-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[117]), __consumer_offsets-36=(offset=3, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), panel-data-change-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), gdcp-notification-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), data-transfer-change-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), __consumer_offsets-11=(offset=15, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-heartbeat-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ukwhs-error-topic-1=(offset=8, logStartOffset=8, maxBytes=1048576, currentLeaderEpoch=Optional[105]), intg-ie-lrx-audit-evt-4=(offset=21, logStartOffset=21, maxBytes=1048576, currentLeaderEpoch=Optional[74]), __consumer_offsets-16=(offset=11329814, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), __consumer_offsets-31=(offset=3472033, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), ukpai-hdfs-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), mft-pflow-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), ukwhs-hdfs-landing-evt-01-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), it-sou-audit-evt-2=(offset=490084, logStartOffset=490084, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ie-lrx-pat-audit-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104])}, isolationLevel=READ_UNCOMMITTED, toForget=, metadata=(sessionId=919177392, epoch=INITIAL)) (kafka.server.ReplicaFetcherThread)
java.io.IOException: Connection to 2 was disconnected before the response was read
	at org.apache.kafka.clients.NetworkClientUtils.sendAndReceive(NetworkClientUtils.java:97)
	at kafka.server.ReplicaFetcherBlockingSend.sendRequest(ReplicaFetcherBlockingSend.scala:97)
	at kafka.server.ReplicaFetcherThread.fetchFromLeader(ReplicaFetcherThread.scala:190)
	at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:241)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:130)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:129)
	at scala.Option.foreach(Option.scala:257)
	at kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:129)
	at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:111)
	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:82)
[2019-10-10 06:30:08,703] INFO [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error sending fetch request (sessionId=919177392, epoch=INITIAL) to node 2: java.io.IOException: Connection to 2 was disconnected before the response was read. (org.apache.kafka.clients.FetchSessionHandler)
[2019-10-10 06:30:08,708] WARN [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error in response for fetch request (type=FetchRequest, replicaId=4, maxWait=500, minBytes=1, maxBytes=10485760, fetchData={ie-lrx-rxer-audit-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), mft-hdfs-landing-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), it-sou-audit-evt-7=(offset=94819, logStartOffset=94819, maxBytes=1048576, currentLeaderEpoch=Optional[100]), intg-ie-lrx-rxer-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[78]), prod-pipelines-errors-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[117]), __consumer_offsets-36=(offset=3, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), panel-data-change-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), gdcp-notification-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), data-transfer-change-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), __consumer_offsets-11=(offset=15, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-heartbeat-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ukwhs-error-topic-1=(offset=8, logStartOffset=8, maxBytes=1048576, currentLeaderEpoch=Optional[105]), intg-ie-lrx-audit-evt-4=(offset=21, logStartOffset=21, maxBytes=1048576, currentLeaderEpoch=Optional[74]), __consumer_offsets-16=(offset=11329814, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), __consumer_offsets-31=(offset=3472033, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), ukpai-hdfs-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), mft-pflow-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), ukwhs-hdfs-landing-evt-01-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), it-sou-audit-evt-2=(offset=490084, logStartOffset=490084, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ie-lrx-pat-audit-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104])}, isolationLevel=READ_UNCOMMITTED, toForget=, metadata=(sessionId=919177392, epoch=INITIAL)) (kafka.server.ReplicaFetcherThread)
java.io.IOException: Connection to 2 was disconnected before the response was read
	at org.apache.kafka.clients.NetworkClientUtils.sendAndReceive(NetworkClientUtils.java:97)
	at kafka.server.ReplicaFetcherBlockingSend.sendRequest(ReplicaFetcherBlockingSend.scala:97)
	at kafka.server.ReplicaFetcherThread.fetchFromLeader(ReplicaFetcherThread.scala:190)
	at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:241)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:130)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:129)
	at scala.Option.foreach(Option.scala:257)
	at kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:129)
	at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:111)
	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:82)
[2019-10-10 06:32:10,844] INFO [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error sending fetch request (sessionId=919177392, epoch=INITIAL) to node 2: java.io.IOException: Connection to 2 was disconnected before the response was read. (org.apache.kafka.clients.FetchSessionHandler)
[2019-10-10 06:32:10,849] WARN [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error in response for fetch request (type=FetchRequest, replicaId=4, maxWait=500, minBytes=1, maxBytes=10485760, fetchData={ie-lrx-rxer-audit-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), mft-hdfs-landing-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), it-sou-audit-evt-7=(offset=94819, logStartOffset=94819, maxBytes=1048576, currentLeaderEpoch=Optional[100]), intg-ie-lrx-rxer-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[78]), prod-pipelines-errors-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[117]), __consumer_offsets-36=(offset=3, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), panel-data-change-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), gdcp-notification-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), data-transfer-change-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), __consumer_offsets-11=(offset=15, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-heartbeat-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ukwhs-error-topic-1=(offset=8, logStartOffset=8, maxBytes=1048576, currentLeaderEpoch=Optional[105]), intg-ie-lrx-audit-evt-4=(offset=21, logStartOffset=21, maxBytes=1048576, currentLeaderEpoch=Optional[74]), __consumer_offsets-16=(offset=11329814, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), __consumer_offsets-31=(offset=3472033, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), ukpai-hdfs-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), mft-pflow-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), ukwhs-hdfs-landing-evt-01-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), it-sou-audit-evt-2=(offset=490084, logStartOffset=490084, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ie-lrx-pat-audit-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104])}, isolationLevel=READ_UNCOMMITTED, toForget=, metadata=(sessionId=919177392, epoch=INITIAL)) (kafka.server.ReplicaFetcherThread)
java.io.IOException: Connection to 2 was disconnected before the response was read
	at org.apache.kafka.clients.NetworkClientUtils.sendAndReceive(NetworkClientUtils.java:97)
	at kafka.server.ReplicaFetcherBlockingSend.sendRequest(ReplicaFetcherBlockingSend.scala:97)
	at kafka.server.ReplicaFetcherThread.fetchFromLeader(ReplicaFetcherThread.scala:190)
	at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:241)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:130)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:129)
	at scala.Option.foreach(Option.scala:257)
	at kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:129)
	at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:111)
	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:82)
[2019-10-10 06:33:54,614] INFO [GroupMetadataManager brokerId=4] Removed 0 expired offsets in 5 milliseconds. (kafka.coordinator.group.GroupMetadataManager)
[2019-10-10 06:34:12,966] INFO [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error sending fetch request (sessionId=919177392, epoch=INITIAL) to node 2: java.io.IOException: Connection to 2 was disconnected before the response was read. (org.apache.kafka.clients.FetchSessionHandler)
[2019-10-10 06:34:12,971] WARN [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error in response for fetch request (type=FetchRequest, replicaId=4, maxWait=500, minBytes=1, maxBytes=10485760, fetchData={ie-lrx-rxer-audit-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), mft-hdfs-landing-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), it-sou-audit-evt-7=(offset=94819, logStartOffset=94819, maxBytes=1048576, currentLeaderEpoch=Optional[100]), intg-ie-lrx-rxer-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[78]), prod-pipelines-errors-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[117]), __consumer_offsets-36=(offset=3, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), panel-data-change-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), gdcp-notification-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), data-transfer-change-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), __consumer_offsets-11=(offset=15, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-heartbeat-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ukwhs-error-topic-1=(offset=8, logStartOffset=8, maxBytes=1048576, currentLeaderEpoch=Optional[105]), intg-ie-lrx-audit-evt-4=(offset=21, logStartOffset=21, maxBytes=1048576, currentLeaderEpoch=Optional[74]), __consumer_offsets-16=(offset=11329814, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), __consumer_offsets-31=(offset=3472033, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), ukpai-hdfs-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), mft-pflow-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), ukwhs-hdfs-landing-evt-01-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), it-sou-audit-evt-2=(offset=490084, logStartOffset=490084, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ie-lrx-pat-audit-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104])}, isolationLevel=READ_UNCOMMITTED, toForget=, metadata=(sessionId=919177392, epoch=INITIAL)) (kafka.server.ReplicaFetcherThread)
java.io.IOException: Connection to 2 was disconnected before the response was read
	at org.apache.kafka.clients.NetworkClientUtils.sendAndReceive(NetworkClientUtils.java:97)
	at kafka.server.ReplicaFetcherBlockingSend.sendRequest(ReplicaFetcherBlockingSend.scala:97)
	at kafka.server.ReplicaFetcherThread.fetchFromLeader(ReplicaFetcherThread.scala:190)
	at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:241)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:130)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:129)
	at scala.Option.foreach(Option.scala:257)
	at kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:129)
	at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:111)
	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:82)
[2019-10-10 06:36:15,082] INFO [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error sending fetch request (sessionId=919177392, epoch=INITIAL) to node 2: java.io.IOException: Connection to 2 was disconnected before the response was read. (org.apache.kafka.clients.FetchSessionHandler)
[2019-10-10 06:36:15,082] WARN [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error in response for fetch request (type=FetchRequest, replicaId=4, maxWait=500, minBytes=1, maxBytes=10485760, fetchData={ie-lrx-rxer-audit-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), mft-hdfs-landing-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), it-sou-audit-evt-7=(offset=94819, logStartOffset=94819, maxBytes=1048576, currentLeaderEpoch=Optional[100]), intg-ie-lrx-rxer-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[78]), prod-pipelines-errors-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[117]), __consumer_offsets-36=(offset=3, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), panel-data-change-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), gdcp-notification-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), data-transfer-change-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), __consumer_offsets-11=(offset=15, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-heartbeat-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ukwhs-error-topic-1=(offset=8, logStartOffset=8, maxBytes=1048576, currentLeaderEpoch=Optional[105]), intg-ie-lrx-audit-evt-4=(offset=21, logStartOffset=21, maxBytes=1048576, currentLeaderEpoch=Optional[74]), __consumer_offsets-16=(offset=11329814, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), __consumer_offsets-31=(offset=3472033, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), ukpai-hdfs-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), mft-pflow-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), ukwhs-hdfs-landing-evt-01-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), it-sou-audit-evt-2=(offset=490084, logStartOffset=490084, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ie-lrx-pat-audit-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104])}, isolationLevel=READ_UNCOMMITTED, toForget=, metadata=(sessionId=919177392, epoch=INITIAL)) (kafka.server.ReplicaFetcherThread)
java.io.IOException: Connection to 2 was disconnected before the response was read
	at org.apache.kafka.clients.NetworkClientUtils.sendAndReceive(NetworkClientUtils.java:97)
	at kafka.server.ReplicaFetcherBlockingSend.sendRequest(ReplicaFetcherBlockingSend.scala:97)
	at kafka.server.ReplicaFetcherThread.fetchFromLeader(ReplicaFetcherThread.scala:190)
	at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:241)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:130)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:129)
	at scala.Option.foreach(Option.scala:257)
	at kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:129)
	at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:111)
	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:82)
[2019-10-10 06:38:17,202] INFO [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error sending fetch request (sessionId=919177392, epoch=INITIAL) to node 2: java.io.IOException: Connection to 2 was disconnected before the response was read. (org.apache.kafka.clients.FetchSessionHandler)
[2019-10-10 06:38:17,202] WARN [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error in response for fetch request (type=FetchRequest, replicaId=4, maxWait=500, minBytes=1, maxBytes=10485760, fetchData={ie-lrx-rxer-audit-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), mft-hdfs-landing-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), it-sou-audit-evt-7=(offset=94819, logStartOffset=94819, maxBytes=1048576, currentLeaderEpoch=Optional[100]), intg-ie-lrx-rxer-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[78]), prod-pipelines-errors-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[117]), __consumer_offsets-36=(offset=3, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), panel-data-change-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), gdcp-notification-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), data-transfer-change-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), __consumer_offsets-11=(offset=15, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-heartbeat-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ukwhs-error-topic-1=(offset=8, logStartOffset=8, maxBytes=1048576, currentLeaderEpoch=Optional[105]), intg-ie-lrx-audit-evt-4=(offset=21, logStartOffset=21, maxBytes=1048576, currentLeaderEpoch=Optional[74]), __consumer_offsets-16=(offset=11329814, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), __consumer_offsets-31=(offset=3472033, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), ukpai-hdfs-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), mft-pflow-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), ukwhs-hdfs-landing-evt-01-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), it-sou-audit-evt-2=(offset=490084, logStartOffset=490084, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ie-lrx-pat-audit-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104])}, isolationLevel=READ_UNCOMMITTED, toForget=, metadata=(sessionId=919177392, epoch=INITIAL)) (kafka.server.ReplicaFetcherThread)
java.io.IOException: Connection to 2 was disconnected before the response was read
	at org.apache.kafka.clients.NetworkClientUtils.sendAndReceive(NetworkClientUtils.java:97)
	at kafka.server.ReplicaFetcherBlockingSend.sendRequest(ReplicaFetcherBlockingSend.scala:97)
	at kafka.server.ReplicaFetcherThread.fetchFromLeader(ReplicaFetcherThread.scala:190)
	at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:241)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:130)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:129)
	at scala.Option.foreach(Option.scala:257)
	at kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:129)
	at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:111)
	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:82)
[2019-10-10 06:40:19,311] INFO [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error sending fetch request (sessionId=919177392, epoch=INITIAL) to node 2: java.io.IOException: Connection to 2 was disconnected before the response was read. (org.apache.kafka.clients.FetchSessionHandler)
[2019-10-10 06:40:19,312] WARN [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error in response for fetch request (type=FetchRequest, replicaId=4, maxWait=500, minBytes=1, maxBytes=10485760, fetchData={ie-lrx-rxer-audit-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), mft-hdfs-landing-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), it-sou-audit-evt-7=(offset=94819, logStartOffset=94819, maxBytes=1048576, currentLeaderEpoch=Optional[100]), intg-ie-lrx-rxer-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[78]), prod-pipelines-errors-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[117]), __consumer_offsets-36=(offset=3, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), panel-data-change-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), gdcp-notification-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), data-transfer-change-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), __consumer_offsets-11=(offset=15, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-heartbeat-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ukwhs-error-topic-1=(offset=8, logStartOffset=8, maxBytes=1048576, currentLeaderEpoch=Optional[105]), intg-ie-lrx-audit-evt-4=(offset=21, logStartOffset=21, maxBytes=1048576, currentLeaderEpoch=Optional[74]), __consumer_offsets-16=(offset=11329814, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), __consumer_offsets-31=(offset=3472033, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), ukpai-hdfs-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), mft-pflow-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), ukwhs-hdfs-landing-evt-01-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), it-sou-audit-evt-2=(offset=490084, logStartOffset=490084, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ie-lrx-pat-audit-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104])}, isolationLevel=READ_UNCOMMITTED, toForget=, metadata=(sessionId=919177392, epoch=INITIAL)) (kafka.server.ReplicaFetcherThread)
java.io.IOException: Connection to 2 was disconnected before the response was read
	at org.apache.kafka.clients.NetworkClientUtils.sendAndReceive(NetworkClientUtils.java:97)
	at kafka.server.ReplicaFetcherBlockingSend.sendRequest(ReplicaFetcherBlockingSend.scala:97)
	at kafka.server.ReplicaFetcherThread.fetchFromLeader(ReplicaFetcherThread.scala:190)
	at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:241)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:130)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:129)
	at scala.Option.foreach(Option.scala:257)
	at kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:129)
	at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:111)
	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:82)
[2019-10-10 06:42:21,443] INFO [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error sending fetch request (sessionId=919177392, epoch=INITIAL) to node 2: java.io.IOException: Connection to 2 was disconnected before the response was read. (org.apache.kafka.clients.FetchSessionHandler)
[2019-10-10 06:42:21,444] WARN [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error in response for fetch request (type=FetchRequest, replicaId=4, maxWait=500, minBytes=1, maxBytes=10485760, fetchData={ie-lrx-rxer-audit-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), mft-hdfs-landing-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), it-sou-audit-evt-7=(offset=94819, logStartOffset=94819, maxBytes=1048576, currentLeaderEpoch=Optional[100]), intg-ie-lrx-rxer-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[78]), prod-pipelines-errors-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[117]), __consumer_offsets-36=(offset=3, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), panel-data-change-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), gdcp-notification-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), data-transfer-change-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), __consumer_offsets-11=(offset=15, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-heartbeat-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ukwhs-error-topic-1=(offset=8, logStartOffset=8, maxBytes=1048576, currentLeaderEpoch=Optional[105]), intg-ie-lrx-audit-evt-4=(offset=21, logStartOffset=21, maxBytes=1048576, currentLeaderEpoch=Optional[74]), __consumer_offsets-16=(offset=11329814, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), __consumer_offsets-31=(offset=3472033, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), ukpai-hdfs-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), mft-pflow-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), ukwhs-hdfs-landing-evt-01-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), it-sou-audit-evt-2=(offset=490084, logStartOffset=490084, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ie-lrx-pat-audit-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104])}, isolationLevel=READ_UNCOMMITTED, toForget=, metadata=(sessionId=919177392, epoch=INITIAL)) (kafka.server.ReplicaFetcherThread)
java.io.IOException: Connection to 2 was disconnected before the response was read
	at org.apache.kafka.clients.NetworkClientUtils.sendAndReceive(NetworkClientUtils.java:97)
	at kafka.server.ReplicaFetcherBlockingSend.sendRequest(ReplicaFetcherBlockingSend.scala:97)
	at kafka.server.ReplicaFetcherThread.fetchFromLeader(ReplicaFetcherThread.scala:190)
	at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:241)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:130)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:129)
	at scala.Option.foreach(Option.scala:257)
	at kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:129)
	at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:111)
	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:82)
[2019-10-10 06:43:54,611] INFO [GroupMetadataManager brokerId=4] Removed 0 expired offsets in 2 milliseconds. (kafka.coordinator.group.GroupMetadataManager)
[2019-10-10 06:44:23,583] INFO [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error sending fetch request (sessionId=919177392, epoch=INITIAL) to node 2: java.io.IOException: Connection to 2 was disconnected before the response was read. (org.apache.kafka.clients.FetchSessionHandler)
[2019-10-10 06:44:23,594] WARN [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error in response for fetch request (type=FetchRequest, replicaId=4, maxWait=500, minBytes=1, maxBytes=10485760, fetchData={ie-lrx-rxer-audit-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), mft-hdfs-landing-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), it-sou-audit-evt-7=(offset=94819, logStartOffset=94819, maxBytes=1048576, currentLeaderEpoch=Optional[100]), intg-ie-lrx-rxer-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[78]), prod-pipelines-errors-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[117]), __consumer_offsets-36=(offset=3, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), panel-data-change-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), gdcp-notification-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), data-transfer-change-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), __consumer_offsets-11=(offset=15, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-heartbeat-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ukwhs-error-topic-1=(offset=8, logStartOffset=8, maxBytes=1048576, currentLeaderEpoch=Optional[105]), intg-ie-lrx-audit-evt-4=(offset=21, logStartOffset=21, maxBytes=1048576, currentLeaderEpoch=Optional[74]), __consumer_offsets-16=(offset=11329814, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), __consumer_offsets-31=(offset=3472033, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), ukpai-hdfs-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), mft-pflow-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), ukwhs-hdfs-landing-evt-01-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), it-sou-audit-evt-2=(offset=490084, logStartOffset=490084, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ie-lrx-pat-audit-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104])}, isolationLevel=READ_UNCOMMITTED, toForget=, metadata=(sessionId=919177392, epoch=INITIAL)) (kafka.server.ReplicaFetcherThread)
java.io.IOException: Connection to 2 was disconnected before the response was read
	at org.apache.kafka.clients.NetworkClientUtils.sendAndReceive(NetworkClientUtils.java:97)
	at kafka.server.ReplicaFetcherBlockingSend.sendRequest(ReplicaFetcherBlockingSend.scala:97)
	at kafka.server.ReplicaFetcherThread.fetchFromLeader(ReplicaFetcherThread.scala:190)
	at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:241)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:130)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:129)
	at scala.Option.foreach(Option.scala:257)
	at kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:129)
	at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:111)
	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:82)
[2019-10-10 06:46:25,713] INFO [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error sending fetch request (sessionId=919177392, epoch=INITIAL) to node 2: java.io.IOException: Connection to 2 was disconnected before the response was read. (org.apache.kafka.clients.FetchSessionHandler)
[2019-10-10 06:46:25,713] WARN [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error in response for fetch request (type=FetchRequest, replicaId=4, maxWait=500, minBytes=1, maxBytes=10485760, fetchData={ie-lrx-rxer-audit-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), mft-hdfs-landing-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), it-sou-audit-evt-7=(offset=94819, logStartOffset=94819, maxBytes=1048576, currentLeaderEpoch=Optional[100]), intg-ie-lrx-rxer-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[78]), prod-pipelines-errors-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[117]), __consumer_offsets-36=(offset=3, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), panel-data-change-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), gdcp-notification-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), data-transfer-change-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), __consumer_offsets-11=(offset=15, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-heartbeat-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ukwhs-error-topic-1=(offset=8, logStartOffset=8, maxBytes=1048576, currentLeaderEpoch=Optional[105]), intg-ie-lrx-audit-evt-4=(offset=21, logStartOffset=21, maxBytes=1048576, currentLeaderEpoch=Optional[74]), __consumer_offsets-16=(offset=11329814, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), __consumer_offsets-31=(offset=3472033, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), ukpai-hdfs-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), mft-pflow-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), ukwhs-hdfs-landing-evt-01-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), it-sou-audit-evt-2=(offset=490084, logStartOffset=490084, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ie-lrx-pat-audit-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104])}, isolationLevel=READ_UNCOMMITTED, toForget=, metadata=(sessionId=919177392, epoch=INITIAL)) (kafka.server.ReplicaFetcherThread)
java.io.IOException: Connection to 2 was disconnected before the response was read
	at org.apache.kafka.clients.NetworkClientUtils.sendAndReceive(NetworkClientUtils.java:97)
	at kafka.server.ReplicaFetcherBlockingSend.sendRequest(ReplicaFetcherBlockingSend.scala:97)
	at kafka.server.ReplicaFetcherThread.fetchFromLeader(ReplicaFetcherThread.scala:190)
	at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:241)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:130)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:129)
	at scala.Option.foreach(Option.scala:257)
	at kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:129)
	at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:111)
	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:82)
[2019-10-10 06:48:27,842] INFO [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error sending fetch request (sessionId=919177392, epoch=INITIAL) to node 2: java.io.IOException: Connection to 2 was disconnected before the response was read. (org.apache.kafka.clients.FetchSessionHandler)
[2019-10-10 06:48:27,843] WARN [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error in response for fetch request (type=FetchRequest, replicaId=4, maxWait=500, minBytes=1, maxBytes=10485760, fetchData={ie-lrx-rxer-audit-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), mft-hdfs-landing-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), it-sou-audit-evt-7=(offset=94819, logStartOffset=94819, maxBytes=1048576, currentLeaderEpoch=Optional[100]), intg-ie-lrx-rxer-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[78]), prod-pipelines-errors-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[117]), __consumer_offsets-36=(offset=3, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), panel-data-change-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), gdcp-notification-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), data-transfer-change-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), __consumer_offsets-11=(offset=15, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-heartbeat-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ukwhs-error-topic-1=(offset=8, logStartOffset=8, maxBytes=1048576, currentLeaderEpoch=Optional[105]), intg-ie-lrx-audit-evt-4=(offset=21, logStartOffset=21, maxBytes=1048576, currentLeaderEpoch=Optional[74]), __consumer_offsets-16=(offset=11329814, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), __consumer_offsets-31=(offset=3472033, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), ukpai-hdfs-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), mft-pflow-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), ukwhs-hdfs-landing-evt-01-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), it-sou-audit-evt-2=(offset=490084, logStartOffset=490084, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ie-lrx-pat-audit-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104])}, isolationLevel=READ_UNCOMMITTED, toForget=, metadata=(sessionId=919177392, epoch=INITIAL)) (kafka.server.ReplicaFetcherThread)
java.io.IOException: Connection to 2 was disconnected before the response was read
	at org.apache.kafka.clients.NetworkClientUtils.sendAndReceive(NetworkClientUtils.java:97)
	at kafka.server.ReplicaFetcherBlockingSend.sendRequest(ReplicaFetcherBlockingSend.scala:97)
	at kafka.server.ReplicaFetcherThread.fetchFromLeader(ReplicaFetcherThread.scala:190)
	at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:241)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:130)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:129)
	at scala.Option.foreach(Option.scala:257)
	at kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:129)
	at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:111)
	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:82)
[2019-10-10 06:50:29,974] INFO [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error sending fetch request (sessionId=919177392, epoch=INITIAL) to node 2: java.io.IOException: Connection to 2 was disconnected before the response was read. (org.apache.kafka.clients.FetchSessionHandler)
[2019-10-10 06:50:29,982] WARN [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error in response for fetch request (type=FetchRequest, replicaId=4, maxWait=500, minBytes=1, maxBytes=10485760, fetchData={ie-lrx-rxer-audit-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), mft-hdfs-landing-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), it-sou-audit-evt-7=(offset=94819, logStartOffset=94819, maxBytes=1048576, currentLeaderEpoch=Optional[100]), intg-ie-lrx-rxer-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[78]), prod-pipelines-errors-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[117]), __consumer_offsets-36=(offset=3, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), panel-data-change-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), gdcp-notification-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), data-transfer-change-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), __consumer_offsets-11=(offset=15, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-heartbeat-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ukwhs-error-topic-1=(offset=8, logStartOffset=8, maxBytes=1048576, currentLeaderEpoch=Optional[105]), intg-ie-lrx-audit-evt-4=(offset=21, logStartOffset=21, maxBytes=1048576, currentLeaderEpoch=Optional[74]), __consumer_offsets-16=(offset=11329814, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), __consumer_offsets-31=(offset=3472033, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), ukpai-hdfs-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), mft-pflow-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), ukwhs-hdfs-landing-evt-01-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), it-sou-audit-evt-2=(offset=490084, logStartOffset=490084, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ie-lrx-pat-audit-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104])}, isolationLevel=READ_UNCOMMITTED, toForget=, metadata=(sessionId=919177392, epoch=INITIAL)) (kafka.server.ReplicaFetcherThread)
java.io.IOException: Connection to 2 was disconnected before the response was read
	at org.apache.kafka.clients.NetworkClientUtils.sendAndReceive(NetworkClientUtils.java:97)
	at kafka.server.ReplicaFetcherBlockingSend.sendRequest(ReplicaFetcherBlockingSend.scala:97)
	at kafka.server.ReplicaFetcherThread.fetchFromLeader(ReplicaFetcherThread.scala:190)
	at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:241)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:130)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:129)
	at scala.Option.foreach(Option.scala:257)
	at kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:129)
	at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:111)
	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:82)
[2019-10-10 06:52:32,113] INFO [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error sending fetch request (sessionId=919177392, epoch=INITIAL) to node 2: java.io.IOException: Connection to 2 was disconnected before the response was read. (org.apache.kafka.clients.FetchSessionHandler)
[2019-10-10 06:52:32,113] WARN [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error in response for fetch request (type=FetchRequest, replicaId=4, maxWait=500, minBytes=1, maxBytes=10485760, fetchData={ie-lrx-rxer-audit-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), mft-hdfs-landing-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), it-sou-audit-evt-7=(offset=94819, logStartOffset=94819, maxBytes=1048576, currentLeaderEpoch=Optional[100]), intg-ie-lrx-rxer-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[78]), prod-pipelines-errors-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[117]), __consumer_offsets-36=(offset=3, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), panel-data-change-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), gdcp-notification-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), data-transfer-change-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), __consumer_offsets-11=(offset=15, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-heartbeat-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ukwhs-error-topic-1=(offset=8, logStartOffset=8, maxBytes=1048576, currentLeaderEpoch=Optional[105]), intg-ie-lrx-audit-evt-4=(offset=21, logStartOffset=21, maxBytes=1048576, currentLeaderEpoch=Optional[74]), __consumer_offsets-16=(offset=11329814, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), __consumer_offsets-31=(offset=3472033, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), ukpai-hdfs-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), mft-pflow-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), ukwhs-hdfs-landing-evt-01-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), it-sou-audit-evt-2=(offset=490084, logStartOffset=490084, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ie-lrx-pat-audit-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104])}, isolationLevel=READ_UNCOMMITTED, toForget=, metadata=(sessionId=919177392, epoch=INITIAL)) (kafka.server.ReplicaFetcherThread)
java.io.IOException: Connection to 2 was disconnected before the response was read
	at org.apache.kafka.clients.NetworkClientUtils.sendAndReceive(NetworkClientUtils.java:97)
	at kafka.server.ReplicaFetcherBlockingSend.sendRequest(ReplicaFetcherBlockingSend.scala:97)
	at kafka.server.ReplicaFetcherThread.fetchFromLeader(ReplicaFetcherThread.scala:190)
	at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:241)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:130)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:129)
	at scala.Option.foreach(Option.scala:257)
	at kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:129)
	at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:111)
	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:82)
[2019-10-10 06:53:54,611] INFO [GroupMetadataManager brokerId=4] Removed 0 expired offsets in 4 milliseconds. (kafka.coordinator.group.GroupMetadataManager)
[2019-10-10 06:54:34,242] INFO [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error sending fetch request (sessionId=919177392, epoch=INITIAL) to node 2: java.io.IOException: Connection to 2 was disconnected before the response was read. (org.apache.kafka.clients.FetchSessionHandler)
[2019-10-10 06:54:34,243] WARN [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error in response for fetch request (type=FetchRequest, replicaId=4, maxWait=500, minBytes=1, maxBytes=10485760, fetchData={ie-lrx-rxer-audit-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), mft-hdfs-landing-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), it-sou-audit-evt-7=(offset=94819, logStartOffset=94819, maxBytes=1048576, currentLeaderEpoch=Optional[100]), intg-ie-lrx-rxer-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[78]), prod-pipelines-errors-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[117]), __consumer_offsets-36=(offset=3, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), panel-data-change-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), gdcp-notification-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), data-transfer-change-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), __consumer_offsets-11=(offset=15, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-heartbeat-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ukwhs-error-topic-1=(offset=8, logStartOffset=8, maxBytes=1048576, currentLeaderEpoch=Optional[105]), intg-ie-lrx-audit-evt-4=(offset=21, logStartOffset=21, maxBytes=1048576, currentLeaderEpoch=Optional[74]), __consumer_offsets-16=(offset=11329814, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), __consumer_offsets-31=(offset=3472033, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), ukpai-hdfs-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), mft-pflow-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), ukwhs-hdfs-landing-evt-01-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), it-sou-audit-evt-2=(offset=490084, logStartOffset=490084, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ie-lrx-pat-audit-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104])}, isolationLevel=READ_UNCOMMITTED, toForget=, metadata=(sessionId=919177392, epoch=INITIAL)) (kafka.server.ReplicaFetcherThread)
java.io.IOException: Connection to 2 was disconnected before the response was read
	at org.apache.kafka.clients.NetworkClientUtils.sendAndReceive(NetworkClientUtils.java:97)
	at kafka.server.ReplicaFetcherBlockingSend.sendRequest(ReplicaFetcherBlockingSend.scala:97)
	at kafka.server.ReplicaFetcherThread.fetchFromLeader(ReplicaFetcherThread.scala:190)
	at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:241)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:130)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:129)
	at scala.Option.foreach(Option.scala:257)
	at kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:129)
	at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:111)
	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:82)
[2019-10-10 06:56:36,353] INFO [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error sending fetch request (sessionId=919177392, epoch=INITIAL) to node 2: java.io.IOException: Connection to 2 was disconnected before the response was read. (org.apache.kafka.clients.FetchSessionHandler)
[2019-10-10 06:56:36,353] WARN [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error in response for fetch request (type=FetchRequest, replicaId=4, maxWait=500, minBytes=1, maxBytes=10485760, fetchData={ie-lrx-rxer-audit-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), mft-hdfs-landing-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), it-sou-audit-evt-7=(offset=94819, logStartOffset=94819, maxBytes=1048576, currentLeaderEpoch=Optional[100]), intg-ie-lrx-rxer-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[78]), prod-pipelines-errors-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[117]), __consumer_offsets-36=(offset=3, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), panel-data-change-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), gdcp-notification-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), data-transfer-change-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), __consumer_offsets-11=(offset=15, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-heartbeat-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ukwhs-error-topic-1=(offset=8, logStartOffset=8, maxBytes=1048576, currentLeaderEpoch=Optional[105]), intg-ie-lrx-audit-evt-4=(offset=21, logStartOffset=21, maxBytes=1048576, currentLeaderEpoch=Optional[74]), __consumer_offsets-16=(offset=11329814, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), __consumer_offsets-31=(offset=3472033, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), ukpai-hdfs-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), mft-pflow-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), ukwhs-hdfs-landing-evt-01-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), it-sou-audit-evt-2=(offset=490084, logStartOffset=490084, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ie-lrx-pat-audit-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104])}, isolationLevel=READ_UNCOMMITTED, toForget=, metadata=(sessionId=919177392, epoch=INITIAL)) (kafka.server.ReplicaFetcherThread)
java.io.IOException: Connection to 2 was disconnected before the response was read
	at org.apache.kafka.clients.NetworkClientUtils.sendAndReceive(NetworkClientUtils.java:97)
	at kafka.server.ReplicaFetcherBlockingSend.sendRequest(ReplicaFetcherBlockingSend.scala:97)
	at kafka.server.ReplicaFetcherThread.fetchFromLeader(ReplicaFetcherThread.scala:190)
	at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:241)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:130)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:129)
	at scala.Option.foreach(Option.scala:257)
	at kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:129)
	at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:111)
	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:82)
[2019-10-10 06:58:38,491] INFO [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error sending fetch request (sessionId=919177392, epoch=INITIAL) to node 2: java.io.IOException: Connection to 2 was disconnected before the response was read. (org.apache.kafka.clients.FetchSessionHandler)
[2019-10-10 06:58:38,492] WARN [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error in response for fetch request (type=FetchRequest, replicaId=4, maxWait=500, minBytes=1, maxBytes=10485760, fetchData={ie-lrx-rxer-audit-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), mft-hdfs-landing-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), it-sou-audit-evt-7=(offset=94819, logStartOffset=94819, maxBytes=1048576, currentLeaderEpoch=Optional[100]), intg-ie-lrx-rxer-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[78]), prod-pipelines-errors-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[117]), __consumer_offsets-36=(offset=3, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), panel-data-change-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), gdcp-notification-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), data-transfer-change-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), __consumer_offsets-11=(offset=15, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-heartbeat-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ukwhs-error-topic-1=(offset=8, logStartOffset=8, maxBytes=1048576, currentLeaderEpoch=Optional[105]), intg-ie-lrx-audit-evt-4=(offset=21, logStartOffset=21, maxBytes=1048576, currentLeaderEpoch=Optional[74]), __consumer_offsets-16=(offset=11329814, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), __consumer_offsets-31=(offset=3472033, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), ukpai-hdfs-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), mft-pflow-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), ukwhs-hdfs-landing-evt-01-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), it-sou-audit-evt-2=(offset=490084, logStartOffset=490084, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ie-lrx-pat-audit-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104])}, isolationLevel=READ_UNCOMMITTED, toForget=, metadata=(sessionId=919177392, epoch=INITIAL)) (kafka.server.ReplicaFetcherThread)
java.io.IOException: Connection to 2 was disconnected before the response was read
	at org.apache.kafka.clients.NetworkClientUtils.sendAndReceive(NetworkClientUtils.java:97)
	at kafka.server.ReplicaFetcherBlockingSend.sendRequest(ReplicaFetcherBlockingSend.scala:97)
	at kafka.server.ReplicaFetcherThread.fetchFromLeader(ReplicaFetcherThread.scala:190)
	at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:241)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:130)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:129)
	at scala.Option.foreach(Option.scala:257)
	at kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:129)
	at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:111)
	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:82)
[2019-10-10 07:00:40,622] INFO [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error sending fetch request (sessionId=919177392, epoch=INITIAL) to node 2: java.io.IOException: Connection to 2 was disconnected before the response was read. (org.apache.kafka.clients.FetchSessionHandler)
[2019-10-10 07:00:40,624] WARN [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error in response for fetch request (type=FetchRequest, replicaId=4, maxWait=500, minBytes=1, maxBytes=10485760, fetchData={ie-lrx-rxer-audit-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), mft-hdfs-landing-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), it-sou-audit-evt-7=(offset=94819, logStartOffset=94819, maxBytes=1048576, currentLeaderEpoch=Optional[100]), intg-ie-lrx-rxer-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[78]), prod-pipelines-errors-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[117]), __consumer_offsets-36=(offset=3, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), panel-data-change-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), gdcp-notification-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), data-transfer-change-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), __consumer_offsets-11=(offset=15, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-heartbeat-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ukwhs-error-topic-1=(offset=8, logStartOffset=8, maxBytes=1048576, currentLeaderEpoch=Optional[105]), intg-ie-lrx-audit-evt-4=(offset=21, logStartOffset=21, maxBytes=1048576, currentLeaderEpoch=Optional[74]), __consumer_offsets-16=(offset=11329814, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), __consumer_offsets-31=(offset=3472033, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), ukpai-hdfs-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), mft-pflow-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), ukwhs-hdfs-landing-evt-01-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), it-sou-audit-evt-2=(offset=490084, logStartOffset=490084, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ie-lrx-pat-audit-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104])}, isolationLevel=READ_UNCOMMITTED, toForget=, metadata=(sessionId=919177392, epoch=INITIAL)) (kafka.server.ReplicaFetcherThread)
java.io.IOException: Connection to 2 was disconnected before the response was read
	at org.apache.kafka.clients.NetworkClientUtils.sendAndReceive(NetworkClientUtils.java:97)
	at kafka.server.ReplicaFetcherBlockingSend.sendRequest(ReplicaFetcherBlockingSend.scala:97)
	at kafka.server.ReplicaFetcherThread.fetchFromLeader(ReplicaFetcherThread.scala:190)
	at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:241)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:130)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:129)
	at scala.Option.foreach(Option.scala:257)
	at kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:129)
	at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:111)
	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:82)
[2019-10-10 07:02:42,746] INFO [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error sending fetch request (sessionId=919177392, epoch=INITIAL) to node 2: java.io.IOException: Connection to 2 was disconnected before the response was read. (org.apache.kafka.clients.FetchSessionHandler)
[2019-10-10 07:02:42,747] WARN [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error in response for fetch request (type=FetchRequest, replicaId=4, maxWait=500, minBytes=1, maxBytes=10485760, fetchData={ie-lrx-rxer-audit-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), mft-hdfs-landing-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), it-sou-audit-evt-7=(offset=94819, logStartOffset=94819, maxBytes=1048576, currentLeaderEpoch=Optional[100]), intg-ie-lrx-rxer-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[78]), prod-pipelines-errors-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[117]), __consumer_offsets-36=(offset=3, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), panel-data-change-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), gdcp-notification-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), data-transfer-change-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), __consumer_offsets-11=(offset=15, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-heartbeat-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ukwhs-error-topic-1=(offset=8, logStartOffset=8, maxBytes=1048576, currentLeaderEpoch=Optional[105]), intg-ie-lrx-audit-evt-4=(offset=21, logStartOffset=21, maxBytes=1048576, currentLeaderEpoch=Optional[74]), __consumer_offsets-16=(offset=11329814, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), __consumer_offsets-31=(offset=3472033, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), ukpai-hdfs-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), mft-pflow-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), ukwhs-hdfs-landing-evt-01-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), it-sou-audit-evt-2=(offset=490084, logStartOffset=490084, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ie-lrx-pat-audit-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104])}, isolationLevel=READ_UNCOMMITTED, toForget=, metadata=(sessionId=919177392, epoch=INITIAL)) (kafka.server.ReplicaFetcherThread)
java.io.IOException: Connection to 2 was disconnected before the response was read
	at org.apache.kafka.clients.NetworkClientUtils.sendAndReceive(NetworkClientUtils.java:97)
	at kafka.server.ReplicaFetcherBlockingSend.sendRequest(ReplicaFetcherBlockingSend.scala:97)
	at kafka.server.ReplicaFetcherThread.fetchFromLeader(ReplicaFetcherThread.scala:190)
	at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:241)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:130)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:129)
	at scala.Option.foreach(Option.scala:257)
	at kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:129)
	at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:111)
	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:82)
[2019-10-10 07:03:54,601] INFO [GroupMetadataManager brokerId=4] Removed 0 expired offsets in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager)
[2019-10-10 07:04:44,871] INFO [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error sending fetch request (sessionId=919177392, epoch=INITIAL) to node 2: java.io.IOException: Connection to 2 was disconnected before the response was read. (org.apache.kafka.clients.FetchSessionHandler)
[2019-10-10 07:04:44,873] WARN [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error in response for fetch request (type=FetchRequest, replicaId=4, maxWait=500, minBytes=1, maxBytes=10485760, fetchData={ie-lrx-rxer-audit-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), mft-hdfs-landing-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), it-sou-audit-evt-7=(offset=94819, logStartOffset=94819, maxBytes=1048576, currentLeaderEpoch=Optional[100]), intg-ie-lrx-rxer-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[78]), prod-pipelines-errors-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[117]), __consumer_offsets-36=(offset=3, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), panel-data-change-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), gdcp-notification-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), data-transfer-change-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), __consumer_offsets-11=(offset=15, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-heartbeat-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ukwhs-error-topic-1=(offset=8, logStartOffset=8, maxBytes=1048576, currentLeaderEpoch=Optional[105]), intg-ie-lrx-audit-evt-4=(offset=21, logStartOffset=21, maxBytes=1048576, currentLeaderEpoch=Optional[74]), __consumer_offsets-16=(offset=11329814, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), __consumer_offsets-31=(offset=3472033, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), ukpai-hdfs-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), mft-pflow-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), ukwhs-hdfs-landing-evt-01-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), it-sou-audit-evt-2=(offset=490084, logStartOffset=490084, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ie-lrx-pat-audit-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104])}, isolationLevel=READ_UNCOMMITTED, toForget=, metadata=(sessionId=919177392, epoch=INITIAL)) (kafka.server.ReplicaFetcherThread)
java.io.IOException: Connection to 2 was disconnected before the response was read
	at org.apache.kafka.clients.NetworkClientUtils.sendAndReceive(NetworkClientUtils.java:97)
	at kafka.server.ReplicaFetcherBlockingSend.sendRequest(ReplicaFetcherBlockingSend.scala:97)
	at kafka.server.ReplicaFetcherThread.fetchFromLeader(ReplicaFetcherThread.scala:190)
	at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:241)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:130)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:129)
	at scala.Option.foreach(Option.scala:257)
	at kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:129)
	at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:111)
	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:82)
[2019-10-10 07:06:46,984] INFO [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error sending fetch request (sessionId=919177392, epoch=INITIAL) to node 2: java.io.IOException: Connection to 2 was disconnected before the response was read. (org.apache.kafka.clients.FetchSessionHandler)
[2019-10-10 07:06:46,993] WARN [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error in response for fetch request (type=FetchRequest, replicaId=4, maxWait=500, minBytes=1, maxBytes=10485760, fetchData={ie-lrx-rxer-audit-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), mft-hdfs-landing-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), it-sou-audit-evt-7=(offset=94819, logStartOffset=94819, maxBytes=1048576, currentLeaderEpoch=Optional[100]), intg-ie-lrx-rxer-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[78]), prod-pipelines-errors-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[117]), __consumer_offsets-36=(offset=3, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), panel-data-change-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), gdcp-notification-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), data-transfer-change-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), __consumer_offsets-11=(offset=15, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-heartbeat-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ukwhs-error-topic-1=(offset=8, logStartOffset=8, maxBytes=1048576, currentLeaderEpoch=Optional[105]), intg-ie-lrx-audit-evt-4=(offset=21, logStartOffset=21, maxBytes=1048576, currentLeaderEpoch=Optional[74]), __consumer_offsets-16=(offset=11329814, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), __consumer_offsets-31=(offset=3472033, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), ukpai-hdfs-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), mft-pflow-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), ukwhs-hdfs-landing-evt-01-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), it-sou-audit-evt-2=(offset=490084, logStartOffset=490084, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ie-lrx-pat-audit-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104])}, isolationLevel=READ_UNCOMMITTED, toForget=, metadata=(sessionId=919177392, epoch=INITIAL)) (kafka.server.ReplicaFetcherThread)
java.io.IOException: Connection to 2 was disconnected before the response was read
	at org.apache.kafka.clients.NetworkClientUtils.sendAndReceive(NetworkClientUtils.java:97)
	at kafka.server.ReplicaFetcherBlockingSend.sendRequest(ReplicaFetcherBlockingSend.scala:97)
	at kafka.server.ReplicaFetcherThread.fetchFromLeader(ReplicaFetcherThread.scala:190)
	at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:241)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:130)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:129)
	at scala.Option.foreach(Option.scala:257)
	at kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:129)
	at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:111)
	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:82)
[2019-10-10 07:08:49,113] INFO [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error sending fetch request (sessionId=919177392, epoch=INITIAL) to node 2: java.io.IOException: Connection to 2 was disconnected before the response was read. (org.apache.kafka.clients.FetchSessionHandler)
[2019-10-10 07:08:49,114] WARN [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error in response for fetch request (type=FetchRequest, replicaId=4, maxWait=500, minBytes=1, maxBytes=10485760, fetchData={ie-lrx-rxer-audit-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), mft-hdfs-landing-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), it-sou-audit-evt-7=(offset=94819, logStartOffset=94819, maxBytes=1048576, currentLeaderEpoch=Optional[100]), intg-ie-lrx-rxer-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[78]), prod-pipelines-errors-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[117]), __consumer_offsets-36=(offset=3, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), panel-data-change-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), gdcp-notification-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), data-transfer-change-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), __consumer_offsets-11=(offset=15, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-heartbeat-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ukwhs-error-topic-1=(offset=8, logStartOffset=8, maxBytes=1048576, currentLeaderEpoch=Optional[105]), intg-ie-lrx-audit-evt-4=(offset=21, logStartOffset=21, maxBytes=1048576, currentLeaderEpoch=Optional[74]), __consumer_offsets-16=(offset=11329814, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), __consumer_offsets-31=(offset=3472033, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), ukpai-hdfs-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), mft-pflow-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), ukwhs-hdfs-landing-evt-01-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), it-sou-audit-evt-2=(offset=490084, logStartOffset=490084, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ie-lrx-pat-audit-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104])}, isolationLevel=READ_UNCOMMITTED, toForget=, metadata=(sessionId=919177392, epoch=INITIAL)) (kafka.server.ReplicaFetcherThread)
java.io.IOException: Connection to 2 was disconnected before the response was read
	at org.apache.kafka.clients.NetworkClientUtils.sendAndReceive(NetworkClientUtils.java:97)
	at kafka.server.ReplicaFetcherBlockingSend.sendRequest(ReplicaFetcherBlockingSend.scala:97)
	at kafka.server.ReplicaFetcherThread.fetchFromLeader(ReplicaFetcherThread.scala:190)
	at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:241)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:130)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:129)
	at scala.Option.foreach(Option.scala:257)
	at kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:129)
	at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:111)
	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:82)
[2019-10-10 07:10:51,273] INFO [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error sending fetch request (sessionId=919177392, epoch=INITIAL) to node 2: java.io.IOException: Connection to 2 was disconnected before the response was read. (org.apache.kafka.clients.FetchSessionHandler)
[2019-10-10 07:10:51,282] WARN [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error in response for fetch request (type=FetchRequest, replicaId=4, maxWait=500, minBytes=1, maxBytes=10485760, fetchData={ie-lrx-rxer-audit-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), mft-hdfs-landing-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), it-sou-audit-evt-7=(offset=94819, logStartOffset=94819, maxBytes=1048576, currentLeaderEpoch=Optional[100]), intg-ie-lrx-rxer-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[78]), prod-pipelines-errors-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[117]), __consumer_offsets-36=(offset=3, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), panel-data-change-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), gdcp-notification-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), data-transfer-change-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), __consumer_offsets-11=(offset=15, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-heartbeat-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ukwhs-error-topic-1=(offset=8, logStartOffset=8, maxBytes=1048576, currentLeaderEpoch=Optional[105]), intg-ie-lrx-audit-evt-4=(offset=21, logStartOffset=21, maxBytes=1048576, currentLeaderEpoch=Optional[74]), __consumer_offsets-16=(offset=11329814, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), __consumer_offsets-31=(offset=3472033, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), ukpai-hdfs-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), mft-pflow-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), ukwhs-hdfs-landing-evt-01-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), it-sou-audit-evt-2=(offset=490084, logStartOffset=490084, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ie-lrx-pat-audit-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104])}, isolationLevel=READ_UNCOMMITTED, toForget=, metadata=(sessionId=919177392, epoch=INITIAL)) (kafka.server.ReplicaFetcherThread)
java.io.IOException: Connection to 2 was disconnected before the response was read
	at org.apache.kafka.clients.NetworkClientUtils.sendAndReceive(NetworkClientUtils.java:97)
	at kafka.server.ReplicaFetcherBlockingSend.sendRequest(ReplicaFetcherBlockingSend.scala:97)
	at kafka.server.ReplicaFetcherThread.fetchFromLeader(ReplicaFetcherThread.scala:190)
	at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:241)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:130)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:129)
	at scala.Option.foreach(Option.scala:257)
	at kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:129)
	at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:111)
	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:82)
[2019-10-10 07:12:53,381] INFO [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error sending fetch request (sessionId=919177392, epoch=INITIAL) to node 2: java.io.IOException: Connection to 2 was disconnected before the response was read. (org.apache.kafka.clients.FetchSessionHandler)
[2019-10-10 07:12:53,382] WARN [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error in response for fetch request (type=FetchRequest, replicaId=4, maxWait=500, minBytes=1, maxBytes=10485760, fetchData={ie-lrx-rxer-audit-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), mft-hdfs-landing-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), it-sou-audit-evt-7=(offset=94819, logStartOffset=94819, maxBytes=1048576, currentLeaderEpoch=Optional[100]), intg-ie-lrx-rxer-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[78]), prod-pipelines-errors-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[117]), __consumer_offsets-36=(offset=3, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), panel-data-change-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), gdcp-notification-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), data-transfer-change-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), __consumer_offsets-11=(offset=15, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-heartbeat-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ukwhs-error-topic-1=(offset=8, logStartOffset=8, maxBytes=1048576, currentLeaderEpoch=Optional[105]), intg-ie-lrx-audit-evt-4=(offset=21, logStartOffset=21, maxBytes=1048576, currentLeaderEpoch=Optional[74]), __consumer_offsets-16=(offset=11329814, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), __consumer_offsets-31=(offset=3472033, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), ukpai-hdfs-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), mft-pflow-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), ukwhs-hdfs-landing-evt-01-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), it-sou-audit-evt-2=(offset=490084, logStartOffset=490084, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ie-lrx-pat-audit-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104])}, isolationLevel=READ_UNCOMMITTED, toForget=, metadata=(sessionId=919177392, epoch=INITIAL)) (kafka.server.ReplicaFetcherThread)
java.io.IOException: Connection to 2 was disconnected before the response was read
	at org.apache.kafka.clients.NetworkClientUtils.sendAndReceive(NetworkClientUtils.java:97)
	at kafka.server.ReplicaFetcherBlockingSend.sendRequest(ReplicaFetcherBlockingSend.scala:97)
	at kafka.server.ReplicaFetcherThread.fetchFromLeader(ReplicaFetcherThread.scala:190)
	at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:241)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:130)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:129)
	at scala.Option.foreach(Option.scala:257)
	at kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:129)
	at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:111)
	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:82)
[2019-10-10 07:13:54,602] INFO [GroupMetadataManager brokerId=4] Removed 0 expired offsets in 1 milliseconds. (kafka.coordinator.group.GroupMetadataManager)
[2019-10-10 07:14:55,540] INFO [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error sending fetch request (sessionId=919177392, epoch=INITIAL) to node 2: java.io.IOException: Connection to 2 was disconnected before the response was read. (org.apache.kafka.clients.FetchSessionHandler)
[2019-10-10 07:14:55,541] WARN [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error in response for fetch request (type=FetchRequest, replicaId=4, maxWait=500, minBytes=1, maxBytes=10485760, fetchData={ie-lrx-rxer-audit-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), mft-hdfs-landing-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), it-sou-audit-evt-7=(offset=94819, logStartOffset=94819, maxBytes=1048576, currentLeaderEpoch=Optional[100]), intg-ie-lrx-rxer-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[78]), prod-pipelines-errors-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[117]), __consumer_offsets-36=(offset=3, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), panel-data-change-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), gdcp-notification-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), data-transfer-change-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), __consumer_offsets-11=(offset=15, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-heartbeat-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ukwhs-error-topic-1=(offset=8, logStartOffset=8, maxBytes=1048576, currentLeaderEpoch=Optional[105]), intg-ie-lrx-audit-evt-4=(offset=21, logStartOffset=21, maxBytes=1048576, currentLeaderEpoch=Optional[74]), __consumer_offsets-16=(offset=11329814, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), __consumer_offsets-31=(offset=3472033, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), ukpai-hdfs-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), mft-pflow-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), ukwhs-hdfs-landing-evt-01-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), it-sou-audit-evt-2=(offset=490084, logStartOffset=490084, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ie-lrx-pat-audit-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104])}, isolationLevel=READ_UNCOMMITTED, toForget=, metadata=(sessionId=919177392, epoch=INITIAL)) (kafka.server.ReplicaFetcherThread)
java.io.IOException: Connection to 2 was disconnected before the response was read
	at org.apache.kafka.clients.NetworkClientUtils.sendAndReceive(NetworkClientUtils.java:97)
	at kafka.server.ReplicaFetcherBlockingSend.sendRequest(ReplicaFetcherBlockingSend.scala:97)
	at kafka.server.ReplicaFetcherThread.fetchFromLeader(ReplicaFetcherThread.scala:190)
	at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:241)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:130)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:129)
	at scala.Option.foreach(Option.scala:257)
	at kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:129)
	at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:111)
	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:82)
[2019-10-10 07:16:57,670] INFO [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error sending fetch request (sessionId=919177392, epoch=INITIAL) to node 2: java.io.IOException: Connection to 2 was disconnected before the response was read. (org.apache.kafka.clients.FetchSessionHandler)
[2019-10-10 07:16:57,670] WARN [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error in response for fetch request (type=FetchRequest, replicaId=4, maxWait=500, minBytes=1, maxBytes=10485760, fetchData={ie-lrx-rxer-audit-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), mft-hdfs-landing-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), it-sou-audit-evt-7=(offset=94819, logStartOffset=94819, maxBytes=1048576, currentLeaderEpoch=Optional[100]), intg-ie-lrx-rxer-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[78]), prod-pipelines-errors-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[117]), __consumer_offsets-36=(offset=3, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), panel-data-change-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), gdcp-notification-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), data-transfer-change-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), __consumer_offsets-11=(offset=15, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-heartbeat-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ukwhs-error-topic-1=(offset=8, logStartOffset=8, maxBytes=1048576, currentLeaderEpoch=Optional[105]), intg-ie-lrx-audit-evt-4=(offset=21, logStartOffset=21, maxBytes=1048576, currentLeaderEpoch=Optional[74]), __consumer_offsets-16=(offset=11329814, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), __consumer_offsets-31=(offset=3472033, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), ukpai-hdfs-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), mft-pflow-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), ukwhs-hdfs-landing-evt-01-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), it-sou-audit-evt-2=(offset=490084, logStartOffset=490084, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ie-lrx-pat-audit-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104])}, isolationLevel=READ_UNCOMMITTED, toForget=, metadata=(sessionId=919177392, epoch=INITIAL)) (kafka.server.ReplicaFetcherThread)
java.io.IOException: Connection to 2 was disconnected before the response was read
	at org.apache.kafka.clients.NetworkClientUtils.sendAndReceive(NetworkClientUtils.java:97)
	at kafka.server.ReplicaFetcherBlockingSend.sendRequest(ReplicaFetcherBlockingSend.scala:97)
	at kafka.server.ReplicaFetcherThread.fetchFromLeader(ReplicaFetcherThread.scala:190)
	at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:241)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:130)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:129)
	at scala.Option.foreach(Option.scala:257)
	at kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:129)
	at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:111)
	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:82)
[2019-10-10 07:18:59,771] INFO [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error sending fetch request (sessionId=919177392, epoch=INITIAL) to node 2: java.io.IOException: Connection to 2 was disconnected before the response was read. (org.apache.kafka.clients.FetchSessionHandler)
[2019-10-10 07:18:59,772] WARN [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error in response for fetch request (type=FetchRequest, replicaId=4, maxWait=500, minBytes=1, maxBytes=10485760, fetchData={ie-lrx-rxer-audit-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), mft-hdfs-landing-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), it-sou-audit-evt-7=(offset=94819, logStartOffset=94819, maxBytes=1048576, currentLeaderEpoch=Optional[100]), intg-ie-lrx-rxer-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[78]), prod-pipelines-errors-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[117]), __consumer_offsets-36=(offset=3, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), panel-data-change-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), gdcp-notification-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), data-transfer-change-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), __consumer_offsets-11=(offset=15, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-heartbeat-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ukwhs-error-topic-1=(offset=8, logStartOffset=8, maxBytes=1048576, currentLeaderEpoch=Optional[105]), intg-ie-lrx-audit-evt-4=(offset=21, logStartOffset=21, maxBytes=1048576, currentLeaderEpoch=Optional[74]), __consumer_offsets-16=(offset=11329814, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), __consumer_offsets-31=(offset=3472033, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), ukpai-hdfs-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), mft-pflow-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), ukwhs-hdfs-landing-evt-01-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), it-sou-audit-evt-2=(offset=490084, logStartOffset=490084, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ie-lrx-pat-audit-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104])}, isolationLevel=READ_UNCOMMITTED, toForget=, metadata=(sessionId=919177392, epoch=INITIAL)) (kafka.server.ReplicaFetcherThread)
java.io.IOException: Connection to 2 was disconnected before the response was read
	at org.apache.kafka.clients.NetworkClientUtils.sendAndReceive(NetworkClientUtils.java:97)
	at kafka.server.ReplicaFetcherBlockingSend.sendRequest(ReplicaFetcherBlockingSend.scala:97)
	at kafka.server.ReplicaFetcherThread.fetchFromLeader(ReplicaFetcherThread.scala:190)
	at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:241)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:130)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:129)
	at scala.Option.foreach(Option.scala:257)
	at kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:129)
	at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:111)
	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:82)
[2019-10-10 07:21:01,903] INFO [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error sending fetch request (sessionId=919177392, epoch=INITIAL) to node 2: java.io.IOException: Connection to 2 was disconnected before the response was read. (org.apache.kafka.clients.FetchSessionHandler)
[2019-10-10 07:21:01,904] WARN [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error in response for fetch request (type=FetchRequest, replicaId=4, maxWait=500, minBytes=1, maxBytes=10485760, fetchData={ie-lrx-rxer-audit-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), mft-hdfs-landing-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), it-sou-audit-evt-7=(offset=94819, logStartOffset=94819, maxBytes=1048576, currentLeaderEpoch=Optional[100]), intg-ie-lrx-rxer-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[78]), prod-pipelines-errors-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[117]), __consumer_offsets-36=(offset=3, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), panel-data-change-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), gdcp-notification-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), data-transfer-change-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), __consumer_offsets-11=(offset=15, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-heartbeat-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ukwhs-error-topic-1=(offset=8, logStartOffset=8, maxBytes=1048576, currentLeaderEpoch=Optional[105]), intg-ie-lrx-audit-evt-4=(offset=21, logStartOffset=21, maxBytes=1048576, currentLeaderEpoch=Optional[74]), __consumer_offsets-16=(offset=11329814, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), __consumer_offsets-31=(offset=3472033, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), ukpai-hdfs-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), mft-pflow-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), ukwhs-hdfs-landing-evt-01-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), it-sou-audit-evt-2=(offset=490084, logStartOffset=490084, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ie-lrx-pat-audit-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104])}, isolationLevel=READ_UNCOMMITTED, toForget=, metadata=(sessionId=919177392, epoch=INITIAL)) (kafka.server.ReplicaFetcherThread)
java.io.IOException: Connection to 2 was disconnected before the response was read
	at org.apache.kafka.clients.NetworkClientUtils.sendAndReceive(NetworkClientUtils.java:97)
	at kafka.server.ReplicaFetcherBlockingSend.sendRequest(ReplicaFetcherBlockingSend.scala:97)
	at kafka.server.ReplicaFetcherThread.fetchFromLeader(ReplicaFetcherThread.scala:190)
	at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:241)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:130)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:129)
	at scala.Option.foreach(Option.scala:257)
	at kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:129)
	at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:111)
	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:82)
[2019-10-10 07:23:04,042] INFO [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error sending fetch request (sessionId=919177392, epoch=INITIAL) to node 2: java.io.IOException: Connection to 2 was disconnected before the response was read. (org.apache.kafka.clients.FetchSessionHandler)
[2019-10-10 07:23:04,042] WARN [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error in response for fetch request (type=FetchRequest, replicaId=4, maxWait=500, minBytes=1, maxBytes=10485760, fetchData={ie-lrx-rxer-audit-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), mft-hdfs-landing-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), it-sou-audit-evt-7=(offset=94819, logStartOffset=94819, maxBytes=1048576, currentLeaderEpoch=Optional[100]), intg-ie-lrx-rxer-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[78]), prod-pipelines-errors-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[117]), __consumer_offsets-36=(offset=3, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), panel-data-change-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), gdcp-notification-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), data-transfer-change-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), __consumer_offsets-11=(offset=15, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-heartbeat-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ukwhs-error-topic-1=(offset=8, logStartOffset=8, maxBytes=1048576, currentLeaderEpoch=Optional[105]), intg-ie-lrx-audit-evt-4=(offset=21, logStartOffset=21, maxBytes=1048576, currentLeaderEpoch=Optional[74]), __consumer_offsets-16=(offset=11329814, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), __consumer_offsets-31=(offset=3472033, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), ukpai-hdfs-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), mft-pflow-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), ukwhs-hdfs-landing-evt-01-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), it-sou-audit-evt-2=(offset=490084, logStartOffset=490084, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ie-lrx-pat-audit-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104])}, isolationLevel=READ_UNCOMMITTED, toForget=, metadata=(sessionId=919177392, epoch=INITIAL)) (kafka.server.ReplicaFetcherThread)
java.io.IOException: Connection to 2 was disconnected before the response was read
	at org.apache.kafka.clients.NetworkClientUtils.sendAndReceive(NetworkClientUtils.java:97)
	at kafka.server.ReplicaFetcherBlockingSend.sendRequest(ReplicaFetcherBlockingSend.scala:97)
	at kafka.server.ReplicaFetcherThread.fetchFromLeader(ReplicaFetcherThread.scala:190)
	at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:241)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:130)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:129)
	at scala.Option.foreach(Option.scala:257)
	at kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:129)
	at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:111)
	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:82)
[2019-10-10 07:23:54,603] INFO [GroupMetadataManager brokerId=4] Removed 0 expired offsets in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager)
[2019-10-10 07:25:06,093] INFO [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error sending fetch request (sessionId=919177392, epoch=INITIAL) to node 2: java.io.IOException: Connection to 2 was disconnected before the response was read. (org.apache.kafka.clients.FetchSessionHandler)
[2019-10-10 07:25:06,121] WARN [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error in response for fetch request (type=FetchRequest, replicaId=4, maxWait=500, minBytes=1, maxBytes=10485760, fetchData={ie-lrx-rxer-audit-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), mft-hdfs-landing-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), it-sou-audit-evt-7=(offset=94819, logStartOffset=94819, maxBytes=1048576, currentLeaderEpoch=Optional[100]), intg-ie-lrx-rxer-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[78]), prod-pipelines-errors-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[117]), __consumer_offsets-36=(offset=3, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), panel-data-change-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), gdcp-notification-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), data-transfer-change-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), __consumer_offsets-11=(offset=15, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-heartbeat-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ukwhs-error-topic-1=(offset=8, logStartOffset=8, maxBytes=1048576, currentLeaderEpoch=Optional[105]), intg-ie-lrx-audit-evt-4=(offset=21, logStartOffset=21, maxBytes=1048576, currentLeaderEpoch=Optional[74]), __consumer_offsets-16=(offset=11329814, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), __consumer_offsets-31=(offset=3472033, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), ukpai-hdfs-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), mft-pflow-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), ukwhs-hdfs-landing-evt-01-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), it-sou-audit-evt-2=(offset=490084, logStartOffset=490084, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ie-lrx-pat-audit-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104])}, isolationLevel=READ_UNCOMMITTED, toForget=, metadata=(sessionId=919177392, epoch=INITIAL)) (kafka.server.ReplicaFetcherThread)
java.io.IOException: Connection to 2 was disconnected before the response was read
	at org.apache.kafka.clients.NetworkClientUtils.sendAndReceive(NetworkClientUtils.java:97)
	at kafka.server.ReplicaFetcherBlockingSend.sendRequest(ReplicaFetcherBlockingSend.scala:97)
	at kafka.server.ReplicaFetcherThread.fetchFromLeader(ReplicaFetcherThread.scala:190)
	at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:241)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:130)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:129)
	at scala.Option.foreach(Option.scala:257)
	at kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:129)
	at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:111)
	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:82)
[2019-10-10 07:27:08,242] INFO [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error sending fetch request (sessionId=919177392, epoch=INITIAL) to node 2: java.io.IOException: Connection to 2 was disconnected before the response was read. (org.apache.kafka.clients.FetchSessionHandler)
[2019-10-10 07:27:08,242] WARN [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error in response for fetch request (type=FetchRequest, replicaId=4, maxWait=500, minBytes=1, maxBytes=10485760, fetchData={ie-lrx-rxer-audit-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), mft-hdfs-landing-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), it-sou-audit-evt-7=(offset=94819, logStartOffset=94819, maxBytes=1048576, currentLeaderEpoch=Optional[100]), intg-ie-lrx-rxer-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[78]), prod-pipelines-errors-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[117]), __consumer_offsets-36=(offset=3, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), panel-data-change-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), gdcp-notification-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), data-transfer-change-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), __consumer_offsets-11=(offset=15, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-heartbeat-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ukwhs-error-topic-1=(offset=8, logStartOffset=8, maxBytes=1048576, currentLeaderEpoch=Optional[105]), intg-ie-lrx-audit-evt-4=(offset=21, logStartOffset=21, maxBytes=1048576, currentLeaderEpoch=Optional[74]), __consumer_offsets-16=(offset=11329814, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), __consumer_offsets-31=(offset=3472033, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), ukpai-hdfs-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), mft-pflow-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), ukwhs-hdfs-landing-evt-01-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), it-sou-audit-evt-2=(offset=490084, logStartOffset=490084, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ie-lrx-pat-audit-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104])}, isolationLevel=READ_UNCOMMITTED, toForget=, metadata=(sessionId=919177392, epoch=INITIAL)) (kafka.server.ReplicaFetcherThread)
java.io.IOException: Connection to 2 was disconnected before the response was read
	at org.apache.kafka.clients.NetworkClientUtils.sendAndReceive(NetworkClientUtils.java:97)
	at kafka.server.ReplicaFetcherBlockingSend.sendRequest(ReplicaFetcherBlockingSend.scala:97)
	at kafka.server.ReplicaFetcherThread.fetchFromLeader(ReplicaFetcherThread.scala:190)
	at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:241)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:130)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:129)
	at scala.Option.foreach(Option.scala:257)
	at kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:129)
	at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:111)
	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:82)
[2019-10-10 07:29:10,353] INFO [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error sending fetch request (sessionId=919177392, epoch=INITIAL) to node 2: java.io.IOException: Connection to 2 was disconnected before the response was read. (org.apache.kafka.clients.FetchSessionHandler)
[2019-10-10 07:29:10,354] WARN [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error in response for fetch request (type=FetchRequest, replicaId=4, maxWait=500, minBytes=1, maxBytes=10485760, fetchData={ie-lrx-rxer-audit-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), mft-hdfs-landing-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), it-sou-audit-evt-7=(offset=94819, logStartOffset=94819, maxBytes=1048576, currentLeaderEpoch=Optional[100]), intg-ie-lrx-rxer-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[78]), prod-pipelines-errors-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[117]), __consumer_offsets-36=(offset=3, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), panel-data-change-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), gdcp-notification-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), data-transfer-change-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), __consumer_offsets-11=(offset=15, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-heartbeat-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ukwhs-error-topic-1=(offset=8, logStartOffset=8, maxBytes=1048576, currentLeaderEpoch=Optional[105]), intg-ie-lrx-audit-evt-4=(offset=21, logStartOffset=21, maxBytes=1048576, currentLeaderEpoch=Optional[74]), __consumer_offsets-16=(offset=11329814, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), __consumer_offsets-31=(offset=3472033, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), ukpai-hdfs-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), mft-pflow-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), ukwhs-hdfs-landing-evt-01-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), it-sou-audit-evt-2=(offset=490084, logStartOffset=490084, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ie-lrx-pat-audit-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104])}, isolationLevel=READ_UNCOMMITTED, toForget=, metadata=(sessionId=919177392, epoch=INITIAL)) (kafka.server.ReplicaFetcherThread)
java.io.IOException: Connection to 2 was disconnected before the response was read
	at org.apache.kafka.clients.NetworkClientUtils.sendAndReceive(NetworkClientUtils.java:97)
	at kafka.server.ReplicaFetcherBlockingSend.sendRequest(ReplicaFetcherBlockingSend.scala:97)
	at kafka.server.ReplicaFetcherThread.fetchFromLeader(ReplicaFetcherThread.scala:190)
	at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:241)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:130)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:129)
	at scala.Option.foreach(Option.scala:257)
	at kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:129)
	at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:111)
	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:82)
[2019-10-10 07:31:12,481] INFO [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error sending fetch request (sessionId=919177392, epoch=INITIAL) to node 2: java.io.IOException: Connection to 2 was disconnected before the response was read. (org.apache.kafka.clients.FetchSessionHandler)
[2019-10-10 07:31:12,481] WARN [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error in response for fetch request (type=FetchRequest, replicaId=4, maxWait=500, minBytes=1, maxBytes=10485760, fetchData={ie-lrx-rxer-audit-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), mft-hdfs-landing-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), it-sou-audit-evt-7=(offset=94819, logStartOffset=94819, maxBytes=1048576, currentLeaderEpoch=Optional[100]), intg-ie-lrx-rxer-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[78]), prod-pipelines-errors-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[117]), __consumer_offsets-36=(offset=3, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), panel-data-change-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), gdcp-notification-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), data-transfer-change-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), __consumer_offsets-11=(offset=15, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-heartbeat-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ukwhs-error-topic-1=(offset=8, logStartOffset=8, maxBytes=1048576, currentLeaderEpoch=Optional[105]), intg-ie-lrx-audit-evt-4=(offset=21, logStartOffset=21, maxBytes=1048576, currentLeaderEpoch=Optional[74]), __consumer_offsets-16=(offset=11329814, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), __consumer_offsets-31=(offset=3472033, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), ukpai-hdfs-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), mft-pflow-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), ukwhs-hdfs-landing-evt-01-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), it-sou-audit-evt-2=(offset=490084, logStartOffset=490084, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ie-lrx-pat-audit-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104])}, isolationLevel=READ_UNCOMMITTED, toForget=, metadata=(sessionId=919177392, epoch=INITIAL)) (kafka.server.ReplicaFetcherThread)
java.io.IOException: Connection to 2 was disconnected before the response was read
	at org.apache.kafka.clients.NetworkClientUtils.sendAndReceive(NetworkClientUtils.java:97)
	at kafka.server.ReplicaFetcherBlockingSend.sendRequest(ReplicaFetcherBlockingSend.scala:97)
	at kafka.server.ReplicaFetcherThread.fetchFromLeader(ReplicaFetcherThread.scala:190)
	at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:241)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:130)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:129)
	at scala.Option.foreach(Option.scala:257)
	at kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:129)
	at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:111)
	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:82)
[2019-10-10 07:33:14,582] INFO [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error sending fetch request (sessionId=919177392, epoch=INITIAL) to node 2: java.io.IOException: Connection to 2 was disconnected before the response was read. (org.apache.kafka.clients.FetchSessionHandler)
[2019-10-10 07:33:14,582] WARN [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error in response for fetch request (type=FetchRequest, replicaId=4, maxWait=500, minBytes=1, maxBytes=10485760, fetchData={ie-lrx-rxer-audit-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), mft-hdfs-landing-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), it-sou-audit-evt-7=(offset=94819, logStartOffset=94819, maxBytes=1048576, currentLeaderEpoch=Optional[100]), intg-ie-lrx-rxer-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[78]), prod-pipelines-errors-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[117]), __consumer_offsets-36=(offset=3, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), panel-data-change-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), gdcp-notification-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), data-transfer-change-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), __consumer_offsets-11=(offset=15, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-heartbeat-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ukwhs-error-topic-1=(offset=8, logStartOffset=8, maxBytes=1048576, currentLeaderEpoch=Optional[105]), intg-ie-lrx-audit-evt-4=(offset=21, logStartOffset=21, maxBytes=1048576, currentLeaderEpoch=Optional[74]), __consumer_offsets-16=(offset=11329814, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), __consumer_offsets-31=(offset=3472033, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), ukpai-hdfs-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), mft-pflow-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), ukwhs-hdfs-landing-evt-01-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), it-sou-audit-evt-2=(offset=490084, logStartOffset=490084, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ie-lrx-pat-audit-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104])}, isolationLevel=READ_UNCOMMITTED, toForget=, metadata=(sessionId=919177392, epoch=INITIAL)) (kafka.server.ReplicaFetcherThread)
java.io.IOException: Connection to 2 was disconnected before the response was read
	at org.apache.kafka.clients.NetworkClientUtils.sendAndReceive(NetworkClientUtils.java:97)
	at kafka.server.ReplicaFetcherBlockingSend.sendRequest(ReplicaFetcherBlockingSend.scala:97)
	at kafka.server.ReplicaFetcherThread.fetchFromLeader(ReplicaFetcherThread.scala:190)
	at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:241)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:130)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:129)
	at scala.Option.foreach(Option.scala:257)
	at kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:129)
	at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:111)
	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:82)
[2019-10-10 07:33:54,612] INFO [GroupMetadataManager brokerId=4] Removed 0 expired offsets in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager)
[2019-10-10 07:35:16,683] INFO [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error sending fetch request (sessionId=919177392, epoch=INITIAL) to node 2: java.io.IOException: Connection to 2 was disconnected before the response was read. (org.apache.kafka.clients.FetchSessionHandler)
[2019-10-10 07:35:16,694] WARN [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error in response for fetch request (type=FetchRequest, replicaId=4, maxWait=500, minBytes=1, maxBytes=10485760, fetchData={ie-lrx-rxer-audit-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), mft-hdfs-landing-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), it-sou-audit-evt-7=(offset=94819, logStartOffset=94819, maxBytes=1048576, currentLeaderEpoch=Optional[100]), intg-ie-lrx-rxer-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[78]), prod-pipelines-errors-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[117]), __consumer_offsets-36=(offset=3, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), panel-data-change-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), gdcp-notification-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), data-transfer-change-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), __consumer_offsets-11=(offset=15, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-heartbeat-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ukwhs-error-topic-1=(offset=8, logStartOffset=8, maxBytes=1048576, currentLeaderEpoch=Optional[105]), intg-ie-lrx-audit-evt-4=(offset=21, logStartOffset=21, maxBytes=1048576, currentLeaderEpoch=Optional[74]), __consumer_offsets-16=(offset=11329814, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), __consumer_offsets-31=(offset=3472033, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), ukpai-hdfs-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), mft-pflow-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), ukwhs-hdfs-landing-evt-01-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), it-sou-audit-evt-2=(offset=490084, logStartOffset=490084, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ie-lrx-pat-audit-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104])}, isolationLevel=READ_UNCOMMITTED, toForget=, metadata=(sessionId=919177392, epoch=INITIAL)) (kafka.server.ReplicaFetcherThread)
java.io.IOException: Connection to 2 was disconnected before the response was read
	at org.apache.kafka.clients.NetworkClientUtils.sendAndReceive(NetworkClientUtils.java:97)
	at kafka.server.ReplicaFetcherBlockingSend.sendRequest(ReplicaFetcherBlockingSend.scala:97)
	at kafka.server.ReplicaFetcherThread.fetchFromLeader(ReplicaFetcherThread.scala:190)
	at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:241)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:130)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:129)
	at scala.Option.foreach(Option.scala:257)
	at kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:129)
	at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:111)
	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:82)
[2019-10-10 07:37:18,814] INFO [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error sending fetch request (sessionId=919177392, epoch=INITIAL) to node 2: java.io.IOException: Connection to 2 was disconnected before the response was read. (org.apache.kafka.clients.FetchSessionHandler)
[2019-10-10 07:37:18,816] WARN [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error in response for fetch request (type=FetchRequest, replicaId=4, maxWait=500, minBytes=1, maxBytes=10485760, fetchData={ie-lrx-rxer-audit-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), mft-hdfs-landing-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), it-sou-audit-evt-7=(offset=94819, logStartOffset=94819, maxBytes=1048576, currentLeaderEpoch=Optional[100]), intg-ie-lrx-rxer-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[78]), prod-pipelines-errors-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[117]), __consumer_offsets-36=(offset=3, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), panel-data-change-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), gdcp-notification-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), data-transfer-change-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), __consumer_offsets-11=(offset=15, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-heartbeat-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ukwhs-error-topic-1=(offset=8, logStartOffset=8, maxBytes=1048576, currentLeaderEpoch=Optional[105]), intg-ie-lrx-audit-evt-4=(offset=21, logStartOffset=21, maxBytes=1048576, currentLeaderEpoch=Optional[74]), __consumer_offsets-16=(offset=11329814, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), __consumer_offsets-31=(offset=3472033, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), ukpai-hdfs-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), mft-pflow-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), ukwhs-hdfs-landing-evt-01-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), it-sou-audit-evt-2=(offset=490084, logStartOffset=490084, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ie-lrx-pat-audit-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104])}, isolationLevel=READ_UNCOMMITTED, toForget=, metadata=(sessionId=919177392, epoch=INITIAL)) (kafka.server.ReplicaFetcherThread)
java.io.IOException: Connection to 2 was disconnected before the response was read
	at org.apache.kafka.clients.NetworkClientUtils.sendAndReceive(NetworkClientUtils.java:97)
	at kafka.server.ReplicaFetcherBlockingSend.sendRequest(ReplicaFetcherBlockingSend.scala:97)
	at kafka.server.ReplicaFetcherThread.fetchFromLeader(ReplicaFetcherThread.scala:190)
	at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:241)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:130)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:129)
	at scala.Option.foreach(Option.scala:257)
	at kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:129)
	at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:111)
	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:82)
[2019-10-10 07:39:20,982] INFO [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error sending fetch request (sessionId=919177392, epoch=INITIAL) to node 2: java.io.IOException: Connection to 2 was disconnected before the response was read. (org.apache.kafka.clients.FetchSessionHandler)
[2019-10-10 07:39:20,982] WARN [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error in response for fetch request (type=FetchRequest, replicaId=4, maxWait=500, minBytes=1, maxBytes=10485760, fetchData={ie-lrx-rxer-audit-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), mft-hdfs-landing-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), it-sou-audit-evt-7=(offset=94819, logStartOffset=94819, maxBytes=1048576, currentLeaderEpoch=Optional[100]), intg-ie-lrx-rxer-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[78]), prod-pipelines-errors-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[117]), __consumer_offsets-36=(offset=3, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), panel-data-change-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), gdcp-notification-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), data-transfer-change-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), __consumer_offsets-11=(offset=15, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-heartbeat-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ukwhs-error-topic-1=(offset=8, logStartOffset=8, maxBytes=1048576, currentLeaderEpoch=Optional[105]), intg-ie-lrx-audit-evt-4=(offset=21, logStartOffset=21, maxBytes=1048576, currentLeaderEpoch=Optional[74]), __consumer_offsets-16=(offset=11329814, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), __consumer_offsets-31=(offset=3472033, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), ukpai-hdfs-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), mft-pflow-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), ukwhs-hdfs-landing-evt-01-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), it-sou-audit-evt-2=(offset=490084, logStartOffset=490084, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ie-lrx-pat-audit-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104])}, isolationLevel=READ_UNCOMMITTED, toForget=, metadata=(sessionId=919177392, epoch=INITIAL)) (kafka.server.ReplicaFetcherThread)
java.io.IOException: Connection to 2 was disconnected before the response was read
	at org.apache.kafka.clients.NetworkClientUtils.sendAndReceive(NetworkClientUtils.java:97)
	at kafka.server.ReplicaFetcherBlockingSend.sendRequest(ReplicaFetcherBlockingSend.scala:97)
	at kafka.server.ReplicaFetcherThread.fetchFromLeader(ReplicaFetcherThread.scala:190)
	at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:241)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:130)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:129)
	at scala.Option.foreach(Option.scala:257)
	at kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:129)
	at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:111)
	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:82)
[2019-10-10 07:41:23,064] INFO [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error sending fetch request (sessionId=919177392, epoch=INITIAL) to node 2: java.io.IOException: Connection to 2 was disconnected before the response was read. (org.apache.kafka.clients.FetchSessionHandler)
[2019-10-10 07:41:23,074] WARN [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error in response for fetch request (type=FetchRequest, replicaId=4, maxWait=500, minBytes=1, maxBytes=10485760, fetchData={ie-lrx-rxer-audit-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), mft-hdfs-landing-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), it-sou-audit-evt-7=(offset=94819, logStartOffset=94819, maxBytes=1048576, currentLeaderEpoch=Optional[100]), intg-ie-lrx-rxer-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[78]), prod-pipelines-errors-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[117]), __consumer_offsets-36=(offset=3, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), panel-data-change-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), gdcp-notification-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), data-transfer-change-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), __consumer_offsets-11=(offset=15, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-heartbeat-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ukwhs-error-topic-1=(offset=8, logStartOffset=8, maxBytes=1048576, currentLeaderEpoch=Optional[105]), intg-ie-lrx-audit-evt-4=(offset=21, logStartOffset=21, maxBytes=1048576, currentLeaderEpoch=Optional[74]), __consumer_offsets-16=(offset=11329814, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), __consumer_offsets-31=(offset=3472033, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), ukpai-hdfs-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), mft-pflow-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), ukwhs-hdfs-landing-evt-01-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), it-sou-audit-evt-2=(offset=490084, logStartOffset=490084, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ie-lrx-pat-audit-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104])}, isolationLevel=READ_UNCOMMITTED, toForget=, metadata=(sessionId=919177392, epoch=INITIAL)) (kafka.server.ReplicaFetcherThread)
java.io.IOException: Connection to 2 was disconnected before the response was read
	at org.apache.kafka.clients.NetworkClientUtils.sendAndReceive(NetworkClientUtils.java:97)
	at kafka.server.ReplicaFetcherBlockingSend.sendRequest(ReplicaFetcherBlockingSend.scala:97)
	at kafka.server.ReplicaFetcherThread.fetchFromLeader(ReplicaFetcherThread.scala:190)
	at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:241)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:130)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:129)
	at scala.Option.foreach(Option.scala:257)
	at kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:129)
	at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:111)
	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:82)
[2019-10-10 07:43:25,241] INFO [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error sending fetch request (sessionId=919177392, epoch=INITIAL) to node 2: java.io.IOException: Connection to 2 was disconnected before the response was read. (org.apache.kafka.clients.FetchSessionHandler)
[2019-10-10 07:43:25,242] WARN [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error in response for fetch request (type=FetchRequest, replicaId=4, maxWait=500, minBytes=1, maxBytes=10485760, fetchData={ie-lrx-rxer-audit-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), mft-hdfs-landing-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), it-sou-audit-evt-7=(offset=94819, logStartOffset=94819, maxBytes=1048576, currentLeaderEpoch=Optional[100]), intg-ie-lrx-rxer-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[78]), prod-pipelines-errors-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[117]), __consumer_offsets-36=(offset=3, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), panel-data-change-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), gdcp-notification-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), data-transfer-change-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), __consumer_offsets-11=(offset=15, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-heartbeat-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ukwhs-error-topic-1=(offset=8, logStartOffset=8, maxBytes=1048576, currentLeaderEpoch=Optional[105]), intg-ie-lrx-audit-evt-4=(offset=21, logStartOffset=21, maxBytes=1048576, currentLeaderEpoch=Optional[74]), __consumer_offsets-16=(offset=11329814, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), __consumer_offsets-31=(offset=3472033, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), ukpai-hdfs-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), mft-pflow-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), ukwhs-hdfs-landing-evt-01-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), it-sou-audit-evt-2=(offset=490084, logStartOffset=490084, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ie-lrx-pat-audit-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104])}, isolationLevel=READ_UNCOMMITTED, toForget=, metadata=(sessionId=919177392, epoch=INITIAL)) (kafka.server.ReplicaFetcherThread)
java.io.IOException: Connection to 2 was disconnected before the response was read
	at org.apache.kafka.clients.NetworkClientUtils.sendAndReceive(NetworkClientUtils.java:97)
	at kafka.server.ReplicaFetcherBlockingSend.sendRequest(ReplicaFetcherBlockingSend.scala:97)
	at kafka.server.ReplicaFetcherThread.fetchFromLeader(ReplicaFetcherThread.scala:190)
	at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:241)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:130)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:129)
	at scala.Option.foreach(Option.scala:257)
	at kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:129)
	at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:111)
	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:82)
[2019-10-10 07:43:54,603] INFO [GroupMetadataManager brokerId=4] Removed 0 expired offsets in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager)
[2019-10-10 07:45:27,383] INFO [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error sending fetch request (sessionId=919177392, epoch=INITIAL) to node 2: java.io.IOException: Connection to 2 was disconnected before the response was read. (org.apache.kafka.clients.FetchSessionHandler)
[2019-10-10 07:45:27,392] WARN [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error in response for fetch request (type=FetchRequest, replicaId=4, maxWait=500, minBytes=1, maxBytes=10485760, fetchData={ie-lrx-rxer-audit-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), mft-hdfs-landing-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), it-sou-audit-evt-7=(offset=94819, logStartOffset=94819, maxBytes=1048576, currentLeaderEpoch=Optional[100]), intg-ie-lrx-rxer-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[78]), prod-pipelines-errors-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[117]), __consumer_offsets-36=(offset=3, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), panel-data-change-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), gdcp-notification-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), data-transfer-change-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), __consumer_offsets-11=(offset=15, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-heartbeat-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ukwhs-error-topic-1=(offset=8, logStartOffset=8, maxBytes=1048576, currentLeaderEpoch=Optional[105]), intg-ie-lrx-audit-evt-4=(offset=21, logStartOffset=21, maxBytes=1048576, currentLeaderEpoch=Optional[74]), __consumer_offsets-16=(offset=11329814, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), __consumer_offsets-31=(offset=3472033, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), ukpai-hdfs-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), mft-pflow-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), ukwhs-hdfs-landing-evt-01-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), it-sou-audit-evt-2=(offset=490084, logStartOffset=490084, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ie-lrx-pat-audit-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104])}, isolationLevel=READ_UNCOMMITTED, toForget=, metadata=(sessionId=919177392, epoch=INITIAL)) (kafka.server.ReplicaFetcherThread)
java.io.IOException: Connection to 2 was disconnected before the response was read
	at org.apache.kafka.clients.NetworkClientUtils.sendAndReceive(NetworkClientUtils.java:97)
	at kafka.server.ReplicaFetcherBlockingSend.sendRequest(ReplicaFetcherBlockingSend.scala:97)
	at kafka.server.ReplicaFetcherThread.fetchFromLeader(ReplicaFetcherThread.scala:190)
	at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:241)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:130)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:129)
	at scala.Option.foreach(Option.scala:257)
	at kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:129)
	at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:111)
	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:82)
[2019-10-10 07:47:29,523] INFO [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error sending fetch request (sessionId=919177392, epoch=INITIAL) to node 2: java.io.IOException: Connection to 2 was disconnected before the response was read. (org.apache.kafka.clients.FetchSessionHandler)
[2019-10-10 07:47:29,523] WARN [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error in response for fetch request (type=FetchRequest, replicaId=4, maxWait=500, minBytes=1, maxBytes=10485760, fetchData={ie-lrx-rxer-audit-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), mft-hdfs-landing-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), it-sou-audit-evt-7=(offset=94819, logStartOffset=94819, maxBytes=1048576, currentLeaderEpoch=Optional[100]), intg-ie-lrx-rxer-audit-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[78]), prod-pipelines-errors-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[117]), __consumer_offsets-36=(offset=3, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), panel-data-change-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), gdcp-notification-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), data-transfer-change-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), __consumer_offsets-11=(offset=15, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), dca-heartbeat-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ukwhs-error-topic-1=(offset=8, logStartOffset=8, maxBytes=1048576, currentLeaderEpoch=Optional[105]), intg-ie-lrx-audit-evt-4=(offset=21, logStartOffset=21, maxBytes=1048576, currentLeaderEpoch=Optional[74]), __consumer_offsets-16=(offset=11329814, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104]), __consumer_offsets-31=(offset=3472033, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), ukpai-hdfs-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[107]), mft-pflow-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[108]), ukwhs-hdfs-landing-evt-01-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[105]), it-sou-audit-evt-2=(offset=490084, logStartOffset=490084, maxBytes=1048576, currentLeaderEpoch=Optional[105]), ie-lrx-pat-audit-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[104])}, isolationLevel=READ_UNCOMMITTED, toForget=, metadata=(sessionId=919177392, epoch=INITIAL)) (kafka.server.ReplicaFetcherThread)
java.io.IOException: Connection to 2 was disconnected before the response was read
	at org.apache.kafka.clients.NetworkClientUtils.sendAndReceive(NetworkClientUtils.java:97)
	at kafka.server.ReplicaFetcherBlockingSend.sendRequest(ReplicaFetcherBlockingSend.scala:97)
	at kafka.server.ReplicaFetcherThread.fetchFromLeader(ReplicaFetcherThread.scala:190)
	at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:241)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:130)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:129)
	at scala.Option.foreach(Option.scala:257)
	at kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:129)
	at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:111)
	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:82)
[2019-10-10 07:48:12,392] INFO [ReplicaFetcherManager on broker 4] Removed fetcher for partitions Set(email-service-audit-4, __consumer_offsets-9, __consumer_offsets-49, send-email-evt-4, prod-fi-hdfs-landing-evt-4, mft-file-arrival-evt-3, __consumer_offsets-29, ie-lrx-audit-evt-1) (kafka.server.ReplicaFetcherManager)
[2019-10-10 07:48:12,404] INFO [Partition __consumer_offsets-29 broker=4] __consumer_offsets-29 starts at Leader Epoch 40 from offset 6. Previous Leader Epoch was: 39 (kafka.cluster.Partition)
[2019-10-10 07:48:12,437] INFO [Partition send-email-evt-4 broker=4] send-email-evt-4 starts at Leader Epoch 39 from offset 0. Previous Leader Epoch was: 38 (kafka.cluster.Partition)
[2019-10-10 07:48:12,451] INFO [Partition __consumer_offsets-49 broker=4] __consumer_offsets-49 starts at Leader Epoch 39 from offset 15. Previous Leader Epoch was: 38 (kafka.cluster.Partition)
[2019-10-10 07:48:12,462] INFO [Partition mft-file-arrival-evt-3 broker=4] mft-file-arrival-evt-3 starts at Leader Epoch 40 from offset 0. Previous Leader Epoch was: 39 (kafka.cluster.Partition)
[2019-10-10 07:48:12,483] INFO [Partition ie-lrx-audit-evt-1 broker=4] ie-lrx-audit-evt-1 starts at Leader Epoch 40 from offset 728. Previous Leader Epoch was: 39 (kafka.cluster.Partition)
[2019-10-10 07:48:12,494] INFO [Partition prod-fi-hdfs-landing-evt-4 broker=4] prod-fi-hdfs-landing-evt-4 starts at Leader Epoch 9 from offset 0. Previous Leader Epoch was: 8 (kafka.cluster.Partition)
[2019-10-10 07:48:12,513] INFO [Partition __consumer_offsets-9 broker=4] __consumer_offsets-9 starts at Leader Epoch 39 from offset 6. Previous Leader Epoch was: 38 (kafka.cluster.Partition)
[2019-10-10 07:48:12,524] INFO [Partition email-service-audit-4 broker=4] email-service-audit-4 starts at Leader Epoch 38 from offset 0. Previous Leader Epoch was: 37 (kafka.cluster.Partition)
[2019-10-10 07:48:12,542] INFO [ReplicaFetcherManager on broker 4] Removed fetcher for partitions Set(fi-error-records-1, __consumer_offsets-4, email-srvc-audit-evt-3, __consumer_offsets-44, __consumer_offsets-24) (kafka.server.ReplicaFetcherManager)
[2019-10-10 07:48:12,543] INFO [ReplicaFetcherManager on broker 4] Added fetcher to broker BrokerEndPoint(id=3, host=10.75.148.7:9610) for partitions Map(__consumer_offsets-4 -> (offset=6, leaderEpoch=36), email-srvc-audit-evt-3 -> (offset=0, leaderEpoch=37), __consumer_offsets-24 -> (offset=6, leaderEpoch=38), fi-error-records-1 -> (offset=0, leaderEpoch=8), __consumer_offsets-44 -> (offset=6, leaderEpoch=38)) (kafka.server.ReplicaFetcherManager)
[2019-10-10 07:48:12,553] INFO [ReplicaFetcher replicaId=4, leaderId=0, fetcherId=0] Shutting down (kafka.server.ReplicaFetcherThread)
[2019-10-10 07:48:12,576] INFO [ReplicaFetcher replicaId=4, leaderId=0, fetcherId=0] Shutdown completed (kafka.server.ReplicaFetcherThread)
[2019-10-10 07:48:12,602] INFO [ReplicaFetcher replicaId=4, leaderId=0, fetcherId=0] Stopped (kafka.server.ReplicaFetcherThread)
[2019-10-10 07:48:12,630] INFO [GroupMetadataManager brokerId=4] Scheduling loading of offsets and group metadata from __consumer_offsets-9 (kafka.coordinator.group.GroupMetadataManager)
[2019-10-10 07:48:12,631] INFO [GroupMetadataManager brokerId=4] Scheduling loading of offsets and group metadata from __consumer_offsets-49 (kafka.coordinator.group.GroupMetadataManager)
[2019-10-10 07:48:12,631] INFO [GroupMetadataManager brokerId=4] Scheduling loading of offsets and group metadata from __consumer_offsets-29 (kafka.coordinator.group.GroupMetadataManager)
[2019-10-10 07:48:12,631] INFO [GroupMetadataManager brokerId=4] Scheduling unloading of offsets and group metadata from __consumer_offsets-44 (kafka.coordinator.group.GroupMetadataManager)
[2019-10-10 07:48:12,631] INFO [GroupMetadataManager brokerId=4] Scheduling unloading of offsets and group metadata from __consumer_offsets-24 (kafka.coordinator.group.GroupMetadataManager)
[2019-10-10 07:48:12,632] INFO [GroupMetadataManager brokerId=4] Scheduling unloading of offsets and group metadata from __consumer_offsets-4 (kafka.coordinator.group.GroupMetadataManager)
[2019-10-10 07:48:12,642] INFO [GroupMetadataManager brokerId=4] Finished loading offsets and group metadata from __consumer_offsets-9 in 12 milliseconds. (kafka.coordinator.group.GroupMetadataManager)
[2019-10-10 07:48:12,654] INFO [ReplicaFetcherManager on broker 4] Removed fetcher for partitions Set(__consumer_offsets-8, data-transfer-change-evt-2, ie-lrx-audit-evt-0, prod-fi-hdfs-landing-evt-3, dca-audit-evt-4, ukpai-hdfs-evt-3, __consumer_offsets-33, intg-ie-lrx-rxer-audit-evt-4, ukwhs-error-topic-3, panel-data-change-evt-1, __consumer_offsets-28, send-email-evt-3, mft-file-arrival-evt-2, __consumer_offsets-48, mft-pflow-evt-3, __consumer_offsets-13, mft-hdfs-landing-evt-3, email-service-audit-3, ukwhs-hdfs-landing-evt-01-4) (kafka.server.ReplicaFetcherManager)
[2019-10-10 07:48:12,654] INFO [Partition send-email-evt-3 broker=4] send-email-evt-3 starts at Leader Epoch 42 from offset 0. Previous Leader Epoch was: 41 (kafka.cluster.Partition)
[2019-10-10 07:48:12,654] WARN [LeaderEpochCache send-email-evt-3] New epoch entry EpochEntry(epoch=42, startOffset=0) caused truncation of conflicting entries ListBuffer(EpochEntry(epoch=41, startOffset=0)). Cache now contains 1 entries. (kafka.server.epoch.LeaderEpochFileCache)
[2019-10-10 07:48:12,664] INFO [GroupMetadataManager brokerId=4] Finished loading offsets and group metadata from __consumer_offsets-49 in 21 milliseconds. (kafka.coordinator.group.GroupMetadataManager)
[2019-10-10 07:48:12,673] INFO [Log partition=__consumer_offsets-44, dir=/var/lib/mesos/slave/slaves/e67d2813-79ab-4885-8bd0-3ca45a8960bc-S7/frameworks/ef477552-90f0-4a11-979d-70a7659eecae-0000/executors/prod.xg.dcp.kafka01__kafka__c0e289ae-9a26-4585-bb4d-dd3a28a346fd/runs/3797d666-632e-44ce-9b8f-09e2c226a11f/containers/714ff76b-a31b-4c23-8ce4-664c685715d8/kafka-broker-data/broker-4] Truncating to 6 has no effect as the largest offset in the log is 5 (kafka.log.Log)
[2019-10-10 07:48:12,673] WARN [ReplicaFetcher replicaId=4, leaderId=3, fetcherId=0] Based on replica's leader epoch, leader replied with an unknown offset in fi-error-records-1. The initial fetch offset 0 will be used for truncation. (kafka.server.ReplicaFetcherThread)
[2019-10-10 07:48:12,673] INFO [Partition intg-ie-lrx-rxer-audit-evt-4 broker=4] intg-ie-lrx-rxer-audit-evt-4 starts at Leader Epoch 24 from offset 0. Previous Leader Epoch was: 23 (kafka.cluster.Partition)
[2019-10-10 07:48:12,673] INFO [Log partition=fi-error-records-1, dir=/var/lib/mesos/slave/slaves/e67d2813-79ab-4885-8bd0-3ca45a8960bc-S7/frameworks/ef477552-90f0-4a11-979d-70a7659eecae-0000/executors/prod.xg.dcp.kafka01__kafka__c0e289ae-9a26-4585-bb4d-dd3a28a346fd/runs/3797d666-632e-44ce-9b8f-09e2c226a11f/containers/714ff76b-a31b-4c23-8ce4-664c685715d8/kafka-broker-data/broker-4] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.Log)
[2019-10-10 07:48:12,673] INFO [Log partition=__consumer_offsets-24, dir=/var/lib/mesos/slave/slaves/e67d2813-79ab-4885-8bd0-3ca45a8960bc-S7/frameworks/ef477552-90f0-4a11-979d-70a7659eecae-0000/executors/prod.xg.dcp.kafka01__kafka__c0e289ae-9a26-4585-bb4d-dd3a28a346fd/runs/3797d666-632e-44ce-9b8f-09e2c226a11f/containers/714ff76b-a31b-4c23-8ce4-664c685715d8/kafka-broker-data/broker-4] Truncating to 6 has no effect as the largest offset in the log is 5 (kafka.log.Log)
[2019-10-10 07:48:12,673] WARN [LeaderEpochCache intg-ie-lrx-rxer-audit-evt-4] New epoch entry EpochEntry(epoch=24, startOffset=0) caused truncation of conflicting entries ListBuffer(EpochEntry(epoch=23, startOffset=0)). Cache now contains 1 entries. (kafka.server.epoch.LeaderEpochFileCache)
[2019-10-10 07:48:12,673] WARN [ReplicaFetcher replicaId=4, leaderId=3, fetcherId=0] Based on replica's leader epoch, leader replied with an unknown offset in email-srvc-audit-evt-3. The initial fetch offset 0 will be used for truncation. (kafka.server.ReplicaFetcherThread)
[2019-10-10 07:48:12,673] INFO [Log partition=email-srvc-audit-evt-3, dir=/var/lib/mesos/slave/slaves/e67d2813-79ab-4885-8bd0-3ca45a8960bc-S7/frameworks/ef477552-90f0-4a11-979d-70a7659eecae-0000/executors/prod.xg.dcp.kafka01__kafka__c0e289ae-9a26-4585-bb4d-dd3a28a346fd/runs/3797d666-632e-44ce-9b8f-09e2c226a11f/containers/714ff76b-a31b-4c23-8ce4-664c685715d8/kafka-broker-data/broker-4] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.Log)
[2019-10-10 07:48:12,673] INFO [Log partition=__consumer_offsets-4, dir=/var/lib/mesos/slave/slaves/e67d2813-79ab-4885-8bd0-3ca45a8960bc-S7/frameworks/ef477552-90f0-4a11-979d-70a7659eecae-0000/executors/prod.xg.dcp.kafka01__kafka__c0e289ae-9a26-4585-bb4d-dd3a28a346fd/runs/3797d666-632e-44ce-9b8f-09e2c226a11f/containers/714ff76b-a31b-4c23-8ce4-664c685715d8/kafka-broker-data/broker-4] Truncating to 6 has no effect as the largest offset in the log is 5 (kafka.log.Log)
[2019-10-10 07:48:12,692] INFO [Partition __consumer_offsets-48 broker=4] __consumer_offsets-48 starts at Leader Epoch 42 from offset 12. Previous Leader Epoch was: 41 (kafka.cluster.Partition)
[2019-10-10 07:48:12,693] WARN [LeaderEpochCache __consumer_offsets-48] New epoch entry EpochEntry(epoch=42, startOffset=12) caused truncation of conflicting entries ListBuffer(EpochEntry(epoch=41, startOffset=12)). Cache now contains 5 entries. (kafka.server.epoch.LeaderEpochFileCache)
[2019-10-10 07:48:12,703] INFO [Partition mft-file-arrival-evt-2 broker=4] mft-file-arrival-evt-2 starts at Leader Epoch 42 from offset 0. Previous Leader Epoch was: 41 (kafka.cluster.Partition)
[2019-10-10 07:48:12,703] WARN [LeaderEpochCache mft-file-arrival-evt-2] New epoch entry EpochEntry(epoch=42, startOffset=0) caused truncation of conflicting entries ListBuffer(EpochEntry(epoch=41, startOffset=0)). Cache now contains 1 entries. (kafka.server.epoch.LeaderEpochFileCache)
[2019-10-10 07:48:12,704] INFO [GroupMetadataManager brokerId=4] Finished loading offsets and group metadata from __consumer_offsets-29 in 31 milliseconds. (kafka.coordinator.group.GroupMetadataManager)
[2019-10-10 07:48:12,724] INFO [GroupMetadataManager brokerId=4] Finished unloading __consumer_offsets-44. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
[2019-10-10 07:48:12,736] INFO [GroupMetadataManager brokerId=4] Finished unloading __consumer_offsets-24. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
[2019-10-10 07:48:12,740] INFO [GroupMetadataManager brokerId=4] Finished unloading __consumer_offsets-4. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
[2019-10-10 07:48:12,740] INFO [Partition ie-lrx-audit-evt-0 broker=4] ie-lrx-audit-evt-0 starts at Leader Epoch 42 from offset 749. Previous Leader Epoch was: 41 (kafka.cluster.Partition)
[2019-10-10 07:48:12,751] INFO [Partition ukwhs-hdfs-landing-evt-01-4 broker=4] ukwhs-hdfs-landing-evt-01-4 starts at Leader Epoch 42 from offset 0. Previous Leader Epoch was: 41 (kafka.cluster.Partition)
[2019-10-10 07:48:12,751] WARN [LeaderEpochCache ukwhs-hdfs-landing-evt-01-4] New epoch entry EpochEntry(epoch=42, startOffset=0) caused truncation of conflicting entries ListBuffer(EpochEntry(epoch=41, startOffset=0)). Cache now contains 1 entries. (kafka.server.epoch.LeaderEpochFileCache)
[2019-10-10 07:48:12,764] INFO [Partition dca-audit-evt-4 broker=4] dca-audit-evt-4 starts at Leader Epoch 42 from offset 0. Previous Leader Epoch was: 41 (kafka.cluster.Partition)
[2019-10-10 07:48:12,764] WARN [LeaderEpochCache dca-audit-evt-4] New epoch entry EpochEntry(epoch=42, startOffset=0) caused truncation of conflicting entries ListBuffer(EpochEntry(epoch=41, startOffset=0)). Cache now contains 1 entries. (kafka.server.epoch.LeaderEpochFileCache)
[2019-10-10 07:48:12,781] INFO [Partition prod-fi-hdfs-landing-evt-3 broker=4] prod-fi-hdfs-landing-evt-3 starts at Leader Epoch 8 from offset 0. Previous Leader Epoch was: 7 (kafka.cluster.Partition)
[2019-10-10 07:48:12,781] WARN [LeaderEpochCache prod-fi-hdfs-landing-evt-3] New epoch entry EpochEntry(epoch=8, startOffset=0) caused truncation of conflicting entries ListBuffer(EpochEntry(epoch=7, startOffset=0)). Cache now contains 1 entries. (kafka.server.epoch.LeaderEpochFileCache)
[2019-10-10 07:48:12,791] INFO [Partition __consumer_offsets-33 broker=4] __consumer_offsets-33 starts at Leader Epoch 42 from offset 6. Previous Leader Epoch was: 41 (kafka.cluster.Partition)
[2019-10-10 07:48:12,791] WARN [LeaderEpochCache __consumer_offsets-33] New epoch entry EpochEntry(epoch=42, startOffset=6) caused truncation of conflicting entries ListBuffer(EpochEntry(epoch=41, startOffset=6)). Cache now contains 3 entries. (kafka.server.epoch.LeaderEpochFileCache)
[2019-10-10 07:48:12,803] INFO [Partition panel-data-change-evt-1 broker=4] panel-data-change-evt-1 starts at Leader Epoch 42 from offset 0. Previous Leader Epoch was: 41 (kafka.cluster.Partition)
[2019-10-10 07:48:12,803] WARN [LeaderEpochCache panel-data-change-evt-1] New epoch entry EpochEntry(epoch=42, startOffset=0) caused truncation of conflicting entries ListBuffer(EpochEntry(epoch=41, startOffset=0)). Cache now contains 1 entries. (kafka.server.epoch.LeaderEpochFileCache)
[2019-10-10 07:48:12,812] INFO [Partition __consumer_offsets-8 broker=4] __consumer_offsets-8 starts at Leader Epoch 42 from offset 17. Previous Leader Epoch was: 41 (kafka.cluster.Partition)
[2019-10-10 07:48:12,813] WARN [LeaderEpochCache __consumer_offsets-8] New epoch entry EpochEntry(epoch=42, startOffset=17) caused truncation of conflicting entries ListBuffer(EpochEntry(epoch=41, startOffset=17)). Cache now contains 3 entries. (kafka.server.epoch.LeaderEpochFileCache)
[2019-10-10 07:48:12,823] INFO [Partition email-service-audit-3 broker=4] email-service-audit-3 starts at Leader Epoch 42 from offset 0. Previous Leader Epoch was: 41 (kafka.cluster.Partition)
[2019-10-10 07:48:12,824] WARN [LeaderEpochCache email-service-audit-3] New epoch entry EpochEntry(epoch=42, startOffset=0) caused truncation of conflicting entries ListBuffer(EpochEntry(epoch=41, startOffset=0)). Cache now contains 1 entries. (kafka.server.epoch.LeaderEpochFileCache)
[2019-10-10 07:48:12,852] INFO [Partition ukwhs-error-topic-3 broker=4] ukwhs-error-topic-3 starts at Leader Epoch 42 from offset 9. Previous Leader Epoch was: 41 (kafka.cluster.Partition)
[2019-10-10 07:48:12,852] WARN [LeaderEpochCache ukwhs-error-topic-3] New epoch entry EpochEntry(epoch=42, startOffset=9) caused truncation of conflicting entries ListBuffer(EpochEntry(epoch=41, startOffset=9)). Cache now contains 1 entries. (kafka.server.epoch.LeaderEpochFileCache)
[2019-10-10 07:48:12,863] INFO [Partition data-transfer-change-evt-2 broker=4] data-transfer-change-evt-2 starts at Leader Epoch 42 from offset 0. Previous Leader Epoch was: 41 (kafka.cluster.Partition)
[2019-10-10 07:48:12,863] WARN [LeaderEpochCache data-transfer-change-evt-2] New epoch entry EpochEntry(epoch=42, startOffset=0) caused truncation of conflicting entries ListBuffer(EpochEntry(epoch=41, startOffset=0)). Cache now contains 1 entries. (kafka.server.epoch.LeaderEpochFileCache)
[2019-10-10 07:48:12,874] INFO [Partition mft-pflow-evt-3 broker=4] mft-pflow-evt-3 starts at Leader Epoch 42 from offset 0. Previous Leader Epoch was: 41 (kafka.cluster.Partition)
[2019-10-10 07:48:12,874] WARN [LeaderEpochCache mft-pflow-evt-3] New epoch entry EpochEntry(epoch=42, startOffset=0) caused truncation of conflicting entries ListBuffer(EpochEntry(epoch=41, startOffset=0)). Cache now contains 1 entries. (kafka.server.epoch.LeaderEpochFileCache)
[2019-10-10 07:48:12,894] INFO [Partition ukpai-hdfs-evt-3 broker=4] ukpai-hdfs-evt-3 starts at Leader Epoch 42 from offset 0. Previous Leader Epoch was: 41 (kafka.cluster.Partition)
[2019-10-10 07:48:12,901] WARN [LeaderEpochCache ukpai-hdfs-evt-3] New epoch entry EpochEntry(epoch=42, startOffset=0) caused truncation of conflicting entries ListBuffer(EpochEntry(epoch=41, startOffset=0)). Cache now contains 1 entries. (kafka.server.epoch.LeaderEpochFileCache)
[2019-10-10 07:48:12,940] INFO [Partition __consumer_offsets-28 broker=4] __consumer_offsets-28 starts at Leader Epoch 42 from offset 18. Previous Leader Epoch was: 41 (kafka.cluster.Partition)
[2019-10-10 07:48:12,940] WARN [LeaderEpochCache __consumer_offsets-28] New epoch entry EpochEntry(epoch=42, startOffset=18) caused truncation of conflicting entries ListBuffer(EpochEntry(epoch=41, startOffset=18)). Cache now contains 5 entries. (kafka.server.epoch.LeaderEpochFileCache)
[2019-10-10 07:48:12,951] INFO [Partition __consumer_offsets-13 broker=4] __consumer_offsets-13 starts at Leader Epoch 42 from offset 15. Previous Leader Epoch was: 41 (kafka.cluster.Partition)
[2019-10-10 07:48:12,951] WARN [LeaderEpochCache __consumer_offsets-13] New epoch entry EpochEntry(epoch=42, startOffset=15) caused truncation of conflicting entries ListBuffer(EpochEntry(epoch=41, startOffset=15)). Cache now contains 5 entries. (kafka.server.epoch.LeaderEpochFileCache)
[2019-10-10 07:48:12,973] INFO [Partition mft-hdfs-landing-evt-3 broker=4] mft-hdfs-landing-evt-3 starts at Leader Epoch 42 from offset 0. Previous Leader Epoch was: 41 (kafka.cluster.Partition)
[2019-10-10 07:48:12,978] WARN [LeaderEpochCache mft-hdfs-landing-evt-3] New epoch entry EpochEntry(epoch=42, startOffset=0) caused truncation of conflicting entries ListBuffer(EpochEntry(epoch=41, startOffset=0)). Cache now contains 1 entries. (kafka.server.epoch.LeaderEpochFileCache)
[2019-10-10 07:48:13,012] INFO [ReplicaFetcherManager on broker 4] Removed fetcher for partitions Set(ukwhs-hdfs-landing-evt-01-3, ie-lrx-rxer-audit-evt-0, __consumer_offsets-32, ukpai-hdfs-evt-2, panel-data-change-evt-0, fi-error-records-2, mft-pflow-evt-2, dca-audit-evt-3, it-sou-audit-evt-7, prod-pipelines-errors-evt-0, __consumer_offsets-36, gdcp-notification-evt-2, __consumer_offsets-40, mft-hdfs-landing-evt-2, dca-heartbeat-evt-2, __consumer_offsets-0, data-transfer-change-evt-1, intg-ie-lrx-rxer-audit-evt-3, intg-ie-lrx-audit-evt-4, __consumer_offsets-16, ukwhs-error-topic-2, __consumer_offsets-12, __consumer_offsets-20, it-sou-audit-evt-2, ie-lrx-pat-audit-evt-4, email-srvc-audit-evt-4) (kafka.server.ReplicaFetcherManager)
[2019-10-10 07:48:13,013] INFO [ReplicaFetcherManager on broker 4] Added fetcher to broker BrokerEndPoint(id=1, host=10.75.148.5:9610) for partitions Map(email-srvc-audit-evt-4 -> (offset=0, leaderEpoch=32), fi-error-records-2 -> (offset=0, leaderEpoch=5), __consumer_offsets-20 -> (offset=6, leaderEpoch=36), __consumer_offsets-0 -> (offset=9, leaderEpoch=36), __consumer_offsets-40 -> (offset=6, leaderEpoch=36)) (kafka.server.ReplicaFetcherManager)
[2019-10-10 07:48:13,013] INFO [ReplicaFetcherManager on broker 4] Added fetcher to broker BrokerEndPoint(id=3, host=10.75.148.7:9610) for partitions Map(ukwhs-hdfs-landing-evt-01-3 -> (offset=0, leaderEpoch=29), intg-ie-lrx-rxer-audit-evt-3 -> (offset=0, leaderEpoch=17), mft-hdfs-landing-evt-2 -> (offset=0, leaderEpoch=31), dca-audit-evt-3 -> (offset=0, leaderEpoch=31), panel-data-change-evt-0 -> (offset=0, leaderEpoch=31), ukpai-hdfs-evt-2 -> (offset=2, leaderEpoch=32), ukwhs-error-topic-2 -> (offset=8, leaderEpoch=32), mft-pflow-evt-2 -> (offset=0, leaderEpoch=32), __consumer_offsets-12 -> (offset=15, leaderEpoch=32), data-transfer-change-evt-1 -> (offset=0, leaderEpoch=32), __consumer_offsets-32 -> (offset=9, leaderEpoch=32)) (kafka.server.ReplicaFetcherManager)
[2019-10-10 07:48:13,013] INFO [ReplicaFetcherManager on broker 4] Added fetcher to broker BrokerEndPoint(id=2, host=10.75.148.4:9610) for partitions Map(it-sou-audit-evt-7 -> (offset=94819, leaderEpoch=101), prod-pipelines-errors-evt-0 -> (offset=0, leaderEpoch=118), ie-lrx-rxer-audit-evt-0 -> (offset=0, leaderEpoch=105), intg-ie-lrx-audit-evt-4 -> (offset=21, leaderEpoch=75), ie-lrx-pat-audit-evt-4 -> (offset=0, leaderEpoch=105), __consumer_offsets-16 -> (offset=11329814, leaderEpoch=105), __consumer_offsets-36 -> (offset=3, leaderEpoch=105), gdcp-notification-evt-2 -> (offset=0, leaderEpoch=105), it-sou-audit-evt-2 -> (offset=490084, leaderEpoch=106), dca-heartbeat-evt-2 -> (offset=0, leaderEpoch=106)) (kafka.server.ReplicaFetcherManager)
[2019-10-10 07:48:13,019] INFO [GroupMetadataManager brokerId=4] Scheduling unloading of offsets and group metadata from __consumer_offsets-40 (kafka.coordinator.group.GroupMetadataManager)
[2019-10-10 07:48:13,020] INFO [GroupMetadataManager brokerId=4] Scheduling unloading of offsets and group metadata from __consumer_offsets-20 (kafka.coordinator.group.GroupMetadataManager)
[2019-10-10 07:48:13,021] INFO [GroupMetadataManager brokerId=4] Scheduling unloading of offsets and group metadata from __consumer_offsets-32 (kafka.coordinator.group.GroupMetadataManager)
[2019-10-10 07:48:13,021] INFO [GroupMetadataManager brokerId=4] Scheduling unloading of offsets and group metadata from __consumer_offsets-0 (kafka.coordinator.group.GroupMetadataManager)
[2019-10-10 07:48:13,021] INFO [GroupMetadataManager brokerId=4] Scheduling unloading of offsets and group metadata from __consumer_offsets-12 (kafka.coordinator.group.GroupMetadataManager)
[2019-10-10 07:48:13,023] INFO [GroupMetadataManager brokerId=4] Scheduling unloading of offsets and group metadata from __consumer_offsets-36 (kafka.coordinator.group.GroupMetadataManager)
[2019-10-10 07:48:13,026] INFO [GroupMetadataManager brokerId=4] Scheduling unloading of offsets and group metadata from __consumer_offsets-16 (kafka.coordinator.group.GroupMetadataManager)
[2019-10-10 07:48:13,041] INFO [GroupMetadataManager brokerId=4] Finished unloading __consumer_offsets-40. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
[2019-10-10 07:48:13,043] INFO [GroupMetadataManager brokerId=4] Finished unloading __consumer_offsets-20. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
[2019-10-10 07:48:13,043] INFO [GroupMetadataManager brokerId=4] Finished unloading __consumer_offsets-32. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
[2019-10-10 07:48:13,043] INFO [GroupMetadataManager brokerId=4] Finished unloading __consumer_offsets-0. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
[2019-10-10 07:48:13,043] INFO [GroupMetadataManager brokerId=4] Finished unloading __consumer_offsets-12. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
[2019-10-10 07:48:13,043] INFO [GroupMetadataManager brokerId=4] Finished unloading __consumer_offsets-36. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
[2019-10-10 07:48:13,043] INFO [GroupMetadataManager brokerId=4] Finished unloading __consumer_offsets-16. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
[2019-10-10 07:48:13,199] WARN [ReplicaFetcher replicaId=4, leaderId=3, fetcherId=0] Based on replica's leader epoch, leader replied with an unknown offset in intg-ie-lrx-rxer-audit-evt-3. The initial fetch offset 0 will be used for truncation. (kafka.server.ReplicaFetcherThread)
[2019-10-10 07:48:13,201] INFO [Log partition=intg-ie-lrx-rxer-audit-evt-3, dir=/var/lib/mesos/slave/slaves/e67d2813-79ab-4885-8bd0-3ca45a8960bc-S7/frameworks/ef477552-90f0-4a11-979d-70a7659eecae-0000/executors/prod.xg.dcp.kafka01__kafka__c0e289ae-9a26-4585-bb4d-dd3a28a346fd/runs/3797d666-632e-44ce-9b8f-09e2c226a11f/containers/714ff76b-a31b-4c23-8ce4-664c685715d8/kafka-broker-data/broker-4] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.Log)
[2019-10-10 07:48:13,201] WARN [ReplicaFetcher replicaId=4, leaderId=3, fetcherId=0] Based on replica's leader epoch, leader replied with an unknown offset in mft-pflow-evt-2. The initial fetch offset 0 will be used for truncation. (kafka.server.ReplicaFetcherThread)
[2019-10-10 07:48:13,201] INFO [Log partition=mft-pflow-evt-2, dir=/var/lib/mesos/slave/slaves/e67d2813-79ab-4885-8bd0-3ca45a8960bc-S7/frameworks/ef477552-90f0-4a11-979d-70a7659eecae-0000/executors/prod.xg.dcp.kafka01__kafka__c0e289ae-9a26-4585-bb4d-dd3a28a346fd/runs/3797d666-632e-44ce-9b8f-09e2c226a11f/containers/714ff76b-a31b-4c23-8ce4-664c685715d8/kafka-broker-data/broker-4] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.Log)
[2019-10-10 07:48:13,201] INFO [Log partition=__consumer_offsets-32, dir=/var/lib/mesos/slave/slaves/e67d2813-79ab-4885-8bd0-3ca45a8960bc-S7/frameworks/ef477552-90f0-4a11-979d-70a7659eecae-0000/executors/prod.xg.dcp.kafka01__kafka__c0e289ae-9a26-4585-bb4d-dd3a28a346fd/runs/3797d666-632e-44ce-9b8f-09e2c226a11f/containers/714ff76b-a31b-4c23-8ce4-664c685715d8/kafka-broker-data/broker-4] Truncating to 9 has no effect as the largest offset in the log is 8 (kafka.log.Log)
[2019-10-10 07:48:13,201] WARN [ReplicaFetcher replicaId=4, leaderId=3, fetcherId=0] Based on replica's leader epoch, leader replied with an unknown offset in ukwhs-error-topic-2. The initial fetch offset 8 will be used for truncation. (kafka.server.ReplicaFetcherThread)
[2019-10-10 07:48:13,201] INFO [Log partition=ukwhs-error-topic-2, dir=/var/lib/mesos/slave/slaves/e67d2813-79ab-4885-8bd0-3ca45a8960bc-S7/frameworks/ef477552-90f0-4a11-979d-70a7659eecae-0000/executors/prod.xg.dcp.kafka01__kafka__c0e289ae-9a26-4585-bb4d-dd3a28a346fd/runs/3797d666-632e-44ce-9b8f-09e2c226a11f/containers/714ff76b-a31b-4c23-8ce4-664c685715d8/kafka-broker-data/broker-4] Truncating to 8 has no effect as the largest offset in the log is 7 (kafka.log.Log)
[2019-10-10 07:48:13,201] INFO [Log partition=ukpai-hdfs-evt-2, dir=/var/lib/mesos/slave/slaves/e67d2813-79ab-4885-8bd0-3ca45a8960bc-S7/frameworks/ef477552-90f0-4a11-979d-70a7659eecae-0000/executors/prod.xg.dcp.kafka01__kafka__c0e289ae-9a26-4585-bb4d-dd3a28a346fd/runs/3797d666-632e-44ce-9b8f-09e2c226a11f/containers/714ff76b-a31b-4c23-8ce4-664c685715d8/kafka-broker-data/broker-4] Truncating to 2 has no effect as the largest offset in the log is 1 (kafka.log.Log)
[2019-10-10 07:48:13,201] INFO [Log partition=__consumer_offsets-12, dir=/var/lib/mesos/slave/slaves/e67d2813-79ab-4885-8bd0-3ca45a8960bc-S7/frameworks/ef477552-90f0-4a11-979d-70a7659eecae-0000/executors/prod.xg.dcp.kafka01__kafka__c0e289ae-9a26-4585-bb4d-dd3a28a346fd/runs/3797d666-632e-44ce-9b8f-09e2c226a11f/containers/714ff76b-a31b-4c23-8ce4-664c685715d8/kafka-broker-data/broker-4] Truncating to 15 has no effect as the largest offset in the log is 14 (kafka.log.Log)
[2019-10-10 07:48:13,201] WARN [ReplicaFetcher replicaId=4, leaderId=3, fetcherId=0] Based on replica's leader epoch, leader replied with an unknown offset in ukwhs-hdfs-landing-evt-01-3. The initial fetch offset 0 will be used for truncation. (kafka.server.ReplicaFetcherThread)
[2019-10-10 07:48:13,201] INFO [Log partition=ukwhs-hdfs-landing-evt-01-3, dir=/var/lib/mesos/slave/slaves/e67d2813-79ab-4885-8bd0-3ca45a8960bc-S7/frameworks/ef477552-90f0-4a11-979d-70a7659eecae-0000/executors/prod.xg.dcp.kafka01__kafka__c0e289ae-9a26-4585-bb4d-dd3a28a346fd/runs/3797d666-632e-44ce-9b8f-09e2c226a11f/containers/714ff76b-a31b-4c23-8ce4-664c685715d8/kafka-broker-data/broker-4] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.Log)
[2019-10-10 07:48:13,201] WARN [ReplicaFetcher replicaId=4, leaderId=3, fetcherId=0] Based on replica's leader epoch, leader replied with an unknown offset in mft-hdfs-landing-evt-2. The initial fetch offset 0 will be used for truncation. (kafka.server.ReplicaFetcherThread)
[2019-10-10 07:48:13,201] INFO [Log partition=mft-hdfs-landing-evt-2, dir=/var/lib/mesos/slave/slaves/e67d2813-79ab-4885-8bd0-3ca45a8960bc-S7/frameworks/ef477552-90f0-4a11-979d-70a7659eecae-0000/executors/prod.xg.dcp.kafka01__kafka__c0e289ae-9a26-4585-bb4d-dd3a28a346fd/runs/3797d666-632e-44ce-9b8f-09e2c226a11f/containers/714ff76b-a31b-4c23-8ce4-664c685715d8/kafka-broker-data/broker-4] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.Log)
[2019-10-10 07:48:13,202] WARN [ReplicaFetcher replicaId=4, leaderId=3, fetcherId=0] Based on replica's leader epoch, leader replied with an unknown offset in dca-audit-evt-3. The initial fetch offset 0 will be used for truncation. (kafka.server.ReplicaFetcherThread)
[2019-10-10 07:48:13,202] INFO [Log partition=dca-audit-evt-3, dir=/var/lib/mesos/slave/slaves/e67d2813-79ab-4885-8bd0-3ca45a8960bc-S7/frameworks/ef477552-90f0-4a11-979d-70a7659eecae-0000/executors/prod.xg.dcp.kafka01__kafka__c0e289ae-9a26-4585-bb4d-dd3a28a346fd/runs/3797d666-632e-44ce-9b8f-09e2c226a11f/containers/714ff76b-a31b-4c23-8ce4-664c685715d8/kafka-broker-data/broker-4] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.Log)
[2019-10-10 07:48:13,202] WARN [ReplicaFetcher replicaId=4, leaderId=3, fetcherId=0] Based on replica's leader epoch, leader replied with an unknown offset in panel-data-change-evt-0. The initial fetch offset 0 will be used for truncation. (kafka.server.ReplicaFetcherThread)
[2019-10-10 07:48:13,202] INFO [Log partition=panel-data-change-evt-0, dir=/var/lib/mesos/slave/slaves/e67d2813-79ab-4885-8bd0-3ca45a8960bc-S7/frameworks/ef477552-90f0-4a11-979d-70a7659eecae-0000/executors/prod.xg.dcp.kafka01__kafka__c0e289ae-9a26-4585-bb4d-dd3a28a346fd/runs/3797d666-632e-44ce-9b8f-09e2c226a11f/containers/714ff76b-a31b-4c23-8ce4-664c685715d8/kafka-broker-data/broker-4] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.Log)
[2019-10-10 07:48:13,202] WARN [ReplicaFetcher replicaId=4, leaderId=3, fetcherId=0] Based on replica's leader epoch, leader replied with an unknown offset in data-transfer-change-evt-1. The initial fetch offset 0 will be used for truncation. (kafka.server.ReplicaFetcherThread)
[2019-10-10 07:48:13,202] INFO [Log partition=data-transfer-change-evt-1, dir=/var/lib/mesos/slave/slaves/e67d2813-79ab-4885-8bd0-3ca45a8960bc-S7/frameworks/ef477552-90f0-4a11-979d-70a7659eecae-0000/executors/prod.xg.dcp.kafka01__kafka__c0e289ae-9a26-4585-bb4d-dd3a28a346fd/runs/3797d666-632e-44ce-9b8f-09e2c226a11f/containers/714ff76b-a31b-4c23-8ce4-664c685715d8/kafka-broker-data/broker-4] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.Log)
[2019-10-10 07:48:13,343] INFO [Log partition=__consumer_offsets-0, dir=/var/lib/mesos/slave/slaves/e67d2813-79ab-4885-8bd0-3ca45a8960bc-S7/frameworks/ef477552-90f0-4a11-979d-70a7659eecae-0000/executors/prod.xg.dcp.kafka01__kafka__c0e289ae-9a26-4585-bb4d-dd3a28a346fd/runs/3797d666-632e-44ce-9b8f-09e2c226a11f/containers/714ff76b-a31b-4c23-8ce4-664c685715d8/kafka-broker-data/broker-4] Truncating to 9 has no effect as the largest offset in the log is 8 (kafka.log.Log)
[2019-10-10 07:48:13,343] WARN [ReplicaFetcher replicaId=4, leaderId=1, fetcherId=0] Based on replica's leader epoch, leader replied with an unknown offset in email-srvc-audit-evt-4. The initial fetch offset 0 will be used for truncation. (kafka.server.ReplicaFetcherThread)
[2019-10-10 07:48:13,343] INFO [Log partition=email-srvc-audit-evt-4, dir=/var/lib/mesos/slave/slaves/e67d2813-79ab-4885-8bd0-3ca45a8960bc-S7/frameworks/ef477552-90f0-4a11-979d-70a7659eecae-0000/executors/prod.xg.dcp.kafka01__kafka__c0e289ae-9a26-4585-bb4d-dd3a28a346fd/runs/3797d666-632e-44ce-9b8f-09e2c226a11f/containers/714ff76b-a31b-4c23-8ce4-664c685715d8/kafka-broker-data/broker-4] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.Log)
[2019-10-10 07:48:13,343] INFO [Log partition=__consumer_offsets-40, dir=/var/lib/mesos/slave/slaves/e67d2813-79ab-4885-8bd0-3ca45a8960bc-S7/frameworks/ef477552-90f0-4a11-979d-70a7659eecae-0000/executors/prod.xg.dcp.kafka01__kafka__c0e289ae-9a26-4585-bb4d-dd3a28a346fd/runs/3797d666-632e-44ce-9b8f-09e2c226a11f/containers/714ff76b-a31b-4c23-8ce4-664c685715d8/kafka-broker-data/broker-4] Truncating to 6 has no effect as the largest offset in the log is 5 (kafka.log.Log)
[2019-10-10 07:48:13,343] WARN [ReplicaFetcher replicaId=4, leaderId=1, fetcherId=0] Based on replica's leader epoch, leader replied with an unknown offset in fi-error-records-2. The initial fetch offset 0 will be used for truncation. (kafka.server.ReplicaFetcherThread)
[2019-10-10 07:48:13,343] INFO [Log partition=fi-error-records-2, dir=/var/lib/mesos/slave/slaves/e67d2813-79ab-4885-8bd0-3ca45a8960bc-S7/frameworks/ef477552-90f0-4a11-979d-70a7659eecae-0000/executors/prod.xg.dcp.kafka01__kafka__c0e289ae-9a26-4585-bb4d-dd3a28a346fd/runs/3797d666-632e-44ce-9b8f-09e2c226a11f/containers/714ff76b-a31b-4c23-8ce4-664c685715d8/kafka-broker-data/broker-4] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.Log)
[2019-10-10 07:48:13,343] INFO [Log partition=__consumer_offsets-20, dir=/var/lib/mesos/slave/slaves/e67d2813-79ab-4885-8bd0-3ca45a8960bc-S7/frameworks/ef477552-90f0-4a11-979d-70a7659eecae-0000/executors/prod.xg.dcp.kafka01__kafka__c0e289ae-9a26-4585-bb4d-dd3a28a346fd/runs/3797d666-632e-44ce-9b8f-09e2c226a11f/containers/714ff76b-a31b-4c23-8ce4-664c685715d8/kafka-broker-data/broker-4] Truncating to 6 has no effect as the largest offset in the log is 5 (kafka.log.Log)
[2019-10-10 07:48:16,938] INFO [ReplicaFetcherManager on broker 4] Removed fetcher for partitions Set(email-srvc-audit-evt-4, fi-error-records-2, __consumer_offsets-20, __consumer_offsets-0, __consumer_offsets-40) (kafka.server.ReplicaFetcherManager)
[2019-10-10 07:48:16,938] INFO [Partition __consumer_offsets-0 broker=4] __consumer_offsets-0 starts at Leader Epoch 37 from offset 9. Previous Leader Epoch was: 36 (kafka.cluster.Partition)
[2019-10-10 07:48:16,944] INFO [Partition __consumer_offsets-20 broker=4] __consumer_offsets-20 starts at Leader Epoch 37 from offset 6. Previous Leader Epoch was: 36 (kafka.cluster.Partition)
[2019-10-10 07:48:16,973] INFO [Partition __consumer_offsets-40 broker=4] __consumer_offsets-40 starts at Leader Epoch 37 from offset 6. Previous Leader Epoch was: 36 (kafka.cluster.Partition)
[2019-10-10 07:48:16,992] INFO [Partition fi-error-records-2 broker=4] fi-error-records-2 starts at Leader Epoch 6 from offset 0. Previous Leader Epoch was: 5 (kafka.cluster.Partition)
[2019-10-10 07:48:17,001] INFO [Partition email-srvc-audit-evt-4 broker=4] email-srvc-audit-evt-4 starts at Leader Epoch 33 from offset 0. Previous Leader Epoch was: 32 (kafka.cluster.Partition)
[2019-10-10 07:48:17,040] INFO [ReplicaFetcherManager on broker 4] Removed fetcher for partitions Set(it-sou-audit-evt-6, __consumer_offsets-15, it-sou-audit-evt-1, ie-lrx-rxer-audit-evt-4, dca-heartbeat-evt-1, gdcp-notification-evt-1, ie-lrx-pat-audit-evt-3, intg-ie-lrx-audit-evt-3, __consumer_offsets-35) (kafka.server.ReplicaFetcherManager)
[2019-10-10 07:48:17,041] INFO [ReplicaFetcherManager on broker 4] Added fetcher to broker BrokerEndPoint(id=3, host=10.75.148.7:9610) for partitions Map(ie-lrx-pat-audit-evt-3 -> (offset=0, leaderEpoch=29), __consumer_offsets-35 -> (offset=6, leaderEpoch=33), it-sou-audit-evt-6 -> (offset=100036, leaderEpoch=30), __consumer_offsets-15 -> (offset=3, leaderEpoch=35), dca-heartbeat-evt-1 -> (offset=0, leaderEpoch=35), gdcp-notification-evt-1 -> (offset=0, leaderEpoch=35), ie-lrx-rxer-audit-evt-4 -> (offset=0, leaderEpoch=36), it-sou-audit-evt-1 -> (offset=494818, leaderEpoch=35), intg-ie-lrx-audit-evt-3 -> (offset=21, leaderEpoch=18)) (kafka.server.ReplicaFetcherManager)
[2019-10-10 07:48:17,041] INFO [ReplicaFetcher replicaId=4, leaderId=1, fetcherId=0] Shutting down (kafka.server.ReplicaFetcherThread)
[2019-10-10 07:48:17,044] INFO [ReplicaFetcher replicaId=4, leaderId=1, fetcherId=0] Shutdown completed (kafka.server.ReplicaFetcherThread)
[2019-10-10 07:48:17,044] INFO [ReplicaFetcher replicaId=4, leaderId=1, fetcherId=0] Stopped (kafka.server.ReplicaFetcherThread)
[2019-10-10 07:48:17,053] INFO [GroupMetadataManager brokerId=4] Scheduling loading of offsets and group metadata from __consumer_offsets-40 (kafka.coordinator.group.GroupMetadataManager)
[2019-10-10 07:48:17,053] INFO [GroupMetadataManager brokerId=4] Scheduling loading of offsets and group metadata from __consumer_offsets-20 (kafka.coordinator.group.GroupMetadataManager)
[2019-10-10 07:48:17,053] INFO [GroupMetadataManager brokerId=4] Scheduling loading of offsets and group metadata from __consumer_offsets-0 (kafka.coordinator.group.GroupMetadataManager)
[2019-10-10 07:48:17,053] INFO [GroupMetadataManager brokerId=4] Scheduling unloading of offsets and group metadata from __consumer_offsets-15 (kafka.coordinator.group.GroupMetadataManager)
[2019-10-10 07:48:17,053] INFO [GroupMetadataManager brokerId=4] Scheduling unloading of offsets and group metadata from __consumer_offsets-35 (kafka.coordinator.group.GroupMetadataManager)
[2019-10-10 07:48:17,082] INFO [ReplicaFetcherManager on broker 4] Removed fetcher for partitions Set(it-sou-audit-evt-4, data-transfer-change-evt-2, email-service-audit-4, __consumer_offsets-9, dca-audit-evt-4, ukpai-hdfs-evt-3, intg-ie-lrx-audit-evt-1, __consumer_offsets-33, __consumer_offsets-49, intg-ie-lrx-rxer-audit-evt-4, ukwhs-error-topic-3, panel-data-change-evt-1, send-email-evt-4, __consumer_offsets-18, prod-fi-hdfs-landing-evt-4, __consumer_offsets-38, mft-pflow-evt-3, it-sou-audit-evt-9, __consumer_offsets-13, ie-lrx-pat-audit-evt-1, mft-hdfs-landing-evt-3, ie-lrx-rxer-audit-evt-2, dca-heartbeat-evt-4, mft-file-arrival-evt-3, __consumer_offsets-29, ukwhs-hdfs-landing-evt-01-4, ie-lrx-audit-evt-1, gdcp-notification-evt-4) (kafka.server.ReplicaFetcherManager)
[2019-10-10 07:48:17,083] INFO [Partition intg-ie-lrx-rxer-audit-evt-4 broker=4] intg-ie-lrx-rxer-audit-evt-4 starts at Leader Epoch 25 from offset 0. Previous Leader Epoch was: 24 (kafka.cluster.Partition)
[2019-10-10 07:48:17,083] WARN [LeaderEpochCache intg-ie-lrx-rxer-audit-evt-4] New epoch entry EpochEntry(epoch=25, startOffset=0) caused truncation of conflicting entries ListBuffer(EpochEntry(epoch=24, startOffset=0)). Cache now contains 1 entries. (kafka.server.epoch.LeaderEpochFileCache)
[2019-10-10 07:48:17,083] INFO [GroupMetadataManager brokerId=4] Finished loading offsets and group metadata from __consumer_offsets-40 in 30 milliseconds. (kafka.coordinator.group.GroupMetadataManager)
[2019-10-10 07:48:17,104] INFO [Partition __consumer_offsets-29 broker=4] __consumer_offsets-29 starts at Leader Epoch 41 from offset 6. Previous Leader Epoch was: 40 (kafka.cluster.Partition)
[2019-10-10 07:48:17,104] WARN [LeaderEpochCache __consumer_offsets-29] New epoch entry EpochEntry(epoch=41, startOffset=6) caused truncation of conflicting entries ListBuffer(EpochEntry(epoch=40, startOffset=6)). Cache now contains 3 entries. (kafka.server.epoch.LeaderEpochFileCache)
[2019-10-10 07:48:17,134] INFO [Partition ie-lrx-pat-audit-evt-1 broker=4] ie-lrx-pat-audit-evt-1 starts at Leader Epoch 113 from offset 0. Previous Leader Epoch was: 112 (kafka.cluster.Partition)
[2019-10-10 07:48:17,134] WARN [LeaderEpochCache ie-lrx-pat-audit-evt-1] New epoch entry EpochEntry(epoch=113, startOffset=0) caused truncation of conflicting entries ListBuffer(EpochEntry(epoch=112, startOffset=0)). Cache now contains 1 entries. (kafka.server.epoch.LeaderEpochFileCache)
[2019-10-10 07:48:17,142] INFO [GroupMetadataManager brokerId=4] Finished loading offsets and group metadata from __consumer_offsets-20 in 59 milliseconds. (kafka.coordinator.group.GroupMetadataManager)
[2019-10-10 07:48:17,143] INFO [Partition it-sou-audit-evt-4 broker=4] it-sou-audit-evt-4 starts at Leader Epoch 89 from offset 493531. Previous Leader Epoch was: 88 (kafka.cluster.Partition)
[2019-10-10 07:48:17,143] WARN [LeaderEpochCache it-sou-audit-evt-4] New epoch entry EpochEntry(epoch=89, startOffset=493531) caused truncation of conflicting entries ListBuffer(EpochEntry(epoch=88, startOffset=493531)). Cache now contains 1 entries. (kafka.server.epoch.LeaderEpochFileCache)
[2019-10-10 07:48:17,150] INFO [Partition send-email-evt-4 broker=4] send-email-evt-4 starts at Leader Epoch 40 from offset 0. Previous Leader Epoch was: 39 (kafka.cluster.Partition)
[2019-10-10 07:48:17,150] WARN [LeaderEpochCache send-email-evt-4] New epoch entry EpochEntry(epoch=40, startOffset=0) caused truncation of conflicting entries ListBuffer(EpochEntry(epoch=39, startOffset=0)). Cache now contains 1 entries. (kafka.server.epoch.LeaderEpochFileCache)
[2019-10-10 07:48:17,152] INFO [GroupMetadataManager brokerId=4] Finished loading offsets and group metadata from __consumer_offsets-0 in 10 milliseconds. (kafka.coordinator.group.GroupMetadataManager)
[2019-10-10 07:48:17,152] INFO [GroupMetadataManager brokerId=4] Finished unloading __consumer_offsets-15. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
[2019-10-10 07:48:17,152] INFO [GroupMetadataManager brokerId=4] Finished unloading __consumer_offsets-35. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
[2019-10-10 07:48:17,154] INFO [Partition ukwhs-hdfs-landing-evt-01-4 broker=4] ukwhs-hdfs-landing-evt-01-4 starts at Leader Epoch 43 from offset 0. Previous Leader Epoch was: 42 (kafka.cluster.Partition)
[2019-10-10 07:48:17,154] WARN [LeaderEpochCache ukwhs-hdfs-landing-evt-01-4] New epoch entry EpochEntry(epoch=43, startOffset=0) caused truncation of conflicting entries ListBuffer(EpochEntry(epoch=42, startOffset=0)). Cache now contains 1 entries. (kafka.server.epoch.LeaderEpochFileCache)
[2019-10-10 07:48:17,171] INFO [Partition dca-audit-evt-4 broker=4] dca-audit-evt-4 starts at Leader Epoch 43 from offset 0. Previous Leader Epoch was: 42 (kafka.cluster.Partition)
[2019-10-10 07:48:17,171] WARN [LeaderEpochCache dca-audit-evt-4] New epoch entry EpochEntry(epoch=43, startOffset=0) caused truncation of conflicting entries ListBuffer(EpochEntry(epoch=42, startOffset=0)). Cache now contains 1 entries. (kafka.server.epoch.LeaderEpochFileCache)
[2019-10-10 07:48:17,182] INFO [Partition __consumer_offsets-33 broker=4] __consumer_offsets-33 starts at Leader Epoch 43 from offset 6. Previous Leader Epoch was: 42 (kafka.cluster.Partition)
[2019-10-10 07:48:17,182] WARN [LeaderEpochCache __consumer_offsets-33] New epoch entry EpochEntry(epoch=43, startOffset=6) caused truncation of conflicting entries ListBuffer(EpochEntry(epoch=42, startOffset=6)). Cache now contains 3 entries. (kafka.server.epoch.LeaderEpochFileCache)
[2019-10-10 07:48:17,190] INFO [Partition __consumer_offsets-49 broker=4] __consumer_offsets-49 starts at Leader Epoch 40 from offset 15. Previous Leader Epoch was: 39 (kafka.cluster.Partition)
[2019-10-10 07:48:17,190] WARN [LeaderEpochCache __consumer_offsets-49] New epoch entry EpochEntry(epoch=40, startOffset=15) caused truncation of conflicting entries ListBuffer(EpochEntry(epoch=39, startOffset=15)). Cache now contains 4 entries. (kafka.server.epoch.LeaderEpochFileCache)
[2019-10-10 07:48:17,194] INFO [Partition panel-data-change-evt-1 broker=4] panel-data-change-evt-1 starts at Leader Epoch 43 from offset 0. Previous Leader Epoch was: 42 (kafka.cluster.Partition)
[2019-10-10 07:48:17,194] WARN [LeaderEpochCache panel-data-change-evt-1] New epoch entry EpochEntry(epoch=43, startOffset=0) caused truncation of conflicting entries ListBuffer(EpochEntry(epoch=42, startOffset=0)). Cache now contains 1 entries. (kafka.server.epoch.LeaderEpochFileCache)
[2019-10-10 07:48:17,212] INFO [Partition mft-file-arrival-evt-3 broker=4] mft-file-arrival-evt-3 starts at Leader Epoch 41 from offset 0. Previous Leader Epoch was: 40 (kafka.cluster.Partition)
[2019-10-10 07:48:17,212] WARN [LeaderEpochCache mft-file-arrival-evt-3] New epoch entry EpochEntry(epoch=41, startOffset=0) caused truncation of conflicting entries ListBuffer(EpochEntry(epoch=40, startOffset=0)). Cache now contains 1 entries. (kafka.server.epoch.LeaderEpochFileCache)
[2019-10-10 07:48:17,220] INFO [Partition ie-lrx-rxer-audit-evt-2 broker=4] ie-lrx-rxer-audit-evt-2 starts at Leader Epoch 112 from offset 0. Previous Leader Epoch was: 111 (kafka.cluster.Partition)
[2019-10-10 07:48:17,221] WARN [LeaderEpochCache ie-lrx-rxer-audit-evt-2] New epoch entry EpochEntry(epoch=112, startOffset=0) caused truncation of conflicting entries ListBuffer(EpochEntry(epoch=111, startOffset=0)). Cache now contains 1 entries. (kafka.server.epoch.LeaderEpochFileCache)
[2019-10-10 07:48:17,233] INFO [Partition ie-lrx-audit-evt-1 broker=4] ie-lrx-audit-evt-1 starts at Leader Epoch 41 from offset 728. Previous Leader Epoch was: 40 (kafka.cluster.Partition)
[2019-10-10 07:48:17,233] WARN [LeaderEpochCache ie-lrx-audit-evt-1] New epoch entry EpochEntry(epoch=41, startOffset=728) caused truncation of conflicting entries ListBuffer(EpochEntry(epoch=40, startOffset=728)). Cache now contains 4 entries. (kafka.server.epoch.LeaderEpochFileCache)
[2019-10-10 07:48:17,249] INFO [Partition gdcp-notification-evt-4 broker=4] gdcp-notification-evt-4 starts at Leader Epoch 113 from offset 0. Previous Leader Epoch was: 112 (kafka.cluster.Partition)
[2019-10-10 07:48:17,249] WARN [LeaderEpochCache gdcp-notification-evt-4] New epoch entry EpochEntry(epoch=113, startOffset=0) caused truncation of conflicting entries ListBuffer(EpochEntry(epoch=112, startOffset=0)). Cache now contains 1 entries. (kafka.server.epoch.LeaderEpochFileCache)
[2019-10-10 07:48:17,253] INFO [Partition __consumer_offsets-18 broker=4] __consumer_offsets-18 starts at Leader Epoch 106 from offset 15. Previous Leader Epoch was: 105 (kafka.cluster.Partition)
[2019-10-10 07:48:17,253] WARN [LeaderEpochCache __consumer_offsets-18] New epoch entry EpochEntry(epoch=106, startOffset=15) caused truncation of conflicting entries ListBuffer(EpochEntry(epoch=105, startOffset=15)). Cache now contains 5 entries. (kafka.server.epoch.LeaderEpochFileCache)
[2019-10-10 07:48:17,263] INFO [Log partition=__consumer_offsets-15, dir=/var/lib/mesos/slave/slaves/e67d2813-79ab-4885-8bd0-3ca45a8960bc-S7/frameworks/ef477552-90f0-4a11-979d-70a7659eecae-0000/executors/prod.xg.dcp.kafka01__kafka__c0e289ae-9a26-4585-bb4d-dd3a28a346fd/runs/3797d666-632e-44ce-9b8f-09e2c226a11f/containers/714ff76b-a31b-4c23-8ce4-664c685715d8/kafka-broker-data/broker-4] Truncating to 3 has no effect as the largest offset in the log is 2 (kafka.log.Log)
[2019-10-10 07:48:17,263] WARN [ReplicaFetcher replicaId=4, leaderId=3, fetcherId=0] Based on replica's leader epoch, leader replied with an unknown offset in it-sou-audit-evt-1. The initial fetch offset 494818 will be used for truncation. (kafka.server.ReplicaFetcherThread)
[2019-10-10 07:48:17,263] INFO [Log partition=it-sou-audit-evt-1, dir=/var/lib/mesos/slave/slaves/e67d2813-79ab-4885-8bd0-3ca45a8960bc-S7/frameworks/ef477552-90f0-4a11-979d-70a7659eecae-0000/executors/prod.xg.dcp.kafka01__kafka__c0e289ae-9a26-4585-bb4d-dd3a28a346fd/runs/3797d666-632e-44ce-9b8f-09e2c226a11f/containers/714ff76b-a31b-4c23-8ce4-664c685715d8/kafka-broker-data/broker-4] Truncating to 494818 has no effect as the largest offset in the log is 494817 (kafka.log.Log)
[2019-10-10 07:48:17,263] WARN [ReplicaFetcher replicaId=4, leaderId=3, fetcherId=0] Based on replica's leader epoch, leader replied with an unknown offset in ie-lrx-pat-audit-evt-3. The initial fetch offset 0 will be used for truncation. (kafka.server.ReplicaFetcherThread)
[2019-10-10 07:48:17,264] INFO [Log partition=ie-lrx-pat-audit-evt-3, dir=/var/lib/mesos/slave/slaves/e67d2813-79ab-4885-8bd0-3ca45a8960bc-S7/frameworks/ef477552-90f0-4a11-979d-70a7659eecae-0000/executors/prod.xg.dcp.kafka01__kafka__c0e289ae-9a26-4585-bb4d-dd3a28a346fd/runs/3797d666-632e-44ce-9b8f-09e2c226a11f/containers/714ff76b-a31b-4c23-8ce4-664c685715d8/kafka-broker-data/broker-4] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.Log)
[2019-10-10 07:48:17,264] WARN [ReplicaFetcher replicaId=4, leaderId=3, fetcherId=0] Based on replica's leader epoch, leader replied with an unknown offset in gdcp-notification-evt-1. The initial fetch offset 0 will be used for truncation. (kafka.server.ReplicaFetcherThread)
[2019-10-10 07:48:17,264] INFO [Log partition=gdcp-notification-evt-1, dir=/var/lib/mesos/slave/slaves/e67d2813-79ab-4885-8bd0-3ca45a8960bc-S7/frameworks/ef477552-90f0-4a11-979d-70a7659eecae-0000/executors/prod.xg.dcp.kafka01__kafka__c0e289ae-9a26-4585-bb4d-dd3a28a346fd/runs/3797d666-632e-44ce-9b8f-09e2c226a11f/containers/714ff76b-a31b-4c23-8ce4-664c685715d8/kafka-broker-data/broker-4] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.Log)
[2019-10-10 07:48:17,264] INFO [Log partition=__consumer_offsets-35, dir=/var/lib/mesos/slave/slaves/e67d2813-79ab-4885-8bd0-3ca45a8960bc-S7/frameworks/ef477552-90f0-4a11-979d-70a7659eecae-0000/executors/prod.xg.dcp.kafka01__kafka__c0e289ae-9a26-4585-bb4d-dd3a28a346fd/runs/3797d666-632e-44ce-9b8f-09e2c226a11f/containers/714ff76b-a31b-4c23-8ce4-664c685715d8/kafka-broker-data/broker-4] Truncating to 6 has no effect as the largest offset in the log is 5 (kafka.log.Log)
[2019-10-10 07:48:17,264] WARN [ReplicaFetcher replicaId=4, leaderId=3, fetcherId=0] Based on replica's leader epoch, leader replied with an unknown offset in it-sou-audit-evt-6. The initial fetch offset 100036 will be used for truncation. (kafka.server.ReplicaFetcherThread)
[2019-10-10 07:48:17,264] INFO [Log partition=it-sou-audit-evt-6, dir=/var/lib/mesos/slave/slaves/e67d2813-79ab-4885-8bd0-3ca45a8960bc-S7/frameworks/ef477552-90f0-4a11-979d-70a7659eecae-0000/executors/prod.xg.dcp.kafka01__kafka__c0e289ae-9a26-4585-bb4d-dd3a28a346fd/runs/3797d666-632e-44ce-9b8f-09e2c226a11f/containers/714ff76b-a31b-4c23-8ce4-664c685715d8/kafka-broker-data/broker-4] Truncating to 100036 has no effect as the largest offset in the log is 100035 (kafka.log.Log)
[2019-10-10 07:48:17,264] WARN [ReplicaFetcher replicaId=4, leaderId=3, fetcherId=0] Based on replica's leader epoch, leader replied with an unknown offset in ie-lrx-rxer-audit-evt-4. The initial fetch offset 0 will be used for truncation. (kafka.server.ReplicaFetcherThread)
[2019-10-10 07:48:17,264] INFO [Log partition=ie-lrx-rxer-audit-evt-4, dir=/var/lib/mesos/slave/slaves/e67d2813-79ab-4885-8bd0-3ca45a8960bc-S7/frameworks/ef477552-90f0-4a11-979d-70a7659eecae-0000/executors/prod.xg.dcp.kafka01__kafka__c0e289ae-9a26-4585-bb4d-dd3a28a346fd/runs/3797d666-632e-44ce-9b8f-09e2c226a11f/containers/714ff76b-a31b-4c23-8ce4-664c685715d8/kafka-broker-data/broker-4] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.Log)
[2019-10-10 07:48:17,264] WARN [ReplicaFetcher replicaId=4, leaderId=3, fetcherId=0] Based on replica's leader epoch, leader replied with an unknown offset in intg-ie-lrx-audit-evt-3. The initial fetch offset 21 will be used for truncation. (kafka.server.ReplicaFetcherThread)
[2019-10-10 07:48:17,264] INFO [Log partition=intg-ie-lrx-audit-evt-3, dir=/var/lib/mesos/slave/slaves/e67d2813-79ab-4885-8bd0-3ca45a8960bc-S7/frameworks/ef477552-90f0-4a11-979d-70a7659eecae-0000/executors/prod.xg.dcp.kafka01__kafka__c0e289ae-9a26-4585-bb4d-dd3a28a346fd/runs/3797d666-632e-44ce-9b8f-09e2c226a11f/containers/714ff76b-a31b-4c23-8ce4-664c685715d8/kafka-broker-data/broker-4] Truncating to 21 has no effect as the largest offset in the log is 20 (kafka.log.Log)
[2019-10-10 07:48:17,264] WARN [ReplicaFetcher replicaId=4, leaderId=3, fetcherId=0] Based on replica's leader epoch, leader replied with an unknown offset in dca-heartbeat-evt-1. The initial fetch offset 0 will be used for truncation. (kafka.server.ReplicaFetcherThread)
[2019-10-10 07:48:17,264] INFO [Log partition=dca-heartbeat-evt-1, dir=/var/lib/mesos/slave/slaves/e67d2813-79ab-4885-8bd0-3ca45a8960bc-S7/frameworks/ef477552-90f0-4a11-979d-70a7659eecae-0000/executors/prod.xg.dcp.kafka01__kafka__c0e289ae-9a26-4585-bb4d-dd3a28a346fd/runs/3797d666-632e-44ce-9b8f-09e2c226a11f/containers/714ff76b-a31b-4c23-8ce4-664c685715d8/kafka-broker-data/broker-4] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.Log)
[2019-10-10 07:48:17,272] INFO [Partition ukwhs-error-topic-3 broker=4] ukwhs-error-topic-3 starts at Leader Epoch 43 from offset 9. Previous Leader Epoch was: 42 (kafka.cluster.Partition)
[2019-10-10 07:48:17,272] WARN [LeaderEpochCache ukwhs-error-topic-3] New epoch entry EpochEntry(epoch=43, startOffset=9) caused truncation of conflicting entries ListBuffer(EpochEntry(epoch=42, startOffset=9)). Cache now contains 1 entries. (kafka.server.epoch.LeaderEpochFileCache)
[2019-10-10 07:48:17,282] INFO [Partition it-sou-audit-evt-9 broker=4] it-sou-audit-evt-9 starts at Leader Epoch 99 from offset 100094. Previous Leader Epoch was: 98 (kafka.cluster.Partition)
[2019-10-10 07:48:17,282] WARN [LeaderEpochCache it-sou-audit-evt-9] New epoch entry EpochEntry(epoch=99, startOffset=100094) caused truncation of conflicting entries ListBuffer(EpochEntry(epoch=98, startOffset=100094)). Cache now contains 1 entries. (kafka.server.epoch.LeaderEpochFileCache)
[2019-10-10 07:48:17,294] INFO [Partition data-transfer-change-evt-2 broker=4] data-transfer-change-evt-2 starts at Leader Epoch 43 from offset 0. Previous Leader Epoch was: 42 (kafka.cluster.Partition)
[2019-10-10 07:48:17,294] WARN [LeaderEpochCache data-transfer-change-evt-2] New epoch entry EpochEntry(epoch=43, startOffset=0) caused truncation of conflicting entries ListBuffer(EpochEntry(epoch=42, startOffset=0)). Cache now contains 1 entries. (kafka.server.epoch.LeaderEpochFileCache)
[2019-10-10 07:48:17,323] INFO [Partition prod-fi-hdfs-landing-evt-4 broker=4] prod-fi-hdfs-landing-evt-4 starts at Leader Epoch 10 from offset 0. Previous Leader Epoch was: 9 (kafka.cluster.Partition)
[2019-10-10 07:48:17,323] WARN [LeaderEpochCache prod-fi-hdfs-landing-evt-4] New epoch entry EpochEntry(epoch=10, startOffset=0) caused truncation of conflicting entries ListBuffer(EpochEntry(epoch=9, startOffset=0)). Cache now contains 1 entries. (kafka.server.epoch.LeaderEpochFileCache)
[2019-10-10 07:48:17,332] INFO [Partition mft-pflow-evt-3 broker=4] mft-pflow-evt-3 starts at Leader Epoch 43 from offset 0. Previous Leader Epoch was: 42 (kafka.cluster.Partition)
[2019-10-10 07:48:17,332] WARN [LeaderEpochCache mft-pflow-evt-3] New epoch entry EpochEntry(epoch=43, startOffset=0) caused truncation of conflicting entries ListBuffer(EpochEntry(epoch=42, startOffset=0)). Cache now contains 1 entries. (kafka.server.epoch.LeaderEpochFileCache)
[2019-10-10 07:48:17,341] INFO [Partition __consumer_offsets-9 broker=4] __consumer_offsets-9 starts at Leader Epoch 40 from offset 6. Previous Leader Epoch was: 39 (kafka.cluster.Partition)
[2019-10-10 07:48:17,341] WARN [LeaderEpochCache __consumer_offsets-9] New epoch entry EpochEntry(epoch=40, startOffset=6) caused truncation of conflicting entries ListBuffer(EpochEntry(epoch=39, startOffset=6)). Cache now contains 4 entries. (kafka.server.epoch.LeaderEpochFileCache)
[2019-10-10 07:48:17,352] INFO [Partition ukpai-hdfs-evt-3 broker=4] ukpai-hdfs-evt-3 starts at Leader Epoch 43 from offset 0. Previous Leader Epoch was: 42 (kafka.cluster.Partition)
[2019-10-10 07:48:17,352] WARN [LeaderEpochCache ukpai-hdfs-evt-3] New epoch entry EpochEntry(epoch=43, startOffset=0) caused truncation of conflicting entries ListBuffer(EpochEntry(epoch=42, startOffset=0)). Cache now contains 1 entries. (kafka.server.epoch.LeaderEpochFileCache)
[2019-10-10 07:48:17,360] INFO [Partition __consumer_offsets-38 broker=4] __consumer_offsets-38 starts at Leader Epoch 110 from offset 6. Previous Leader Epoch was: 109 (kafka.cluster.Partition)
[2019-10-10 07:48:17,360] WARN [LeaderEpochCache __consumer_offsets-38] New epoch entry EpochEntry(epoch=110, startOffset=6) caused truncation of conflicting entries ListBuffer(EpochEntry(epoch=109, startOffset=6)). Cache now contains 4 entries. (kafka.server.epoch.LeaderEpochFileCache)
[2019-10-10 07:48:17,373] INFO [Partition intg-ie-lrx-audit-evt-1 broker=4] intg-ie-lrx-audit-evt-1 starts at Leader Epoch 60 from offset 16. Previous Leader Epoch was: 59 (kafka.cluster.Partition)
[2019-10-10 07:48:17,373] WARN [LeaderEpochCache intg-ie-lrx-audit-evt-1] New epoch entry EpochEntry(epoch=60, startOffset=16) caused truncation of conflicting entries ListBuffer(EpochEntry(epoch=59, startOffset=16)). Cache now contains 1 entries. (kafka.server.epoch.LeaderEpochFileCache)
[2019-10-10 07:48:17,384] INFO [Partition email-service-audit-4 broker=4] email-service-audit-4 starts at Leader Epoch 39 from offset 0. Previous Leader Epoch was: 38 (kafka.cluster.Partition)
[2019-10-10 07:48:17,384] WARN [LeaderEpochCache email-service-audit-4] New epoch entry EpochEntry(epoch=39, startOffset=0) caused truncation of conflicting entries ListBuffer(EpochEntry(epoch=38, startOffset=0)). Cache now contains 1 entries. (kafka.server.epoch.LeaderEpochFileCache)
[2019-10-10 07:48:17,402] INFO [Partition mft-hdfs-landing-evt-3 broker=4] mft-hdfs-landing-evt-3 starts at Leader Epoch 43 from offset 0. Previous Leader Epoch was: 42 (kafka.cluster.Partition)
[2019-10-10 07:48:17,402] WARN [LeaderEpochCache mft-hdfs-landing-evt-3] New epoch entry EpochEntry(epoch=43, startOffset=0) caused truncation of conflicting entries ListBuffer(EpochEntry(epoch=42, startOffset=0)). Cache now contains 1 entries. (kafka.server.epoch.LeaderEpochFileCache)
[2019-10-10 07:48:17,414] INFO [Partition __consumer_offsets-13 broker=4] __consumer_offsets-13 starts at Leader Epoch 43 from offset 15. Previous Leader Epoch was: 42 (kafka.cluster.Partition)
[2019-10-10 07:48:17,414] WARN [LeaderEpochCache __consumer_offsets-13] New epoch entry EpochEntry(epoch=43, startOffset=15) caused truncation of conflicting entries ListBuffer(EpochEntry(epoch=42, startOffset=15)). Cache now contains 5 entries. (kafka.server.epoch.LeaderEpochFileCache)
[2019-10-10 07:48:17,441] INFO [Partition dca-heartbeat-evt-4 broker=4] dca-heartbeat-evt-4 starts at Leader Epoch 111 from offset 0. Previous Leader Epoch was: 110 (kafka.cluster.Partition)
[2019-10-10 07:48:17,441] WARN [LeaderEpochCache dca-heartbeat-evt-4] New epoch entry EpochEntry(epoch=111, startOffset=0) caused truncation of conflicting entries ListBuffer(EpochEntry(epoch=110, startOffset=0)). Cache now contains 1 entries. (kafka.server.epoch.LeaderEpochFileCache)
[2019-10-10 07:48:17,452] INFO [ReplicaFetcherManager on broker 4] Removed fetcher for partitions Set(prod-pipelines-errors-evt-0) (kafka.server.ReplicaFetcherManager)
[2019-10-10 07:48:17,452] INFO [ReplicaFetcherManager on broker 4] Added fetcher to broker BrokerEndPoint(id=2, host=10.75.148.4:9610) for partitions Map(prod-pipelines-errors-evt-0 -> (offset=0, leaderEpoch=119)) (kafka.server.ReplicaFetcherManager)
[2019-10-10 07:48:33,774] INFO Terminating process due to signal SIGTERM (org.apache.kafka.common.utils.LoggingSignalHandler)
[2019-10-10 07:48:33,833] INFO [KafkaServer id=4] shutting down (kafka.server.KafkaServer)
[2019-10-10 07:48:33,843] INFO [KafkaServer id=4] Starting controlled shutdown (kafka.server.KafkaServer)
[2019-10-10 07:48:33,943] WARN [KafkaServer id=4] Connection to node 1 (/10.75.148.5:9610) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)
[2019-10-10 07:48:33,943] WARN [KafkaServer id=4] Error during controlled shutdown, possibly because leader movement took longer than the configured controller.socket.timeout.ms and/or request.timeout.ms: Connection to 10.75.148.5:9610 (id: 1 rack: null) failed. (kafka.server.KafkaServer)
[2019-10-10 07:48:38,951] WARN [KafkaServer id=4] Retrying controlled shutdown after the previous attempt failed... (kafka.server.KafkaServer)
[2019-10-10 07:48:38,972] WARN [KafkaServer id=4] Connection to node 1 (/10.75.148.5:9610) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)
[2019-10-10 07:48:38,972] WARN [KafkaServer id=4] Error during controlled shutdown, possibly because leader movement took longer than the configured controller.socket.timeout.ms and/or request.timeout.ms: Connection to 10.75.148.5:9610 (id: 1 rack: null) failed. (kafka.server.KafkaServer)
[2019-10-10 07:48:43,981] WARN [KafkaServer id=4] Retrying controlled shutdown after the previous attempt failed... (kafka.server.KafkaServer)
[2019-10-10 07:48:43,993] WARN [KafkaServer id=4] Connection to node 1 (/10.75.148.5:9610) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)
[2019-10-10 07:48:43,993] WARN [KafkaServer id=4] Error during controlled shutdown, possibly because leader movement took longer than the configured controller.socket.timeout.ms and/or request.timeout.ms: Connection to 10.75.148.5:9610 (id: 1 rack: null) failed. (kafka.server.KafkaServer)
[2019-10-10 07:48:46,042] INFO [ReplicaFetcher replicaId=4, leaderId=3, fetcherId=0] Error sending fetch request (sessionId=2009290720, epoch=159064) to node 3: java.io.IOException: Connection to 3 was disconnected before the response was read. (org.apache.kafka.clients.FetchSessionHandler)
[2019-10-10 07:48:46,042] WARN [ReplicaFetcher replicaId=4, leaderId=3, fetcherId=0] Error in response for fetch request (type=FetchRequest, replicaId=4, maxWait=500, minBytes=1, maxBytes=10485760, fetchData={}, isolationLevel=READ_UNCOMMITTED, toForget=, metadata=(sessionId=2009290720, epoch=159064)) (kafka.server.ReplicaFetcherThread)
java.io.IOException: Connection to 3 was disconnected before the response was read
	at org.apache.kafka.clients.NetworkClientUtils.sendAndReceive(NetworkClientUtils.java:97)
	at kafka.server.ReplicaFetcherBlockingSend.sendRequest(ReplicaFetcherBlockingSend.scala:97)
	at kafka.server.ReplicaFetcherThread.fetchFromLeader(ReplicaFetcherThread.scala:190)
	at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:241)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:130)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:129)
	at scala.Option.foreach(Option.scala:257)
	at kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:129)
	at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:111)
	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:82)
[2019-10-10 07:48:48,044] WARN [ReplicaFetcher replicaId=4, leaderId=3, fetcherId=0] Connection to node 3 (/10.75.148.7:9610) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)
[2019-10-10 07:48:48,053] INFO [ReplicaFetcher replicaId=4, leaderId=3, fetcherId=0] Error sending fetch request (sessionId=2009290720, epoch=INITIAL) to node 3: java.io.IOException: Connection to 10.75.148.7:9610 (id: 3 rack: null) failed.. (org.apache.kafka.clients.FetchSessionHandler)
[2019-10-10 07:48:48,053] WARN [ReplicaFetcher replicaId=4, leaderId=3, fetcherId=0] Error in response for fetch request (type=FetchRequest, replicaId=4, maxWait=500, minBytes=1, maxBytes=10485760, fetchData={__consumer_offsets-32=(offset=9, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[32]), ukpai-hdfs-evt-2=(offset=2, logStartOffset=1, maxBytes=1048576, currentLeaderEpoch=Optional[32]), panel-data-change-evt-0=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[31]), gdcp-notification-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[35]), dca-audit-evt-3=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[31]), email-service-audit-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[106]), ie-lrx-audit-evt-4=(offset=716, logStartOffset=543, maxBytes=1048576, currentLeaderEpoch=Optional[114]), send-email-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[114]), mft-file-arrival-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[114]), data-transfer-change-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[32]), prod-fi-hdfs-landing-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[10]), intg-ie-lrx-rxer-audit-evt-3=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[17]), __consumer_offsets-4=(offset=6, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[36]), __consumer_offsets-27=(offset=13, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[89]), ukwhs-error-topic-2=(offset=8, logStartOffset=8, maxBytes=1048576, currentLeaderEpoch=Optional[32]), __consumer_offsets-12=(offset=15, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[32]), __consumer_offsets-35=(offset=6, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[33]), ukwhs-hdfs-landing-evt-01-3=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[29]), it-sou-audit-evt-6=(offset=100036, logStartOffset=100036, maxBytes=1048576, currentLeaderEpoch=Optional[30]), fi-error-records-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[8]), ie-lrx-rxer-audit-evt-4=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[36]), dca-heartbeat-evt-1=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[35]), mft-pflow-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[32]), __consumer_offsets-47=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[100]), __consumer_offsets-44=(offset=6, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[38]), intg-ie-lrx-audit-evt-3=(offset=21, logStartOffset=21, maxBytes=1048576, currentLeaderEpoch=Optional[18]), __consumer_offsets-7=(offset=9, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[89]), mft-hdfs-landing-evt-2=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[31]), __consumer_offsets-15=(offset=3, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[35]), email-srvc-audit-evt-3=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[37]), it-sou-audit-evt-1=(offset=494818, logStartOffset=494818, maxBytes=1048576, currentLeaderEpoch=Optional[35]), ie-lrx-pat-audit-evt-3=(offset=0, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[29]), __consumer_offsets-24=(offset=6, logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[38])}, isolationLevel=READ_UNCOMMITTED, toForget=, metadata=(sessionId=2009290720, epoch=INITIAL)) (kafka.server.ReplicaFetcherThread)
java.io.IOException: Connection to 10.75.148.7:9610 (id: 3 rack: null) failed.
	at org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:70)
	at kafka.server.ReplicaFetcherBlockingSend.sendRequest(ReplicaFetcherBlockingSend.scala:92)
	at kafka.server.ReplicaFetcherThread.fetchFromLeader(ReplicaFetcherThread.scala:190)
	at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:241)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:130)
	at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:129)
	at scala.Option.foreach(Option.scala:257)
	at kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:129)
	at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:111)
	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:82)
[2019-10-10 07:48:48,994] WARN [KafkaServer id=4] Retrying controlled shutdown after the previous attempt failed... (kafka.server.KafkaServer)
[2019-10-10 07:48:49,009] WARN [KafkaServer id=4] Proceeding to do an unclean shutdown as all the controlled shutdown attempts failed (kafka.server.KafkaServer)
[2019-10-10 07:48:49,023] INFO [/config/changes-event-process-thread]: Shutting down (kafka.common.ZkNodeChangeNotificationListener$ChangeEventProcessThread)
[2019-10-10 07:48:49,043] INFO [/config/changes-event-process-thread]: Shutdown completed (kafka.common.ZkNodeChangeNotificationListener$ChangeEventProcessThread)
[2019-10-10 07:48:49,043] INFO [/config/changes-event-process-thread]: Stopped (kafka.common.ZkNodeChangeNotificationListener$ChangeEventProcessThread)
[2019-10-10 07:48:49,051] INFO [SocketServer brokerId=4] Stopping socket server request processors (kafka.network.SocketServer)
[2019-10-10 07:48:49,112] INFO [SocketServer brokerId=4] Stopped socket server request processors (kafka.network.SocketServer)
[2019-10-10 07:48:49,113] INFO [Kafka Request Handler on Broker 4], shutting down (kafka.server.KafkaRequestHandlerPool)
[2019-10-10 07:48:49,134] INFO [Kafka Request Handler on Broker 4], shut down completely (kafka.server.KafkaRequestHandlerPool)
[2019-10-10 07:48:49,183] INFO [KafkaApi-4] Shutdown complete. (kafka.server.KafkaApis)
[2019-10-10 07:48:49,190] INFO [ExpirationReaper-4-topic]: Shutting down (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2019-10-10 07:48:49,331] INFO [ExpirationReaper-4-topic]: Stopped (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2019-10-10 07:48:49,341] INFO [ExpirationReaper-4-topic]: Shutdown completed (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2019-10-10 07:48:49,349] INFO [TransactionCoordinator id=4] Shutting down. (kafka.coordinator.transaction.TransactionCoordinator)
[2019-10-10 07:48:49,350] INFO [ProducerId Manager 4]: Shutdown complete: last producerId assigned 80000 (kafka.coordinator.transaction.ProducerIdManager)
[2019-10-10 07:48:49,351] INFO [Transaction State Manager 4]: Shutdown complete (kafka.coordinator.transaction.TransactionStateManager)
[2019-10-10 07:48:49,351] INFO [Transaction Marker Channel Manager 4]: Shutting down (kafka.coordinator.transaction.TransactionMarkerChannelManager)
[2019-10-10 07:48:49,351] INFO [Transaction Marker Channel Manager 4]: Shutdown completed (kafka.coordinator.transaction.TransactionMarkerChannelManager)
[2019-10-10 07:48:49,351] INFO [Transaction Marker Channel Manager 4]: Stopped (kafka.coordinator.transaction.TransactionMarkerChannelManager)
[2019-10-10 07:48:49,352] INFO [TransactionCoordinator id=4] Shutdown complete. (kafka.coordinator.transaction.TransactionCoordinator)
[2019-10-10 07:48:49,353] INFO [GroupCoordinator 4]: Shutting down. (kafka.coordinator.group.GroupCoordinator)
[2019-10-10 07:48:49,353] INFO [ExpirationReaper-4-Heartbeat]: Shutting down (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2019-10-10 07:48:49,454] INFO [ExpirationReaper-4-Heartbeat]: Stopped (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2019-10-10 07:48:49,454] INFO [ExpirationReaper-4-Heartbeat]: Shutdown completed (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2019-10-10 07:48:49,457] INFO [ExpirationReaper-4-Rebalance]: Shutting down (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2019-10-10 07:48:49,654] INFO [ExpirationReaper-4-Rebalance]: Stopped (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2019-10-10 07:48:49,654] INFO [ExpirationReaper-4-Rebalance]: Shutdown completed (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2019-10-10 07:48:49,662] INFO [GroupCoordinator 4]: Shutdown complete. (kafka.coordinator.group.GroupCoordinator)
[2019-10-10 07:48:49,663] INFO [ReplicaManager broker=4] Shutting down (kafka.server.ReplicaManager)
[2019-10-10 07:48:49,663] INFO [LogDirFailureHandler]: Shutting down (kafka.server.ReplicaManager$LogDirFailureHandler)
[2019-10-10 07:48:49,664] INFO [LogDirFailureHandler]: Shutdown completed (kafka.server.ReplicaManager$LogDirFailureHandler)
[2019-10-10 07:48:49,664] INFO [LogDirFailureHandler]: Stopped (kafka.server.ReplicaManager$LogDirFailureHandler)
[2019-10-10 07:48:49,672] INFO [ReplicaFetcherManager on broker 4] shutting down (kafka.server.ReplicaFetcherManager)
[2019-10-10 07:48:49,672] INFO [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Shutting down (kafka.server.ReplicaFetcherThread)
[2019-10-10 07:48:49,674] INFO [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error sending fetch request (sessionId=919177392, epoch=INITIAL) to node 2: java.nio.channels.ClosedSelectorException. (org.apache.kafka.clients.FetchSessionHandler)
[2019-10-10 07:48:49,674] INFO [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Stopped (kafka.server.ReplicaFetcherThread)
[2019-10-10 07:48:49,679] INFO [ReplicaFetcher replicaId=4, leaderId=3, fetcherId=0] Shutting down (kafka.server.ReplicaFetcherThread)
[2019-10-10 07:48:49,704] INFO [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Shutdown completed (kafka.server.ReplicaFetcherThread)
[2019-10-10 07:48:49,710] INFO [ReplicaFetcher replicaId=4, leaderId=3, fetcherId=0] Stopped (kafka.server.ReplicaFetcherThread)
[2019-10-10 07:48:49,710] INFO [ReplicaFetcher replicaId=4, leaderId=3, fetcherId=0] Shutdown completed (kafka.server.ReplicaFetcherThread)
[2019-10-10 07:48:49,713] INFO [ReplicaFetcherManager on broker 4] shutdown completed (kafka.server.ReplicaFetcherManager)
[2019-10-10 07:48:49,713] INFO [ReplicaAlterLogDirsManager on broker 4] shutting down (kafka.server.ReplicaAlterLogDirsManager)
[2019-10-10 07:48:49,715] INFO [ReplicaAlterLogDirsManager on broker 4] shutdown completed (kafka.server.ReplicaAlterLogDirsManager)
[2019-10-10 07:48:49,717] INFO [ExpirationReaper-4-Fetch]: Shutting down (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2019-10-10 07:48:49,884] INFO [ExpirationReaper-4-Fetch]: Stopped (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2019-10-10 07:48:49,884] INFO [ExpirationReaper-4-Fetch]: Shutdown completed (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2019-10-10 07:48:49,889] INFO [ExpirationReaper-4-Produce]: Shutting down (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2019-10-10 07:48:50,044] INFO [ExpirationReaper-4-Produce]: Stopped (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2019-10-10 07:48:50,044] INFO [ExpirationReaper-4-Produce]: Shutdown completed (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2019-10-10 07:48:50,044] INFO [ExpirationReaper-4-DeleteRecords]: Shutting down (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2019-10-10 07:48:50,153] INFO [ExpirationReaper-4-DeleteRecords]: Stopped (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2019-10-10 07:48:50,153] INFO [ExpirationReaper-4-DeleteRecords]: Shutdown completed (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2019-10-10 07:48:50,172] INFO [ReplicaManager broker=4] Shut down completely (kafka.server.ReplicaManager)
[2019-10-10 07:48:50,172] INFO Shutting down. (kafka.log.LogManager)
[2019-10-10 07:48:50,247] INFO [ProducerStateManager partition=ukwhs-hdfs-landing-evt-2] Writing producer snapshot at offset 67 (kafka.log.ProducerStateManager)
[2019-10-10 07:48:50,255] INFO [ProducerStateManager partition=ie-lrx-audit-evt-0] Writing producer snapshot at offset 749 (kafka.log.ProducerStateManager)
[2019-10-10 07:48:50,281] INFO [ProducerStateManager partition=__consumer_offsets-23] Writing producer snapshot at offset 3025677 (kafka.log.ProducerStateManager)
[2019-10-10 07:48:50,283] INFO [ProducerStateManager partition=__consumer_offsets-16] Writing producer snapshot at offset 11329814 (kafka.log.ProducerStateManager)
[2019-10-10 07:48:50,292] INFO [ProducerStateManager partition=__consumer_offsets-31] Writing producer snapshot at offset 3472033 (kafka.log.ProducerStateManager)
[2019-10-10 07:48:50,314] INFO [ProducerStateManager partition=ukpai-hdfs-evt-2] Writing producer snapshot at offset 2 (kafka.log.ProducerStateManager)
[2019-10-10 07:48:50,343] INFO [ProducerStateManager partition=ukwhs_validations-1] Writing producer snapshot at offset 1 (kafka.log.ProducerStateManager)
[2019-10-10 07:48:50,353] INFO [ProducerStateManager partition=ie-lrx-audit-evt-4] Writing producer snapshot at offset 716 (kafka.log.ProducerStateManager)
[2019-10-10 07:48:50,403] INFO [ProducerStateManager partition=ukwhs-hdfs-landing-evt-7] Writing producer snapshot at offset 66 (kafka.log.ProducerStateManager)
[2019-10-10 07:48:50,413] INFO [ProducerStateManager partition=ie-lrx-audit-evt-1] Writing producer snapshot at offset 728 (kafka.log.ProducerStateManager)
[2019-10-10 07:48:50,572] INFO Shutdown complete. (kafka.log.LogManager)
[2019-10-10 07:48:50,613] INFO [ZooKeeperClient] Closing. (kafka.zookeeper.ZooKeeperClient)
[2019-10-10 07:48:50,641] INFO Session: 0x50000026f97022d closed (org.apache.zookeeper.ZooKeeper)
[2019-10-10 07:48:50,641] INFO EventThread shut down for session: 0x50000026f97022d (org.apache.zookeeper.ClientCnxn)
[2019-10-10 07:48:50,641] INFO [ZooKeeperClient] Closed. (kafka.zookeeper.ZooKeeperClient)
[2019-10-10 07:48:50,641] INFO [ThrottledChannelReaper-Fetch]: Shutting down (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
[2019-10-10 07:48:51,562] INFO [ThrottledChannelReaper-Fetch]: Stopped (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
[2019-10-10 07:48:51,562] INFO [ThrottledChannelReaper-Fetch]: Shutdown completed (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
[2019-10-10 07:48:51,563] INFO [ThrottledChannelReaper-Produce]: Shutting down (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
[2019-10-10 07:48:51,771] INFO [ThrottledChannelReaper-Produce]: Stopped (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
[2019-10-10 07:48:51,771] INFO [ThrottledChannelReaper-Produce]: Shutdown completed (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
[2019-10-10 07:48:51,771] INFO [ThrottledChannelReaper-Request]: Shutting down (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
[2019-10-10 07:48:52,054] INFO [ThrottledChannelReaper-Request]: Stopped (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
[2019-10-10 07:48:52,061] INFO [ThrottledChannelReaper-Request]: Shutdown completed (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
[2019-10-10 07:48:52,063] INFO [SocketServer brokerId=4] Shutting down socket server (kafka.network.SocketServer)
[2019-10-10 07:48:52,170] INFO [SocketServer brokerId=4] Shutdown completed (kafka.network.SocketServer)
[2019-10-10 07:48:52,286] INFO Stopped KafkaStatsDReporter with host=198.51.100.1, port=59954 (com.airbnb.metrics.StatsDReporter)
[2019-10-10 07:48:52,303] INFO [KafkaServer id=4] shut down completed (kafka.server.KafkaServer)