Skip to content

Instantly share code, notes, and snippets.

@jyeargers

jyeargers/gist:e8398fb353d67397f99148bc970479ee

Created December 6, 2016 13:14
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save jyeargers/e8398fb353d67397f99148bc970479ee to your computer and use it in GitHub Desktop.
Save jyeargers/e8398fb353d67397f99148bc970479ee to your computer and use it in GitHub Desktop.
Download ZIP
Debug window output from KStreams app
Raw
gistfile1.txt
2016-12-06 04:55:28,800 [main] INFO o.a.k.common.utils.AppInfoParser - Kafka version : 0.10.1.0
2016-12-06 04:55:28,800 [main] INFO o.a.k.common.utils.AppInfoParser - Kafka version : 0.10.1.0
2016-12-06 04:55:28,801 [main] INFO o.a.k.common.utils.AppInfoParser - Kafka commitId : 3402a74efb23d1d4
2016-12-06 04:55:28,801 [main] INFO o.a.k.common.utils.AppInfoParser - Kafka commitId : 3402a74efb23d1d4
2016-12-06 04:55:28,804 [main] INFO o.apache.kafka.streams.KafkaStreams - Started Kafka Stream process
2016-12-06 04:55:28,804 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Starting
2016-12-06 04:55:28,804 [main] INFO o.apache.kafka.streams.KafkaStreams - Started Kafka Stream process
2016-12-06 04:55:28,804 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Starting
2016-12-06 04:55:29,294 [StreamThread-1] WARN o.a.kafka.clients.NetworkClient - Error while fetching metadata with correlation id 1 : {PRTMinuteAgg-prt_minute_agg_stream-repartition=LEADER_NOT_AVAILABLE}
2016-12-06 04:55:29,294 [StreamThread-1] WARN o.a.kafka.clients.NetworkClient - Error while fetching metadata with correlation id 1 : {PRTMinuteAgg-prt_minute_agg_stream-repartition=LEADER_NOT_AVAILABLE}
2016-12-06 04:55:38,770 [main-SendThread(12.34.236.113:2181)] DEBUG org.apache.zookeeper.ClientCnxn - Got ping response for sessionid: 0xc58abee3e00001f after 180ms
2016-12-06 04:55:48,774 [main-SendThread(12.34.236.113:2181)] DEBUG org.apache.zookeeper.ClientCnxn - Got ping response for sessionid: 0xc58abee3e00001f after 178ms
2016-12-06 04:55:58,781 [main-SendThread(12.34.236.113:2181)] DEBUG org.apache.zookeeper.ClientCnxn - Got ping response for sessionid: 0xc58abee3e00001f after 182ms
2016-12-06 04:56:08,781 [main-SendThread(12.34.236.113:2181)] DEBUG org.apache.zookeeper.ClientCnxn - Got ping response for sessionid: 0xc58abee3e00001f after 181ms
2016-12-06 04:56:18,782 [main-SendThread(12.34.236.113:2181)] DEBUG org.apache.zookeeper.ClientCnxn - Got ping response for sessionid: 0xc58abee3e00001f after 180ms
2016-12-06 04:56:28,791 [main-SendThread(12.34.236.113:2181)] DEBUG org.apache.zookeeper.ClientCnxn - Got ping response for sessionid: 0xc58abee3e00001f after 183ms
2016-12-06 04:56:38,791 [main-SendThread(12.34.236.113:2181)] DEBUG org.apache.zookeeper.ClientCnxn - Got ping response for sessionid: 0xc58abee3e00001f after 179ms
2016-12-06 04:56:45,145 [StreamThread-1] INFO o.a.k.c.c.i.AbstractCoordinator - Discovered coordinator 12.34.236.113:9092 (id: 2147483535 rack: null) for group PRTMinuteAgg.
2016-12-06 04:56:45,145 [StreamThread-1] INFO o.a.k.c.c.i.AbstractCoordinator - Discovered coordinator 12.34.236.113:9092 (id: 2147483535 rack: null) for group PRTMinuteAgg.
2016-12-06 04:56:45,147 [StreamThread-1] INFO o.a.k.c.c.i.ConsumerCoordinator - Revoking previously assigned partitions [] for group PRTMinuteAgg
2016-12-06 04:56:45,147 [StreamThread-1] INFO o.a.k.c.c.i.ConsumerCoordinator - Revoking previously assigned partitions [] for group PRTMinuteAgg
2016-12-06 04:56:45,148 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] partitions [[]] revoked at the beginning of consumer rebalance.
2016-12-06 04:56:45,148 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] partitions [[]] revoked at the beginning of consumer rebalance.
2016-12-06 04:56:45,150 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Removing all active tasks [[]]
2016-12-06 04:56:45,150 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Removing all active tasks [[]]
2016-12-06 04:56:45,150 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Removing all standby tasks [[]]
2016-12-06 04:56:45,150 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Removing all standby tasks [[]]
2016-12-06 04:56:45,150 [StreamThread-1] INFO o.a.k.c.c.i.AbstractCoordinator - (Re-)joining group PRTMinuteAgg
2016-12-06 04:56:45,150 [StreamThread-1] INFO o.a.k.c.c.i.AbstractCoordinator - (Re-)joining group PRTMinuteAgg
2016-12-06 04:56:45,694 [main-SendThread(12.34.236.113:2181)] DEBUG org.apache.zookeeper.ClientCnxn - Reading reply sessionid:0xc58abee3e00001f, packet:: clientPath:null serverPath:null finished:false header:: 1,4 replyHeader:: 1,60129544363,0 request:: '/brokers/topics/PRTMinuteAgg-prt_minute_agg_stream-repartition,F response:: #7b2276657273696f6e223a312c22706172746974696f6e73223a7b2231223a5b3131335d2c2230223a5b3131325d7d7d,s{60129544355,60129544355,1481028929149,1481028929149,0,1,0,0,48,1,60129544358}
2016-12-06 04:56:46,077 [main-SendThread(12.34.236.113:2181)] DEBUG org.apache.zookeeper.ClientCnxn - Reading reply sessionid:0xc58abee3e00001f, packet:: clientPath:null serverPath:null finished:false header:: 2,8 replyHeader:: 2,60129544363,0 request:: '/brokers/ids,F response:: v{'110,'111,'112,'113,'114,'115,'116}
2016-12-06 04:56:46,288 [main-SendThread(12.34.236.113:2181)] DEBUG org.apache.zookeeper.ClientCnxn - Reading reply sessionid:0xc58abee3e00001f, packet:: clientPath:null serverPath:null finished:false header:: 3,5 replyHeader:: 3,60129544364,0 request:: '/brokers/topics/PRTMinuteAgg-prt_minute_agg_stream-repartition,#7b22706172746974696f6e73223a7b2230223a5b3131325d2c2231223a5b3131335d2c2232223a5b3131305d2c2233223a5b3131315d2c2234223a5b3131325d2c2235223a5b3131335d2c2236223a5b3131345d2c2237223a5b3131355d2c2238223a5b3131365d2c2239223a5b3131305d7d2c2276657273696f6e223a317d,-1 response:: s{60129544355,60129544364,1481028929149,1481029006168,1,1,0,0,128,1,60129544358}
2016-12-06 04:56:46,467 [main-SendThread(12.34.236.113:2181)] DEBUG org.apache.zookeeper.ClientCnxn - Reading reply sessionid:0xc58abee3e00001f, packet:: clientPath:null serverPath:null finished:false header:: 4,4 replyHeader:: 4,60129544388,0 request:: '/brokers/topics/PRTMinuteAgg-prt_minute_agg_stream-repartition,F response:: #7b22706172746974696f6e73223a7b2230223a5b3131325d2c2231223a5b3131335d2c2232223a5b3131305d2c2233223a5b3131315d2c2234223a5b3131325d2c2235223a5b3131335d2c2236223a5b3131345d2c2237223a5b3131355d2c2238223a5b3131365d2c2239223a5b3131305d7d2c2276657273696f6e223a317d,s{60129544355,60129544364,1481028929149,1481029006168,1,1,0,0,128,1,60129544358}
2016-12-06 04:56:56,476 [main-SendThread(12.34.236.113:2181)] DEBUG org.apache.zookeeper.ClientCnxn - Got ping response for sessionid: 0xc58abee3e00001f after 181ms
2016-12-06 04:57:06,476 [main-SendThread(12.34.236.113:2181)] DEBUG org.apache.zookeeper.ClientCnxn - Got ping response for sessionid: 0xc58abee3e00001f after 178ms
2016-12-06 04:57:16,529 [main-SendThread(12.34.236.113:2181)] DEBUG org.apache.zookeeper.ClientCnxn - Got ping response for sessionid: 0xc58abee3e00001f after 228ms
2016-12-06 04:57:26,491 [main-SendThread(12.34.236.113:2181)] DEBUG org.apache.zookeeper.ClientCnxn - Got ping response for sessionid: 0xc58abee3e00001f after 187ms
2016-12-06 04:57:36,486 [main-SendThread(12.34.236.113:2181)] DEBUG org.apache.zookeeper.ClientCnxn - Got ping response for sessionid: 0xc58abee3e00001f after 177ms
2016-12-06 04:57:46,491 [main-SendThread(12.34.236.113:2181)] DEBUG org.apache.zookeeper.ClientCnxn - Got ping response for sessionid: 0xc58abee3e00001f after 177ms
2016-12-06 04:57:56,501 [main-SendThread(12.34.236.113:2181)] DEBUG org.apache.zookeeper.ClientCnxn - Got ping response for sessionid: 0xc58abee3e00001f after 184ms
2016-12-06 04:58:02,546 [StreamThread-1] INFO o.a.k.s.p.i.StreamPartitionAssignor - stream-thread [StreamThread-1] Completed validating internal topics in partition assignor
2016-12-06 04:58:02,546 [StreamThread-1] INFO o.a.k.s.p.i.StreamPartitionAssignor - stream-thread [StreamThread-1] Completed validating internal topics in partition assignor
2016-12-06 04:58:02,548 [StreamThread-1] INFO o.a.k.s.p.i.assignment.TaskAssignor - stream-thread [StreamThread-1] Assigning tasks to clients: {a15fcf41-0172-4bf5-9f29-a0520418d675=[activeTasks: ([]) assignedTasks: ([]) prevActiveTasks: ([]) prevAssignedTasks: ([0_0, 0_1, 0_2, 0_3, 0_4, 0_5, 0_6, 0_7, 0_8, 0_9]) capacity: 1.0 cost: 0.0]}, prevAssignmentBalanced: false, prevClientsUnchanged: false, tasks: [0_0, 0_1, 1_0, 0_2, 1_1, 0_3, 1_2, 0_4, 1_3, 0_5, 1_4, 0_6, 1_5, 0_7, 1_6, 0_8, 1_7, 0_9, 1_8, 1_9], replicas: 0
2016-12-06 04:58:02,548 [StreamThread-1] INFO o.a.k.s.p.i.assignment.TaskAssignor - stream-thread [StreamThread-1] Assigning tasks to clients: {a15fcf41-0172-4bf5-9f29-a0520418d675=[activeTasks: ([]) assignedTasks: ([]) prevActiveTasks: ([]) prevAssignedTasks: ([0_0, 0_1, 0_2, 0_3, 0_4, 0_5, 0_6, 0_7, 0_8, 0_9]) capacity: 1.0 cost: 0.0]}, prevAssignmentBalanced: false, prevClientsUnchanged: false, tasks: [0_0, 0_1, 1_0, 0_2, 1_1, 0_3, 1_2, 0_4, 1_3, 0_5, 1_4, 0_6, 1_5, 0_7, 1_6, 0_8, 1_7, 0_9, 1_8, 1_9], replicas: 0
2016-12-06 04:58:02,551 [StreamThread-1] INFO o.a.k.s.p.i.assignment.TaskAssignor - stream-thread [StreamThread-1] Assigned with: {a15fcf41-0172-4bf5-9f29-a0520418d675=[activeTasks: ([0_0, 0_1, 1_0, 0_2, 1_1, 1_2, 0_3, 0_4, 1_3, 0_5, 1_4, 0_6, 1_5, 0_7, 1_6, 0_8, 1_7, 1_8, 0_9, 1_9]) assignedTasks: ([0_0, 0_1, 1_0, 0_2, 1_1, 1_2, 0_3, 0_4, 1_3, 0_5, 1_4, 0_6, 1_5, 0_7, 1_6, 0_8, 1_7, 1_8, 0_9, 1_9]) prevActiveTasks: ([]) prevAssignedTasks: ([]) capacity: 1.0 cost: 7.0]}
2016-12-06 04:58:02,551 [StreamThread-1] INFO o.a.k.s.p.i.assignment.TaskAssignor - stream-thread [StreamThread-1] Assigned with: {a15fcf41-0172-4bf5-9f29-a0520418d675=[activeTasks: ([0_0, 0_1, 1_0, 0_2, 1_1, 1_2, 0_3, 0_4, 1_3, 0_5, 1_4, 0_6, 1_5, 0_7, 1_6, 0_8, 1_7, 1_8, 0_9, 1_9]) assignedTasks: ([0_0, 0_1, 1_0, 0_2, 1_1, 1_2, 0_3, 0_4, 1_3, 0_5, 1_4, 0_6, 1_5, 0_7, 1_6, 0_8, 1_7, 1_8, 0_9, 1_9]) prevActiveTasks: ([]) prevAssignedTasks: ([]) capacity: 1.0 cost: 7.0]}
2016-12-06 04:58:02,732 [main-SendThread(12.34.236.113:2181)] DEBUG org.apache.zookeeper.ClientCnxn - Reading reply sessionid:0xc58abee3e00001f, packet:: clientPath:null serverPath:null finished:false header:: 5,4 replyHeader:: 5,60129544388,0 request:: '/brokers/topics/PRTMinuteAgg-prt_minute_agg_stream-repartition,F response:: #7b22706172746974696f6e73223a7b2230223a5b3131325d2c2231223a5b3131335d2c2232223a5b3131305d2c2233223a5b3131315d2c2234223a5b3131325d2c2235223a5b3131335d2c2236223a5b3131345d2c2237223a5b3131355d2c2238223a5b3131365d2c2239223a5b3131305d7d2c2276657273696f6e223a317d,s{60129544355,60129544364,1481028929149,1481029006168,1,1,0,0,128,1,60129544358}
2016-12-06 04:58:02,915 [StreamThread-1] INFO o.a.k.s.p.i.StreamPartitionAssignor - stream-thread [StreamThread-1] Completed validating internal topics in partition assignor
2016-12-06 04:58:02,915 [StreamThread-1] INFO o.a.k.s.p.i.StreamPartitionAssignor - stream-thread [StreamThread-1] Completed validating internal topics in partition assignor
2016-12-06 04:58:03,096 [main-SendThread(12.34.236.113:2181)] DEBUG org.apache.zookeeper.ClientCnxn - Reading reply sessionid:0xc58abee3e00001f, packet:: clientPath:null serverPath:null finished:false header:: 6,4 replyHeader:: 6,60129544388,0 request:: '/brokers/topics/PRTMinuteAgg-prt_minute_agg_stream-changelog,F response:: #7b22706172746974696f6e73223a7b2230223a5b3131305d2c2231223a5b3131315d2c2232223a5b3131325d2c2233223a5b3131335d2c2234223a5b3131345d2c2235223a5b3131355d2c2236223a5b3131365d2c2237223a5b3131305d2c2238223a5b3131315d2c2239223a5b3131325d7d2c2276657273696f6e223a317d,s{60129543396,60129543396,1480968725975,1480968725975,0,1,0,0,128,1,60129543399}
2016-12-06 04:58:03,272 [StreamThread-1] INFO o.a.k.s.p.i.StreamPartitionAssignor - stream-thread [StreamThread-1] Completed validating internal topics in partition assignor
2016-12-06 04:58:03,272 [StreamThread-1] INFO o.a.k.s.p.i.StreamPartitionAssignor - stream-thread [StreamThread-1] Completed validating internal topics in partition assignor
2016-12-06 04:58:03,451 [StreamThread-1] INFO o.a.k.c.c.i.AbstractCoordinator - (Re-)joining group PRTMinuteAgg
2016-12-06 04:58:03,451 [StreamThread-1] INFO o.a.k.c.c.i.AbstractCoordinator - (Re-)joining group PRTMinuteAgg
2016-12-06 04:58:03,807 [main-SendThread(12.34.236.113:2181)] DEBUG org.apache.zookeeper.ClientCnxn - Reading reply sessionid:0xc58abee3e00001f, packet:: clientPath:null serverPath:null finished:false header:: 7,4 replyHeader:: 7,60129544388,0 request:: '/brokers/topics/PRTMinuteAgg-prt_minute_agg_stream-repartition,F response:: #7b22706172746974696f6e73223a7b2230223a5b3131325d2c2231223a5b3131335d2c2232223a5b3131305d2c2233223a5b3131315d2c2234223a5b3131325d2c2235223a5b3131335d2c2236223a5b3131345d2c2237223a5b3131355d2c2238223a5b3131365d2c2239223a5b3131305d7d2c2276657273696f6e223a317d,s{60129544355,60129544364,1481028929149,1481029006168,1,1,0,0,128,1,60129544358}
2016-12-06 04:58:03,985 [StreamThread-1] INFO o.a.k.s.p.i.StreamPartitionAssignor - stream-thread [StreamThread-1] Completed validating internal topics in partition assignor
2016-12-06 04:58:03,985 [StreamThread-1] INFO o.a.k.s.p.i.StreamPartitionAssignor - stream-thread [StreamThread-1] Completed validating internal topics in partition assignor
2016-12-06 04:58:03,985 [StreamThread-1] INFO o.a.k.s.p.i.assignment.TaskAssignor - stream-thread [StreamThread-1] Assigning tasks to clients: {a15fcf41-0172-4bf5-9f29-a0520418d675=[activeTasks: ([]) assignedTasks: ([]) prevActiveTasks: ([]) prevAssignedTasks: ([0_0, 0_1, 0_2, 0_3, 0_4, 0_5, 0_6, 0_7, 0_8, 0_9]) capacity: 1.0 cost: 0.0]}, prevAssignmentBalanced: false, prevClientsUnchanged: false, tasks: [0_0, 0_1, 1_0, 0_2, 1_1, 0_3, 1_2, 0_4, 1_3, 0_5, 1_4, 0_6, 1_5, 0_7, 1_6, 0_8, 1_7, 0_9, 1_8, 1_9], replicas: 0
2016-12-06 04:58:03,985 [StreamThread-1] INFO o.a.k.s.p.i.assignment.TaskAssignor - stream-thread [StreamThread-1] Assigning tasks to clients: {a15fcf41-0172-4bf5-9f29-a0520418d675=[activeTasks: ([]) assignedTasks: ([]) prevActiveTasks: ([]) prevAssignedTasks: ([0_0, 0_1, 0_2, 0_3, 0_4, 0_5, 0_6, 0_7, 0_8, 0_9]) capacity: 1.0 cost: 0.0]}, prevAssignmentBalanced: false, prevClientsUnchanged: false, tasks: [0_0, 0_1, 1_0, 0_2, 1_1, 0_3, 1_2, 0_4, 1_3, 0_5, 1_4, 0_6, 1_5, 0_7, 1_6, 0_8, 1_7, 0_9, 1_8, 1_9], replicas: 0
2016-12-06 04:58:03,987 [StreamThread-1] INFO o.a.k.s.p.i.assignment.TaskAssignor - stream-thread [StreamThread-1] Assigned with: {a15fcf41-0172-4bf5-9f29-a0520418d675=[activeTasks: ([0_0, 0_1, 1_0, 0_2, 1_1, 1_2, 0_3, 0_4, 1_3, 0_5, 1_4, 0_6, 1_5, 0_7, 1_6, 0_8, 1_7, 1_8, 0_9, 1_9]) assignedTasks: ([0_0, 0_1, 1_0, 0_2, 1_1, 1_2, 0_3, 0_4, 1_3, 0_5, 1_4, 0_6, 1_5, 0_7, 1_6, 0_8, 1_7, 1_8, 0_9, 1_9]) prevActiveTasks: ([]) prevAssignedTasks: ([]) capacity: 1.0 cost: 7.0]}
2016-12-06 04:58:03,987 [StreamThread-1] INFO o.a.k.s.p.i.assignment.TaskAssignor - stream-thread [StreamThread-1] Assigned with: {a15fcf41-0172-4bf5-9f29-a0520418d675=[activeTasks: ([0_0, 0_1, 1_0, 0_2, 1_1, 1_2, 0_3, 0_4, 1_3, 0_5, 1_4, 0_6, 1_5, 0_7, 1_6, 0_8, 1_7, 1_8, 0_9, 1_9]) assignedTasks: ([0_0, 0_1, 1_0, 0_2, 1_1, 1_2, 0_3, 0_4, 1_3, 0_5, 1_4, 0_6, 1_5, 0_7, 1_6, 0_8, 1_7, 1_8, 0_9, 1_9]) prevActiveTasks: ([]) prevAssignedTasks: ([]) capacity: 1.0 cost: 7.0]}
2016-12-06 04:58:04,164 [main-SendThread(12.34.236.113:2181)] DEBUG org.apache.zookeeper.ClientCnxn - Reading reply sessionid:0xc58abee3e00001f, packet:: clientPath:null serverPath:null finished:false header:: 8,4 replyHeader:: 8,60129544388,0 request:: '/brokers/topics/PRTMinuteAgg-prt_minute_agg_stream-repartition,F response:: #7b22706172746974696f6e73223a7b2230223a5b3131325d2c2231223a5b3131335d2c2232223a5b3131305d2c2233223a5b3131315d2c2234223a5b3131325d2c2235223a5b3131335d2c2236223a5b3131345d2c2237223a5b3131355d2c2238223a5b3131365d2c2239223a5b3131305d7d2c2276657273696f6e223a317d,s{60129544355,60129544364,1481028929149,1481029006168,1,1,0,0,128,1,60129544358}
2016-12-06 04:58:04,342 [StreamThread-1] INFO o.a.k.s.p.i.StreamPartitionAssignor - stream-thread [StreamThread-1] Completed validating internal topics in partition assignor
2016-12-06 04:58:04,342 [StreamThread-1] INFO o.a.k.s.p.i.StreamPartitionAssignor - stream-thread [StreamThread-1] Completed validating internal topics in partition assignor
2016-12-06 04:58:04,521 [main-SendThread(12.34.236.113:2181)] DEBUG org.apache.zookeeper.ClientCnxn - Reading reply sessionid:0xc58abee3e00001f, packet:: clientPath:null serverPath:null finished:false header:: 9,4 replyHeader:: 9,60129544388,0 request:: '/brokers/topics/PRTMinuteAgg-prt_minute_agg_stream-changelog,F response:: #7b22706172746974696f6e73223a7b2230223a5b3131305d2c2231223a5b3131315d2c2232223a5b3131325d2c2233223a5b3131335d2c2234223a5b3131345d2c2235223a5b3131355d2c2236223a5b3131365d2c2237223a5b3131305d2c2238223a5b3131315d2c2239223a5b3131325d7d2c2276657273696f6e223a317d,s{60129543396,60129543396,1480968725975,1480968725975,0,1,0,0,128,1,60129543399}
2016-12-06 04:58:04,700 [StreamThread-1] INFO o.a.k.s.p.i.StreamPartitionAssignor - stream-thread [StreamThread-1] Completed validating internal topics in partition assignor
2016-12-06 04:58:04,700 [StreamThread-1] INFO o.a.k.s.p.i.StreamPartitionAssignor - stream-thread [StreamThread-1] Completed validating internal topics in partition assignor
2016-12-06 04:58:04,876 [StreamThread-1] INFO o.a.k.c.c.i.AbstractCoordinator - Successfully joined group PRTMinuteAgg with generation 39
2016-12-06 04:58:04,876 [StreamThread-1] INFO o.a.k.c.c.i.AbstractCoordinator - Successfully joined group PRTMinuteAgg with generation 39
2016-12-06 04:58:04,878 [StreamThread-1] INFO o.a.k.c.c.i.ConsumerCoordinator - Setting newly assigned partitions [PRTMinuteAgg-prt_minute_agg_stream-repartition-9, PRTMinuteAgg-prt_minute_agg_stream-repartition-8, PRTMinuteAgg-prt_minute_agg_stream-repartition-7, PRTMinuteAgg-prt_minute_agg_stream-repartition-6, rtdetail-9, rtdetail-6, rtdetail-5, rtdetail-8, rtdetail-7, rtdetail-2, rtdetail-1, rtdetail-4, rtdetail-3, rtdetail-0, PRTMinuteAgg-prt_minute_agg_stream-repartition-5, PRTMinuteAgg-prt_minute_agg_stream-repartition-4, PRTMinuteAgg-prt_minute_agg_stream-repartition-3, PRTMinuteAgg-prt_minute_agg_stream-repartition-2, PRTMinuteAgg-prt_minute_agg_stream-repartition-1, PRTMinuteAgg-prt_minute_agg_stream-repartition-0] for group PRTMinuteAgg
2016-12-06 04:58:04,878 [StreamThread-1] INFO o.a.k.c.c.i.ConsumerCoordinator - Setting newly assigned partitions [PRTMinuteAgg-prt_minute_agg_stream-repartition-9, PRTMinuteAgg-prt_minute_agg_stream-repartition-8, PRTMinuteAgg-prt_minute_agg_stream-repartition-7, PRTMinuteAgg-prt_minute_agg_stream-repartition-6, rtdetail-9, rtdetail-6, rtdetail-5, rtdetail-8, rtdetail-7, rtdetail-2, rtdetail-1, rtdetail-4, rtdetail-3, rtdetail-0, PRTMinuteAgg-prt_minute_agg_stream-repartition-5, PRTMinuteAgg-prt_minute_agg_stream-repartition-4, PRTMinuteAgg-prt_minute_agg_stream-repartition-3, PRTMinuteAgg-prt_minute_agg_stream-repartition-2, PRTMinuteAgg-prt_minute_agg_stream-repartition-1, PRTMinuteAgg-prt_minute_agg_stream-repartition-0] for group PRTMinuteAgg
2016-12-06 04:58:04,879 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] New partitions [[PRTMinuteAgg-prt_minute_agg_stream-repartition-9, PRTMinuteAgg-prt_minute_agg_stream-repartition-8, PRTMinuteAgg-prt_minute_agg_stream-repartition-7, PRTMinuteAgg-prt_minute_agg_stream-repartition-6, rtdetail-9, rtdetail-6, rtdetail-5, rtdetail-8, rtdetail-7, rtdetail-2, rtdetail-1, rtdetail-4, rtdetail-3, rtdetail-0, PRTMinuteAgg-prt_minute_agg_stream-repartition-5, PRTMinuteAgg-prt_minute_agg_stream-repartition-4, PRTMinuteAgg-prt_minute_agg_stream-repartition-3, PRTMinuteAgg-prt_minute_agg_stream-repartition-2, PRTMinuteAgg-prt_minute_agg_stream-repartition-1, PRTMinuteAgg-prt_minute_agg_stream-repartition-0]] assigned at the end of consumer rebalance.
2016-12-06 04:58:04,879 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] New partitions [[PRTMinuteAgg-prt_minute_agg_stream-repartition-9, PRTMinuteAgg-prt_minute_agg_stream-repartition-8, PRTMinuteAgg-prt_minute_agg_stream-repartition-7, PRTMinuteAgg-prt_minute_agg_stream-repartition-6, rtdetail-9, rtdetail-6, rtdetail-5, rtdetail-8, rtdetail-7, rtdetail-2, rtdetail-1, rtdetail-4, rtdetail-3, rtdetail-0, PRTMinuteAgg-prt_minute_agg_stream-repartition-5, PRTMinuteAgg-prt_minute_agg_stream-repartition-4, PRTMinuteAgg-prt_minute_agg_stream-repartition-3, PRTMinuteAgg-prt_minute_agg_stream-repartition-2, PRTMinuteAgg-prt_minute_agg_stream-repartition-1, PRTMinuteAgg-prt_minute_agg_stream-repartition-0]] assigned at the end of consumer rebalance.
2016-12-06 04:58:04,879 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Creating active task 0_0 with assigned partitions [[rtdetail-0]]
2016-12-06 04:58:04,879 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Creating active task 0_0 with assigned partitions [[rtdetail-0]]
2016-12-06 04:58:04,904 [StreamThread-1] INFO o.a.k.s.p.internals.StreamTask - task [0_0] Initializing state stores
2016-12-06 04:58:04,904 [StreamThread-1] INFO o.a.k.s.p.internals.StreamTask - task [0_0] Initializing state stores
2016-12-06 04:58:05,086 [StreamThread-1] INFO o.a.k.s.p.internals.StreamTask - task [0_0] Initializing processor nodes of the topology
2016-12-06 04:58:05,086 [StreamThread-1] INFO o.a.k.s.p.internals.StreamTask - task [0_0] Initializing processor nodes of the topology
2016-12-06 04:58:05,087 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Creating active task 0_1 with assigned partitions [[rtdetail-1]]
2016-12-06 04:58:05,087 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Creating active task 0_1 with assigned partitions [[rtdetail-1]]
2016-12-06 04:58:05,089 [StreamThread-1] INFO o.a.k.s.p.internals.StreamTask - task [0_1] Initializing state stores
2016-12-06 04:58:05,089 [StreamThread-1] INFO o.a.k.s.p.internals.StreamTask - task [0_1] Initializing state stores
2016-12-06 04:58:05,090 [StreamThread-1] INFO o.a.k.s.p.internals.StreamTask - task [0_1] Initializing processor nodes of the topology
2016-12-06 04:58:05,090 [StreamThread-1] INFO o.a.k.s.p.internals.StreamTask - task [0_1] Initializing processor nodes of the topology
2016-12-06 04:58:05,090 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Creating active task 1_0 with assigned partitions [[PRTMinuteAgg-prt_minute_agg_stream-repartition-0]]
2016-12-06 04:58:05,090 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Creating active task 1_0 with assigned partitions [[PRTMinuteAgg-prt_minute_agg_stream-repartition-0]]
2016-12-06 04:58:05,098 [StreamThread-1] INFO o.a.k.s.p.internals.StreamTask - task [1_0] Initializing state stores
2016-12-06 04:58:05,098 [StreamThread-1] INFO o.a.k.s.p.internals.StreamTask - task [1_0] Initializing state stores
2016-12-06 04:58:14,526 [main-SendThread(12.34.236.113:2181)] DEBUG org.apache.zookeeper.ClientCnxn - Got ping response for sessionid: 0xc58abee3e00001f after 178ms
2016-12-06 04:58:24,532 [main-SendThread(12.34.236.113:2181)] DEBUG org.apache.zookeeper.ClientCnxn - Got ping response for sessionid: 0xc58abee3e00001f after 183ms
2016-12-06 04:58:34,531 [main-SendThread(12.34.236.113:2181)] DEBUG org.apache.zookeeper.ClientCnxn - Got ping response for sessionid: 0xc58abee3e00001f after 180ms
2016-12-06 04:58:44,541 [main-SendThread(12.34.236.113:2181)] DEBUG org.apache.zookeeper.ClientCnxn - Got ping response for sessionid: 0xc58abee3e00001f after 187ms
2016-12-06 04:58:49,655 [StreamThread-1] INFO o.a.k.s.p.internals.StreamTask - task [1_0] Initializing processor nodes of the topology
2016-12-06 04:58:49,655 [StreamThread-1] INFO o.a.k.s.p.internals.StreamTask - task [1_0] Initializing processor nodes of the topology
2016-12-06 04:58:49,656 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Creating active task 0_2 with assigned partitions [[rtdetail-2]]
2016-12-06 04:58:49,656 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Creating active task 0_2 with assigned partitions [[rtdetail-2]]
2016-12-06 04:58:49,657 [StreamThread-1] INFO o.a.k.s.p.internals.StreamTask - task [0_2] Initializing state stores
2016-12-06 04:58:49,657 [StreamThread-1] INFO o.a.k.s.p.internals.StreamTask - task [0_2] Initializing state stores
2016-12-06 04:58:49,657 [StreamThread-1] INFO o.a.k.s.p.internals.StreamTask - task [0_2] Initializing processor nodes of the topology
2016-12-06 04:58:49,657 [StreamThread-1] INFO o.a.k.s.p.internals.StreamTask - task [0_2] Initializing processor nodes of the topology
2016-12-06 04:58:49,657 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Creating active task 1_1 with assigned partitions [[PRTMinuteAgg-prt_minute_agg_stream-repartition-1]]
2016-12-06 04:58:49,657 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Creating active task 1_1 with assigned partitions [[PRTMinuteAgg-prt_minute_agg_stream-repartition-1]]
2016-12-06 04:58:49,658 [StreamThread-1] INFO o.a.k.s.p.internals.StreamTask - task [1_1] Initializing state stores
2016-12-06 04:58:49,658 [StreamThread-1] INFO o.a.k.s.p.internals.StreamTask - task [1_1] Initializing state stores
2016-12-06 04:58:54,534 [main-SendThread(12.34.236.113:2181)] DEBUG org.apache.zookeeper.ClientCnxn - Got ping response for sessionid: 0xc58abee3e00001f after 176ms
2016-12-06 04:59:04,542 [main-SendThread(12.34.236.113:2181)] DEBUG org.apache.zookeeper.ClientCnxn - Got ping response for sessionid: 0xc58abee3e00001f after 178ms
2016-12-06 04:59:14,556 [main-SendThread(12.34.236.113:2181)] DEBUG org.apache.zookeeper.ClientCnxn - Got ping response for sessionid: 0xc58abee3e00001f after 189ms
2016-12-06 04:59:24,563 [main-SendThread(12.34.236.113:2181)] DEBUG org.apache.zookeeper.ClientCnxn - Got ping response for sessionid: 0xc58abee3e00001f after 192ms
2016-12-06 04:59:34,550 [main-SendThread(12.34.236.113:2181)] DEBUG org.apache.zookeeper.ClientCnxn - Got ping response for sessionid: 0xc58abee3e00001f after 175ms
2016-12-06 04:59:35,768 [StreamThread-1] INFO o.a.k.s.p.internals.StreamTask - task [1_1] Initializing processor nodes of the topology
2016-12-06 04:59:35,768 [StreamThread-1] INFO o.a.k.s.p.internals.StreamTask - task [1_1] Initializing processor nodes of the topology
2016-12-06 04:59:35,768 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Creating active task 0_3 with assigned partitions [[rtdetail-3]]
2016-12-06 04:59:35,768 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Creating active task 0_3 with assigned partitions [[rtdetail-3]]
2016-12-06 04:59:35,769 [StreamThread-1] INFO o.a.k.s.p.internals.StreamTask - task [0_3] Initializing state stores
2016-12-06 04:59:35,769 [StreamThread-1] INFO o.a.k.s.p.internals.StreamTask - task [0_3] Initializing state stores
2016-12-06 04:59:35,769 [StreamThread-1] INFO o.a.k.s.p.internals.StreamTask - task [0_3] Initializing processor nodes of the topology
2016-12-06 04:59:35,769 [StreamThread-1] INFO o.a.k.s.p.internals.StreamTask - task [0_3] Initializing processor nodes of the topology
2016-12-06 04:59:35,769 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Creating active task 1_2 with assigned partitions [[PRTMinuteAgg-prt_minute_agg_stream-repartition-2]]
2016-12-06 04:59:35,769 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Creating active task 1_2 with assigned partitions [[PRTMinuteAgg-prt_minute_agg_stream-repartition-2]]
2016-12-06 04:59:35,769 [StreamThread-1] INFO o.a.k.s.p.internals.StreamTask - task [1_2] Initializing state stores
2016-12-06 04:59:35,769 [StreamThread-1] INFO o.a.k.s.p.internals.StreamTask - task [1_2] Initializing state stores
2016-12-06 04:59:44,555 [main-SendThread(12.34.236.113:2181)] DEBUG org.apache.zookeeper.ClientCnxn - Got ping response for sessionid: 0xc58abee3e00001f after 179ms
2016-12-06 04:59:54,699 [main-SendThread(12.34.236.113:2181)] DEBUG org.apache.zookeeper.ClientCnxn - Got ping response for sessionid: 0xc58abee3e00001f after 322ms
2016-12-06 05:00:04,563 [main-SendThread(12.34.236.113:2181)] DEBUG org.apache.zookeeper.ClientCnxn - Got ping response for sessionid: 0xc58abee3e00001f after 186ms
2016-12-06 05:00:14,555 [main-SendThread(12.34.236.113:2181)] DEBUG org.apache.zookeeper.ClientCnxn - Got ping response for sessionid: 0xc58abee3e00001f after 176ms
2016-12-06 05:00:24,571 [main-SendThread(12.34.236.113:2181)] DEBUG org.apache.zookeeper.ClientCnxn - Got ping response for sessionid: 0xc58abee3e00001f after 189ms
2016-12-06 05:00:34,694 [main-SendThread(12.34.236.113:2181)] DEBUG org.apache.zookeeper.ClientCnxn - Got ping response for sessionid: 0xc58abee3e00001f after 312ms
2016-12-06 05:00:44,585 [main-SendThread(12.34.236.113:2181)] DEBUG org.apache.zookeeper.ClientCnxn - Got ping response for sessionid: 0xc58abee3e00001f after 197ms
2016-12-06 05:00:45,031 [StreamThread-1] INFO o.a.k.s.p.internals.StreamTask - task [1_2] Initializing processor nodes of the topology
2016-12-06 05:00:45,031 [StreamThread-1] INFO o.a.k.s.p.internals.StreamTask - task [1_2] Initializing processor nodes of the topology
2016-12-06 05:00:45,031 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Creating active task 0_4 with assigned partitions [[rtdetail-4]]
2016-12-06 05:00:45,031 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Creating active task 0_4 with assigned partitions [[rtdetail-4]]
2016-12-06 05:00:45,037 [StreamThread-1] INFO o.a.k.s.p.internals.StreamTask - task [0_4] Initializing state stores
2016-12-06 05:00:45,037 [StreamThread-1] INFO o.a.k.s.p.internals.StreamTask - task [0_4] Initializing state stores
2016-12-06 05:00:45,037 [StreamThread-1] INFO o.a.k.s.p.internals.StreamTask - task [0_4] Initializing processor nodes of the topology
2016-12-06 05:00:45,037 [StreamThread-1] INFO o.a.k.s.p.internals.StreamTask - task [0_4] Initializing processor nodes of the topology
2016-12-06 05:00:45,037 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Creating active task 1_3 with assigned partitions [[PRTMinuteAgg-prt_minute_agg_stream-repartition-3]]
2016-12-06 05:00:45,037 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Creating active task 1_3 with assigned partitions [[PRTMinuteAgg-prt_minute_agg_stream-repartition-3]]
2016-12-06 05:00:45,038 [StreamThread-1] INFO o.a.k.s.p.internals.StreamTask - task [1_3] Initializing state stores
2016-12-06 05:00:45,038 [StreamThread-1] INFO o.a.k.s.p.internals.StreamTask - task [1_3] Initializing state stores
2016-12-06 05:00:54,565 [main-SendThread(12.34.236.113:2181)] DEBUG org.apache.zookeeper.ClientCnxn - Got ping response for sessionid: 0xc58abee3e00001f after 176ms
2016-12-06 05:01:04,570 [main-SendThread(12.34.236.113:2181)] DEBUG org.apache.zookeeper.ClientCnxn - Got ping response for sessionid: 0xc58abee3e00001f after 174ms
2016-12-06 05:01:14,745 [main-SendThread(12.34.236.113:2181)] DEBUG org.apache.zookeeper.ClientCnxn - Got ping response for sessionid: 0xc58abee3e00001f after 342ms
2016-12-06 05:01:24,691 [main-SendThread(12.34.236.113:2181)] DEBUG org.apache.zookeeper.ClientCnxn - Got ping response for sessionid: 0xc58abee3e00001f after 283ms
2016-12-06 05:01:34,630 [main-SendThread(12.34.236.113:2181)] DEBUG org.apache.zookeeper.ClientCnxn - Got ping response for sessionid: 0xc58abee3e00001f after 215ms
2016-12-06 05:01:44,595 [main-SendThread(12.34.236.113:2181)] DEBUG org.apache.zookeeper.ClientCnxn - Got ping response for sessionid: 0xc58abee3e00001f after 175ms
2016-12-06 05:01:54,606 [main-SendThread(12.34.236.113:2181)] DEBUG org.apache.zookeeper.ClientCnxn - Got ping response for sessionid: 0xc58abee3e00001f after 185ms
2016-12-06 05:02:04,610 [main-SendThread(12.34.236.113:2181)] DEBUG org.apache.zookeeper.ClientCnxn - Got ping response for sessionid: 0xc58abee3e00001f after 182ms
2016-12-06 05:02:14,604 [main-SendThread(12.34.236.113:2181)] DEBUG org.apache.zookeeper.ClientCnxn - Got ping response for sessionid: 0xc58abee3e00001f after 176ms
2016-12-06 05:02:24,605 [main-SendThread(12.34.236.113:2181)] DEBUG org.apache.zookeeper.ClientCnxn - Got ping response for sessionid: 0xc58abee3e00001f after 175ms
2016-12-06 05:02:33,344 [StreamThread-1] INFO o.a.k.s.p.internals.StreamTask - task [1_3] Initializing processor nodes of the topology
2016-12-06 05:02:33,344 [StreamThread-1] INFO o.a.k.s.p.internals.StreamTask - task [1_3] Initializing processor nodes of the topology
2016-12-06 05:02:33,344 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Creating active task 0_5 with assigned partitions [[rtdetail-5]]
2016-12-06 05:02:33,344 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Creating active task 0_5 with assigned partitions [[rtdetail-5]]
2016-12-06 05:02:33,345 [StreamThread-1] INFO o.a.k.s.p.internals.StreamTask - task [0_5] Initializing state stores
2016-12-06 05:02:33,345 [StreamThread-1] INFO o.a.k.s.p.internals.StreamTask - task [0_5] Initializing state stores
2016-12-06 05:02:33,345 [StreamThread-1] INFO o.a.k.s.p.internals.StreamTask - task [0_5] Initializing processor nodes of the topology
2016-12-06 05:02:33,345 [StreamThread-1] INFO o.a.k.s.p.internals.StreamTask - task [0_5] Initializing processor nodes of the topology
2016-12-06 05:02:33,345 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Creating active task 1_4 with assigned partitions [[PRTMinuteAgg-prt_minute_agg_stream-repartition-4]]
2016-12-06 05:02:33,345 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Creating active task 1_4 with assigned partitions [[PRTMinuteAgg-prt_minute_agg_stream-repartition-4]]
2016-12-06 05:02:33,346 [StreamThread-1] INFO o.a.k.s.p.internals.StreamTask - task [1_4] Initializing state stores
2016-12-06 05:02:33,346 [StreamThread-1] INFO o.a.k.s.p.internals.StreamTask - task [1_4] Initializing state stores
2016-12-06 05:02:34,658 [main-SendThread(12.34.236.113:2181)] DEBUG org.apache.zookeeper.ClientCnxn - Got ping response for sessionid: 0xc58abee3e00001f after 223ms
2016-12-06 05:02:44,621 [main-SendThread(12.34.236.113:2181)] DEBUG org.apache.zookeeper.ClientCnxn - Got ping response for sessionid: 0xc58abee3e00001f after 181ms
2016-12-06 05:02:54,620 [main-SendThread(12.34.236.113:2181)] DEBUG org.apache.zookeeper.ClientCnxn - Got ping response for sessionid: 0xc58abee3e00001f after 175ms
2016-12-06 05:03:04,623 [main-SendThread(12.34.236.113:2181)] DEBUG org.apache.zookeeper.ClientCnxn - Got ping response for sessionid: 0xc58abee3e00001f after 176ms
2016-12-06 05:03:14,630 [main-SendThread(12.34.236.113:2181)] DEBUG org.apache.zookeeper.ClientCnxn - Got ping response for sessionid: 0xc58abee3e00001f after 182ms
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment