[2016-11-28 19:55:36,345] INFO Rolled new log segment for 'topic_35-1' in 31 ms. (kafka.log.Log)
[2016-11-28 19:55:39,283] INFO Rolled new log segment for 'topic_5-1' in 32 ms. (kafka.log.Log)
[2016-11-28 19:56:23,564] INFO Rolled new log segment for 'topic_39-1' in 2 ms. (kafka.log.Log)
[2016-11-28 19:56:52,788] INFO Rolled new log segment for 'topic_4-2' in 8 ms. (kafka.log.Log)
[2016-11-28 19:57:04,382] INFO Rolled new log segment for 'topic_16-0' in 10 ms. (kafka.log.Log)
[2016-11-28 19:57:05,408] INFO Partition [topic_18,1] on broker 1002: Shrinking ISR for partition [topic_18,1] from 1002,1003,1001 to 1002 (kafka.cluster.Partition)
[2016-11-28 19:57:05,411] INFO Partition [connect-offsets,22] on broker 1002: Shrinking ISR for partition [connect-offsets,22] from 1003,1002,1001 to 1002 (kafka.cluster.Partition)
[2016-11-28 19:57:05,420] INFO Partition [__consumer_offsets,48] on broker 1002: Shrinking ISR for partition [__consumer_offsets,48] from 1003,1002,1001 to 1002 (kafka.cluster.Partition)
[2016-11-28 19:57:05,421] INFO Partition [__consumer_offsets,15] on broker 1002: Shrinking ISR for partition [__consumer_offsets,15] from 1003,1002,1001 to 1002 (kafka.cluster.Partition)
[2016-11-28 19:57:05,423] INFO Partition [topic_15,1] on broker 1002: Shrinking ISR for partition [topic_15,1] from 1003,1002,1001 to 1002 (kafka.cluster.Partition)
[2016-11-28 19:57:05,424] INFO Partition [topic_7,1] on broker 1002: Shrinking ISR for partition [topic_7,1] from 1003,1002,1001 to 1002 (kafka.cluster.Partition)
[2016-11-28 19:57:05,426] INFO Partition [topic_3,0] on broker 1002: Shrinking ISR for partition [topic_3,0] from 1003,1002,1001 to 1002 (kafka.cluster.Partition)
[2016-11-28 19:57:05,427] INFO Partition [topic_30,1] on broker 1002: Shrinking ISR for partition [topic_30,1] from 1003,1002,1001 to 1002 (kafka.cluster.Partition)
[2016-11-28 19:57:05,429] INFO Partition [__consumer_offsets,36] on broker 1002: Shrinking ISR for partition [__consumer_offsets,36] from 1003,1002,1001 to 1002 (kafka.cluster.Partition)
[2016-11-28 19:57:05,433] INFO Partition [topic_23,0] on broker 1002: Shrinking ISR for partition [topic_23,0] from 1003,1002,1001 to 1002 (kafka.cluster.Partition)
[2016-11-28 19:57:05,440] INFO Partition [__consumer_offsets,18] on broker 1002: Shrinking ISR for partition [__consumer_offsets,18] from 1003,1002,1001 to 1002 (kafka.cluster.Partition)
[2016-11-28 19:57:05,441] INFO Partition [__consumer_offsets,6] on broker 1002: Shrinking ISR for partition [__consumer_offsets,6] from 1003,1002,1001 to 1002 (kafka.cluster.Partition)
[2016-11-28 19:57:05,443] INFO Partition [topic_19,1] on broker 1002: Shrinking ISR for partition [topic_19,1] from 1003,1002,1001 to 1002 (kafka.cluster.Partition)
[2016-11-28 19:57:05,444] INFO Partition [connect-offsets,16] on broker 1002: Shrinking ISR for partition [connect-offsets,16] from 1003,1002,1001 to 1002 (kafka.cluster.Partition)
[2016-11-28 19:57:05,447] INFO Partition [topic_0_get,1] on broker 1002: Shrinking ISR for partition [topic_0_get,1] from 1002,1001,1003 to 1002 (kafka.cluster.Partition)
[2016-11-28 19:57:05,450] INFO Partition [__consumer_offsets,21] on broker 1002: Shrinking ISR for partition [__consumer_offsets,21] from 1003,1002,1001 to 1002 (kafka.cluster.Partition)
[2016-11-28 19:57:05,452] INFO Partition [__consumer_offsets,3] on broker 1002: Shrinking ISR for partition [__consumer_offsets,3] from 1003,1002,1001 to 1002 (kafka.cluster.Partition)
[2016-11-28 19:57:05,453] INFO Partition [__consumer_offsets,39] on broker 1002: Shrinking ISR for partition [__consumer_offsets,39] from 1003,1002,1001 to 1002 (kafka.cluster.Partition)
[2016-11-28 19:57:05,455] INFO Partition [topic_17,1] on broker 1002: Shrinking ISR for partition [topic_17,1] from 1002,1003,1001 to 1002 (kafka.cluster.Partition)
[2016-11-28 19:57:05,457] INFO Partition [topic_24,0] on broker 1002: Shrinking ISR for partition [topic_24,0] from 1003,1002,1001 to 1002 (kafka.cluster.Partition)
[2016-11-28 19:57:05,460] INFO Partition [connect-offsets,1] on broker 1002: Shrinking ISR for partition [connect-offsets,1] from 1003,1002,1001 to 1002 (kafka.cluster.Partition)
[2016-11-28 19:57:05,463] INFO Partition [__consumer_offsets,27] on broker 1002: Shrinking ISR for partition [__consumer_offsets,27] from 1003,1002,1001 to 1002 (kafka.cluster.Partition)
[2016-11-28 19:57:05,466] INFO Partition [connect-offsets,13] on broker 1002: Shrinking ISR for partition [connect-offsets,13] from 1003,1002,1001 to 1002 (kafka.cluster.Partition)
[2016-11-28 19:57:05,468] INFO Partition [__consumer_offsets,30] on broker 1002: Shrinking ISR for partition [__consumer_offsets,30] from 1003,1002,1001 to 1002 (kafka.cluster.Partition)
[2016-11-28 19:57:05,469] INFO Partition [__consumer_offsets,33] on broker 1002: Shrinking ISR for partition [__consumer_offsets,33] from 1003,1002,1001 to 1002 (kafka.cluster.Partition)
[2016-11-28 19:57:05,471] INFO Partition [__consumer_offsets,0] on broker 1002: Shrinking ISR for partition [__consumer_offsets,0] from 1003,1002,1001 to 1002 (kafka.cluster.Partition)
[2016-11-28 19:57:05,473] INFO Partition [topic_39,0] on broker 1002: Shrinking ISR for partition [topic_39,0] from 1003,1002,1001 to 1002 (kafka.cluster.Partition)
[2016-11-28 19:57:05,475] INFO Partition [topic_41,0] on broker 1002: Shrinking ISR for partition [topic_41,0] from 1003,1002,1001 to 1002 (kafka.cluster.Partition)
[2016-11-28 19:57:05,477] INFO Partition [__consumer_offsets,12] on broker 1002: Shrinking ISR for partition [__consumer_offsets,12] from 1003,1002,1001 to 1002 (kafka.cluster.Partition)
[2016-11-28 19:57:05,480] INFO Partition [__consumer_offsets,24] on broker 1002: Shrinking ISR for partition [__consumer_offsets,24] from 1003,1002,1001 to 1002 (kafka.cluster.Partition)
[2016-11-28 19:57:05,482] INFO Partition [topic_13,2] on broker 1002: Shrinking ISR for partition [topic_13,2] from 1003,1002,1001 to 1002 (kafka.cluster.Partition)
[2016-11-28 19:57:05,484] INFO Partition [__consumer_offsets,42] on broker 1002: Shrinking ISR for partition [__consumer_offsets,42] from 1003,1002,1001 to 1002 (kafka.cluster.Partition)
[2016-11-28 19:57:05,487] INFO Partition [topic_21,2] on broker 1002: Shrinking ISR for partition [topic_21,2] from 1003,1002,1001 to 1002 (kafka.cluster.Partition)
[2016-11-28 19:57:05,489] INFO Partition [topic_22,2] on broker 1002: Shrinking ISR for partition [topic_22,2] from 1003,1002,1001 to 1002 (kafka.cluster.Partition)
[2016-11-28 19:57:05,491] INFO Partition [topic_6,1] on broker 1002: Shrinking ISR for partition [topic_6,1] from 1003,1002,1001 to 1002 (kafka.cluster.Partition)
[2016-11-28 19:57:05,492] INFO Partition [connect-offsets,7] on broker 1002: Shrinking ISR for partition [connect-offsets,7] from 1003,1002,1001 to 1002 (kafka.cluster.Partition)
[2016-11-28 19:57:05,494] INFO Partition [topic_20,1] on broker 1002: Shrinking ISR for partition [topic_20,1] from 1003,1002,1001 to 1002 (kafka.cluster.Partition)
[2016-11-28 19:57:05,497] INFO Partition [connect-offsets,10] on broker 1002: Shrinking ISR for partition [connect-offsets,10] from 1003,1002,1001 to 1002 (kafka.cluster.Partition)
[2016-11-28 19:57:05,500] INFO Partition [__consumer_offsets,9] on broker 1002: Shrinking ISR for partition [__consumer_offsets,9] from 1002,1003,1001 to 1002 (kafka.cluster.Partition)
[2016-11-28 19:57:05,504] INFO Partition [topic_8,1] on broker 1002: Shrinking ISR for partition [topic_8,1] from 1003,1002,1001 to 1002 (kafka.cluster.Partition)
[2016-11-28 19:57:05,513] INFO Partition [topic_44,2] on broker 1002: Shrinking ISR for partition [topic_44,2] from 1002,1001,1003 to 1002 (kafka.cluster.Partition)
[2016-11-28 19:57:05,515] INFO Partition [topic_31,1] on broker 1002: Shrinking ISR for partition [topic_31,1] from 1003,1002,1001 to 1002 (kafka.cluster.Partition)
[2016-11-28 19:57:05,517] INFO Partition [topic_28,1] on broker 1002: Shrinking ISR for partition [topic_28,1] from 1003,1002,1001 to 1002 (kafka.cluster.Partition)
[2016-11-28 19:57:05,519] INFO Partition [topic_12,0] on broker 1002: Shrinking ISR for partition [topic_12,0] from 1003,1002,1001 to 1002 (kafka.cluster.Partition)
[2016-11-28 19:57:05,528] INFO Partition [connect-config,0] on broker 1002: Shrinking ISR for partition [connect-config,0] from 1003,1002,1001 to 1002 (kafka.cluster.Partition)
[2016-11-28 19:57:05,534] INFO Partition [topic_42,2] on broker 1002: Shrinking ISR for partition [topic_42,2] from 1003,1002,1001 to 1002 (kafka.cluster.Partition)
[2016-11-28 19:57:05,537] INFO Partition [connect-offsets,4] on broker 1002: Shrinking ISR for partition [connect-offsets,4] from 1003,1002,1001 to 1002 (kafka.cluster.Partition)
[2016-11-28 19:57:05,541] INFO Partition [topic_0,1] on broker 1002: Shrinking ISR for partition [topic_0,1] from 1002,1001,1003 to 1002 (kafka.cluster.Partition)
[2016-11-28 19:57:05,547] INFO Partition [topic_0_post,0] on broker 1002: Shrinking ISR for partition [topic_0_post,0] from 1002,1001,1003 to 1002 (kafka.cluster.Partition)
[2016-11-28 19:57:05,550] INFO Partition [connect-offsets,19] on broker 1002: Shrinking ISR for partition [connect-offsets,19] from 1003,1002,1001 to 1002 (kafka.cluster.Partition)
[2016-11-28 19:57:05,552] INFO Partition [topic_4,0] on broker 1002: Shrinking ISR for partition [topic_4,0] from 1003,1002,1001 to 1002 (kafka.cluster.Partition)
[2016-11-28 19:57:05,555] INFO Partition [topic_11,1] on broker 1002: Shrinking ISR for partition [topic_11,1] from 1003,1002,1001 to 1002 (kafka.cluster.Partition)
[2016-11-28 19:57:05,557] INFO Partition [__consumer_offsets,45] on broker 1002: Shrinking ISR for partition [__consumer_offsets,45] from 1003,1002,1001 to 1002 (kafka.cluster.Partition)
[2016-11-28 19:57:07,992] INFO Successfully authenticated client: authenticationID=kafka_stage/node_1003@REALM_NAME; authorizationID=kafka_stage/node_1003@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:57:07,992] INFO Setting authorizedID: kafka_stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:57:15,162] INFO Scheduling log segment 3227606 for log topic_9-1 for deletion. (kafka.log.Log)
[2016-11-28 19:57:15,176] INFO Scheduling log segment 2421235 for log topic_39-1 for deletion. (kafka.log.Log)
[2016-11-28 19:57:15,176] INFO Scheduling log segment 4652857 for log topic_16-1 for deletion. (kafka.log.Log)
[2016-11-28 19:57:15,184] INFO Scheduling log segment 3227670 for log topic_9-0 for deletion. (kafka.log.Log)
[2016-11-28 19:57:15,213] INFO Scheduling log segment 2470661 for log topic_35-1 for deletion. (kafka.log.Log)
[2016-11-28 19:57:15,213] INFO Scheduling log segment 3487945 for log topic_5-1 for deletion. (kafka.log.Log)
[2016-11-28 19:57:15,213] INFO Scheduling log segment 8560530 for log topic_4-2 for deletion. (kafka.log.Log)
[2016-11-28 19:57:15,213] INFO Scheduling log segment 5026144 for log topic_28-0 for deletion. (kafka.log.Log)
[2016-11-28 19:57:15,221] INFO Scheduling log segment 8560633 for log topic_4-0 for deletion. (kafka.log.Log)
[2016-11-28 19:57:15,221] INFO Scheduling log segment 4652886 for log topic_16-0 for deletion. (kafka.log.Log)
[2016-11-28 19:57:18,012] INFO Successfully authenticated client: authenticationID=kafka_stage/node_1003@REALM_NAME; authorizationID=kafka_stage/node_1003@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:57:18,012] INFO Setting authorizedID: kafka_stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:57:18,013] INFO Partition [topic_3,0] on broker 1002: Expanding ISR for partition [topic_3,0] from 1002 to 1002,1003 (kafka.cluster.Partition)
[2016-11-28 19:57:18,015] INFO Partition [connect-offsets,13] on broker 1002: Expanding ISR for partition [connect-offsets,13] from 1002 to 1002,1003 (kafka.cluster.Partition)
[2016-11-28 19:57:18,016] INFO Partition [__consumer_offsets,36] on broker 1002: Expanding ISR for partition [__consumer_offsets,36] from 1002 to 1002,1003 (kafka.cluster.Partition)
[2016-11-28 19:57:18,018] INFO Partition [topic_22,2] on broker 1002: Expanding ISR for partition [topic_22,2] from 1002 to 1002,1003 (kafka.cluster.Partition)
[2016-11-28 19:57:18,019] INFO Partition [__consumer_offsets,18] on broker 1002: Expanding ISR for partition [__consumer_offsets,18] from 1002 to 1002,1003 (kafka.cluster.Partition)
[2016-11-28 19:57:18,021] INFO Partition [topic_23,0] on broker 1002: Expanding ISR for partition [topic_23,0] from 1002 to 1002,1003 (kafka.cluster.Partition)
[2016-11-28 19:57:18,022] INFO Partition [__consumer_offsets,45] on broker 1002: Expanding ISR for partition [__consumer_offsets,45] from 1002 to 1002,1003 (kafka.cluster.Partition)
[2016-11-28 19:57:18,221] INFO Successfully authenticated client: authenticationID=kafka_stage/node_1001@REALM_NAME; authorizationID=kafka_stage/node_1001@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:57:18,222] INFO Setting authorizedID: kafka_stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:57:18,222] INFO Partition [topic_3,0] on broker 1002: Expanding ISR for partition [topic_3,0] from 1002,1003 to 1002,1003,1001 (kafka.cluster.Partition)
[2016-11-28 19:57:18,224] INFO Partition [connect-offsets,13] on broker 1002: Expanding ISR for partition [connect-offsets,13] from 1002,1003 to 1002,1003,1001 (kafka.cluster.Partition)
[2016-11-28 19:57:18,226] INFO Partition [__consumer_offsets,36] on broker 1002: Expanding ISR for partition [__consumer_offsets,36] from 1002,1003 to 1002,1003,1001 (kafka.cluster.Partition)
[2016-11-28 19:57:18,227] INFO Partition [topic_22,2] on broker 1002: Expanding ISR for partition [topic_22,2] from 1002,1003 to 1002,1003,1001 (kafka.cluster.Partition)
[2016-11-28 19:57:18,229] INFO Partition [__consumer_offsets,18] on broker 1002: Expanding ISR for partition [__consumer_offsets,18] from 1002,1003 to 1002,1003,1001 (kafka.cluster.Partition)
[2016-11-28 19:57:18,230] INFO Partition [topic_23,0] on broker 1002: Expanding ISR for partition [topic_23,0] from 1002,1003 to 1002,1003,1001 (kafka.cluster.Partition)
[2016-11-28 19:57:18,232] INFO Partition [__consumer_offsets,45] on broker 1002: Expanding ISR for partition [__consumer_offsets,45] from 1002,1003 to 1002,1003,1001 (kafka.cluster.Partition)
[2016-11-28 19:57:18,436] INFO Rolled new log segment for 'topic_16-1' in 2 ms. (kafka.log.Log)
[2016-11-28 19:57:26,035] INFO Successfully authenticated client: authenticationID=consumer-12-stage@REALM_NAME; authorizationID=consumer-12-stage@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:57:26,035] INFO Setting authorizedID: consumer-12-stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:57:26,711] INFO Rolled new log segment for 'topic_12-0' in 1 ms. (kafka.log.Log)
[2016-11-28 19:57:28,282] INFO Rolled new log segment for 'topic_28-0' in 2 ms. (kafka.log.Log)
[2016-11-28 19:57:29,879] INFO Rolled new log segment for 'topic_37-1' in 28 ms. (kafka.log.Log)
[2016-11-28 19:57:35,408] INFO Partition [topic_3,0] on broker 1002: Shrinking ISR for partition [topic_3,0] from 1002,1003,1001 to 1002 (kafka.cluster.Partition)
[2016-11-28 19:57:35,412] INFO Partition [__consumer_offsets,36] on broker 1002: Shrinking ISR for partition [__consumer_offsets,36] from 1002,1003,1001 to 1002 (kafka.cluster.Partition)
[2016-11-28 19:57:35,415] INFO Partition [topic_23,0] on broker 1002: Shrinking ISR for partition [topic_23,0] from 1002,1003,1001 to 1002 (kafka.cluster.Partition)
[2016-11-28 19:57:35,416] INFO Partition [__consumer_offsets,18] on broker 1002: Shrinking ISR for partition [__consumer_offsets,18] from 1002,1003,1001 to 1002 (kafka.cluster.Partition)
[2016-11-28 19:57:35,417] INFO Partition [connect-offsets,13] on broker 1002: Shrinking ISR for partition [connect-offsets,13] from 1002,1003,1001 to 1002 (kafka.cluster.Partition)
[2016-11-28 19:57:35,427] INFO Partition [topic_22,2] on broker 1002: Shrinking ISR for partition [topic_22,2] from 1002,1003,1001 to 1002 (kafka.cluster.Partition)
[2016-11-28 19:57:35,430] INFO Partition [__consumer_offsets,45] on broker 1002: Shrinking ISR for partition [__consumer_offsets,45] from 1002,1003,1001 to 1002 (kafka.cluster.Partition)
[2016-11-28 19:57:36,520] INFO Rolled new log segment for 'topic_17-0' in 10 ms. (kafka.log.Log)
[2016-11-28 19:57:39,140] INFO Rolled new log segment for '__consumer_offsets-13' in 1 ms. (kafka.log.Log)
[2016-11-28 19:57:40,782] INFO Rolled new log segment for 'topic_28-1' in 2 ms. (kafka.log.Log)
[2016-11-28 19:57:50,047] INFO Successfully authenticated client: authenticationID=kafka_stage/node_1003@REALM_NAME; authorizationID=kafka_stage/node_1003@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:57:50,047] INFO Setting authorizedID: kafka_stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:57:50,049] INFO Partition [topic_3,0] on broker 1002: Expanding ISR for partition [topic_3,0] from 1002 to 1002,1003 (kafka.cluster.Partition)
[2016-11-28 19:57:50,051] INFO Partition [connect-offsets,13] on broker 1002: Expanding ISR for partition [connect-offsets,13] from 1002 to 1002,1003 (kafka.cluster.Partition)
[2016-11-28 19:57:50,052] INFO Partition [__consumer_offsets,36] on broker 1002: Expanding ISR for partition [__consumer_offsets,36] from 1002 to 1002,1003 (kafka.cluster.Partition)
[2016-11-28 19:57:50,054] INFO Partition [topic_22,2] on broker 1002: Expanding ISR for partition [topic_22,2] from 1002 to 1002,1003 (kafka.cluster.Partition)
[2016-11-28 19:57:50,055] INFO Partition [__consumer_offsets,18] on broker 1002: Expanding ISR for partition [__consumer_offsets,18] from 1002 to 1002,1003 (kafka.cluster.Partition)
[2016-11-28 19:57:50,057] INFO Partition [topic_23,0] on broker 1002: Expanding ISR for partition [topic_23,0] from 1002 to 1002,1003 (kafka.cluster.Partition)
[2016-11-28 19:57:50,058] INFO Partition [__consumer_offsets,45] on broker 1002: Expanding ISR for partition [__consumer_offsets,45] from 1002 to 1002,1003 (kafka.cluster.Partition)
[2016-11-28 19:57:50,256] INFO Successfully authenticated client: authenticationID=kafka_stage/node_1001@REALM_NAME; authorizationID=kafka_stage/node_1001@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:57:50,256] INFO Setting authorizedID: kafka_stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:57:50,257] INFO Partition [topic_3,0] on broker 1002: Expanding ISR for partition [topic_3,0] from 1002,1003 to 1002,1003,1001 (kafka.cluster.Partition)
[2016-11-28 19:57:50,259] INFO Partition [connect-offsets,13] on broker 1002: Expanding ISR for partition [connect-offsets,13] from 1002,1003 to 1002,1003,1001 (kafka.cluster.Partition)
[2016-11-28 19:57:50,261] INFO Partition [__consumer_offsets,36] on broker 1002: Expanding ISR for partition [__consumer_offsets,36] from 1002,1003 to 1002,1003,1001 (kafka.cluster.Partition)
[2016-11-28 19:57:50,262] INFO Partition [topic_22,2] on broker 1002: Expanding ISR for partition [topic_22,2] from 1002,1003 to 1002,1003,1001 (kafka.cluster.Partition)
[2016-11-28 19:57:50,263] INFO Partition [__consumer_offsets,18] on broker 1002: Expanding ISR for partition [__consumer_offsets,18] from 1002,1003 to 1002,1003,1001 (kafka.cluster.Partition)
[2016-11-28 19:57:50,265] INFO Partition [topic_23,0] on broker 1002: Expanding ISR for partition [topic_23,0] from 1002,1003 to 1002,1003,1001 (kafka.cluster.Partition)
[2016-11-28 19:57:50,266] INFO Partition [__consumer_offsets,45] on broker 1002: Expanding ISR for partition [__consumer_offsets,45] from 1002,1003 to 1002,1003,1001 (kafka.cluster.Partition)
[2016-11-28 19:57:56,132] INFO Rolled new log segment for 'topic_14-0' in 12 ms. (kafka.log.Log)
[2016-11-28 19:57:59,237] INFO Rolled new log segment for 'topic_12-1' in 12 ms. (kafka.log.Log)
[2016-11-28 19:58:05,342] INFO Rolled new log segment for 'topic_4-1' in 17 ms. (kafka.log.Log)
[2016-11-28 19:58:05,408] INFO Partition [topic_3,0] on broker 1002: Shrinking ISR for partition [topic_3,0] from 1002,1003,1001 to 1002 (kafka.cluster.Partition)
[2016-11-28 19:58:05,410] INFO Partition [__consumer_offsets,36] on broker 1002: Shrinking ISR for partition [__consumer_offsets,36] from 1002,1003,1001 to 1002 (kafka.cluster.Partition)
[2016-11-28 19:58:05,412] INFO Partition [topic_23,0] on broker 1002: Shrinking ISR for partition [topic_23,0] from 1002,1003,1001 to 1002 (kafka.cluster.Partition)
[2016-11-28 19:58:05,413] INFO Partition [__consumer_offsets,18] on broker 1002: Shrinking ISR for partition [__consumer_offsets,18] from 1002,1003,1001 to 1002 (kafka.cluster.Partition)
[2016-11-28 19:58:05,415] INFO Partition [connect-offsets,13] on broker 1002: Shrinking ISR for partition [connect-offsets,13] from 1002,1003,1001 to 1002 (kafka.cluster.Partition)
[2016-11-28 19:58:05,416] INFO Partition [topic_22,2] on broker 1002: Shrinking ISR for partition [topic_22,2] from 1002,1003,1001 to 1002 (kafka.cluster.Partition)
[2016-11-28 19:58:05,422] INFO Partition [__consumer_offsets,45] on broker 1002: Shrinking ISR for partition [__consumer_offsets,45] from 1002,1003,1001 to 1002 (kafka.cluster.Partition)
[2016-11-28 19:58:06,218] INFO Successfully authenticated client: authenticationID=consumer-12-stage@REALM_NAME; authorizationID=consumer-12-stage@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:06,218] INFO Setting authorizedID: consumer-12-stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:15,176] INFO Deleting segment 3227606 from log topic_9-1. (kafka.log.Log)
[2016-11-28 19:58:15,176] INFO Deleting segment 2421235 from log topic_39-1. (kafka.log.Log)
[2016-11-28 19:58:15,184] INFO Deleting segment 4652857 from log topic_16-1. (kafka.log.Log)
[2016-11-28 19:58:15,213] INFO Deleting segment 3227670 from log topic_9-0. (kafka.log.Log)
[2016-11-28 19:58:15,213] INFO Deleting segment 2470661 from log topic_35-1. (kafka.log.Log)
[2016-11-28 19:58:15,213] INFO Deleting segment 3487945 from log topic_5-1. (kafka.log.Log)
[2016-11-28 19:58:15,213] INFO Deleting segment 8560530 from log topic_4-2. (kafka.log.Log)
[2016-11-28 19:58:15,221] INFO Deleting segment 5026144 from log topic_28-0. (kafka.log.Log)
[2016-11-28 19:58:15,221] INFO Deleting segment 8560633 from log topic_4-0. (kafka.log.Log)
[2016-11-28 19:58:15,221] INFO Deleting segment 4652886 from log topic_16-0. (kafka.log.Log)
[2016-11-28 19:58:15,460] INFO Deleting index /data/kafka-logs/topic_9-1/00000000000003227606.index.deleted (kafka.log.OffsetIndex)
[2016-11-28 19:58:15,460] INFO Deleting index /data/kafka-logs/topic_16-1/00000000000004652857.index.deleted (kafka.log.OffsetIndex)
[2016-11-28 19:58:15,460] INFO Deleting index /data/kafka-logs/topic_5-1/00000000000003487945.index.deleted (kafka.log.OffsetIndex)
[2016-11-28 19:58:15,460] INFO Deleting index /data/kafka-logs/topic_16-1/00000000000004652857.timeindex.deleted (kafka.log.TimeIndex)
[2016-11-28 19:58:15,460] INFO Deleting index /data/kafka-logs/topic_5-1/00000000000003487945.timeindex.deleted (kafka.log.TimeIndex)
[2016-11-28 19:58:15,460] INFO Deleting index /data/kafka-logs/topic_35-1/00000000000002470661.index.deleted (kafka.log.OffsetIndex)
[2016-11-28 19:58:15,460] INFO Deleting index /data/kafka-logs/topic_35-1/00000000000002470661.timeindex.deleted (kafka.log.TimeIndex)
[2016-11-28 19:58:15,460] INFO Deleting index /data/kafka-logs/topic_9-1/00000000000003227606.timeindex.deleted (kafka.log.TimeIndex)
[2016-11-28 19:58:15,460] INFO Deleting index /data/kafka-logs/topic_39-1/00000000000002421235.index.deleted (kafka.log.OffsetIndex)
[2016-11-28 19:58:15,460] INFO Deleting index /data/kafka-logs/topic_39-1/00000000000002421235.timeindex.deleted (kafka.log.TimeIndex)
[2016-11-28 19:58:15,506] INFO Deleting index /data/kafka-logs/topic_9-0/00000000000003227670.index.deleted (kafka.log.OffsetIndex)
[2016-11-28 19:58:15,506] INFO Deleting index /data/kafka-logs/topic_9-0/00000000000003227670.timeindex.deleted (kafka.log.TimeIndex)
[2016-11-28 19:58:15,512] INFO Deleting index /data/kafka-logs/topic_16-0/00000000000004652886.index.deleted (kafka.log.OffsetIndex)
[2016-11-28 19:58:15,512] INFO Deleting index /data/kafka-logs/topic_16-0/00000000000004652886.timeindex.deleted (kafka.log.TimeIndex)
[2016-11-28 19:58:15,550] INFO Deleting index /data/kafka-logs/topic_28-0/00000000000005026144.index.deleted (kafka.log.OffsetIndex)
[2016-11-28 19:58:15,550] INFO Deleting index /data/kafka-logs/topic_28-0/00000000000005026144.timeindex.deleted (kafka.log.TimeIndex)
[2016-11-28 19:58:15,627] INFO Deleting index /data/kafka-logs/topic_4-2/00000000000008560530.index.deleted (kafka.log.OffsetIndex)
[2016-11-28 19:58:15,627] INFO Deleting index /data/kafka-logs/topic_4-2/00000000000008560530.timeindex.deleted (kafka.log.TimeIndex)
[2016-11-28 19:58:15,680] INFO Deleting index /data/kafka-logs/topic_4-0/00000000000008560633.index.deleted (kafka.log.OffsetIndex)
[2016-11-28 19:58:15,680] INFO Deleting index /data/kafka-logs/topic_4-0/00000000000008560633.timeindex.deleted (kafka.log.TimeIndex)
[2016-11-28 19:58:22,083] INFO Successfully authenticated client: authenticationID=kafka_stage/node_1003@REALM_NAME; authorizationID=kafka_stage/node_1003@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:22,083] INFO Setting authorizedID: kafka_stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:22,294] INFO Successfully authenticated client: authenticationID=kafka_stage/node_1001@REALM_NAME; authorizationID=kafka_stage/node_1001@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:22,294] INFO Setting authorizedID: kafka_stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:36,348] INFO Rolled new log segment for 'topic_35-0' in 6 ms. (kafka.log.Log)
[2016-11-28 19:58:36,408] INFO Successfully authenticated client: authenticationID=auth@REALM_NAME; authorizationID=auth@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:36,408] INFO Setting authorizedID: auth (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:36,512] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:36,512] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:36,698] INFO Successfully authenticated client: authenticationID=producer-49@REALM_NAME; authorizationID=producer-49@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:36,698] INFO Setting authorizedID: producer-49 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:36,817] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:36,817] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:36,881] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:36,881] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:36,917] INFO Successfully authenticated client: authenticationID=producer-471@REALM_NAME; authorizationID=producer-471@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:36,917] INFO Setting authorizedID: producer-471 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:37,126] INFO Successfully authenticated client: authenticationID=producer-49@REALM_NAME; authorizationID=producer-49@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:37,126] INFO Setting authorizedID: producer-49 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:37,130] INFO Successfully authenticated client: authenticationID=producer-472@REALM_NAME; authorizationID=producer-472@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:37,130] INFO Setting authorizedID: producer-472 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:37,185] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:37,185] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:37,190] INFO Successfully authenticated client: authenticationID=producer-49@REALM_NAME; authorizationID=producer-49@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:37,190] INFO Setting authorizedID: producer-49 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:37,561] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:37,561] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:37,791] INFO Successfully authenticated client: authenticationID=producer-15@REALM_NAME; authorizationID=producer-15@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:37,791] INFO Setting authorizedID: producer-15 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:37,792] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:37,792] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:37,809] INFO Successfully authenticated client: authenticationID=producer-473@REALM_NAME; authorizationID=producer-473@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:37,809] INFO Setting authorizedID: producer-473 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:37,902] INFO Successfully authenticated client: authenticationID=auth@REALM_NAME; authorizationID=auth@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:37,902] INFO Setting authorizedID: auth (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:37,942] INFO Successfully authenticated client: authenticationID=producer-24@REALM_NAME; authorizationID=producer-24@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:37,942] INFO Setting authorizedID: producer-24 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:38,031] INFO Successfully authenticated client: authenticationID=producer-473@REALM_NAME; authorizationID=producer-473@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:38,031] INFO Setting authorizedID: producer-473 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:38,506] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:38,506] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:38,634] INFO Successfully authenticated client: authenticationID=producer-473@REALM_NAME; authorizationID=producer-473@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:38,634] INFO Setting authorizedID: producer-473 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:38,665] INFO Successfully authenticated client: authenticationID=producer-15@REALM_NAME; authorizationID=producer-15@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:38,665] INFO Setting authorizedID: producer-15 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:38,900] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:38,900] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:38,995] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:38,995] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:39,056] INFO Successfully authenticated client: authenticationID=producer-49@REALM_NAME; authorizationID=producer-49@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:39,056] INFO Setting authorizedID: producer-49 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:39,145] INFO Successfully authenticated client: authenticationID=producer-472@REALM_NAME; authorizationID=producer-472@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:39,145] INFO Setting authorizedID: producer-472 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:39,246] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:39,247] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:39,259] INFO Successfully authenticated client: authenticationID=producer-471@REALM_NAME; authorizationID=producer-471@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:39,260] INFO Setting authorizedID: producer-471 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:39,304] INFO Successfully authenticated client: authenticationID=producer-24@REALM_NAME; authorizationID=producer-24@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:39,304] INFO Setting authorizedID: producer-24 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:39,589] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:39,589] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:40,010] INFO Successfully authenticated client: authenticationID=producer-49@REALM_NAME; authorizationID=producer-49@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:40,010] INFO Setting authorizedID: producer-49 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:40,072] INFO Rolled new log segment for 'topic_29-0' in 260 ms. (kafka.log.Log)
[2016-11-28 19:58:40,961] INFO Successfully authenticated client: authenticationID=producer-24@REALM_NAME; authorizationID=producer-24@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:40,961] INFO Setting authorizedID: producer-24 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:41,496] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:41,496] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:41,745] INFO Successfully authenticated client: authenticationID=producer-471@REALM_NAME; authorizationID=producer-471@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:41,745] INFO Setting authorizedID: producer-471 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:41,977] INFO Successfully authenticated client: authenticationID=producer-49@REALM_NAME; authorizationID=producer-49@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:41,977] INFO Setting authorizedID: producer-49 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:42,165] INFO Successfully authenticated client: authenticationID=producer-23@REALM_NAME; authorizationID=producer-23@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:42,165] INFO Setting authorizedID: producer-23 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:42,691] INFO Successfully authenticated client: authenticationID=topic_19@REALM_NAME; authorizationID=topic_19@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:42,691] INFO Setting authorizedID: topic_19 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:43,109] INFO Successfully authenticated client: authenticationID=kafka_stage/node_1003@REALM_NAME; authorizationID=kafka_stage/node_1003@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:43,109] INFO Setting authorizedID: kafka_stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:43,243] INFO Successfully authenticated client: authenticationID=topic_19@REALM_NAME; authorizationID=topic_19@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:43,243] INFO Setting authorizedID: topic_19 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:43,261] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:43,261] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:43,523] INFO Successfully authenticated client: authenticationID=topic_19@REALM_NAME; authorizationID=topic_19@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:43,523] INFO Setting authorizedID: topic_19 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:43,660] INFO Successfully authenticated client: authenticationID=topic_19@REALM_NAME; authorizationID=topic_19@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:43,660] INFO Setting authorizedID: topic_19 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:43,670] INFO Successfully authenticated client: authenticationID=topic_19@REALM_NAME; authorizationID=topic_19@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:43,670] INFO Setting authorizedID: topic_19 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:43,962] INFO Successfully authenticated client: authenticationID=producer-0@REALM_NAME; authorizationID=producer-0@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:43,962] INFO Setting authorizedID: producer-0 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:44,277] INFO Successfully authenticated client: authenticationID=topic_19@REALM_NAME; authorizationID=topic_19@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:44,277] INFO Setting authorizedID: topic_19 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:46,331] INFO Successfully authenticated client: authenticationID=producer-24@REALM_NAME; authorizationID=producer-24@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:46,331] INFO Setting authorizedID: producer-24 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:46,458] INFO Successfully authenticated client: authenticationID=producer-46@REALM_NAME; authorizationID=producer-46@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:46,458] INFO Setting authorizedID: producer-46 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:46,474] INFO Successfully authenticated client: authenticationID=consumer-12-stage@REALM_NAME; authorizationID=consumer-12-stage@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:46,474] INFO Setting authorizedID: consumer-12-stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:46,485] INFO Successfully authenticated client: authenticationID=consumer-12-stage@REALM_NAME; authorizationID=consumer-12-stage@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:46,485] INFO Setting authorizedID: consumer-12-stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:46,640] INFO Successfully authenticated client: authenticationID=consumer-12-stage@REALM_NAME; authorizationID=consumer-12-stage@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:46,640] INFO Setting authorizedID: consumer-12-stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:46,728] INFO Successfully authenticated client: authenticationID=consumer-12-stage@REALM_NAME; authorizationID=consumer-12-stage@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:46,728] INFO Setting authorizedID: consumer-12-stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:46,752] INFO Successfully authenticated client: authenticationID=producer-46@REALM_NAME; authorizationID=producer-46@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:46,752] INFO Setting authorizedID: producer-46 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:46,805] INFO Successfully authenticated client: authenticationID=consumer-12-stage@REALM_NAME; authorizationID=consumer-12-stage@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:46,805] INFO Setting authorizedID: consumer-12-stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:47,033] INFO Successfully authenticated client: authenticationID=consumer-12-stage@REALM_NAME; authorizationID=consumer-12-stage@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:47,033] INFO Setting authorizedID: consumer-12-stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:47,133] INFO Successfully authenticated client: authenticationID=topic_19@REALM_NAME; authorizationID=topic_19@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:47,133] INFO Setting authorizedID: topic_19 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:47,672] INFO Successfully authenticated client: authenticationID=producer-46@REALM_NAME; authorizationID=producer-46@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:47,672] INFO Setting authorizedID: producer-46 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:47,803] INFO Successfully authenticated client: authenticationID=producer-46@REALM_NAME; authorizationID=producer-46@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:47,803] INFO Setting authorizedID: producer-46 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:48,016] INFO Successfully authenticated client: authenticationID=consumer-12-stage@REALM_NAME; authorizationID=consumer-12-stage@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:48,016] INFO Setting authorizedID: consumer-12-stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:48,066] INFO Deleting segment 0 from log __consumer_offsets-13. (kafka.log.Log)
[2016-11-28 19:58:48,066] INFO Deleting segment 2062052 from log __consumer_offsets-13. (kafka.log.Log)
[2016-11-28 19:58:48,067] INFO Deleting index /data/kafka-logs/__consumer_offsets-13/00000000000000000000.index.deleted (kafka.log.OffsetIndex)
[2016-11-28 19:58:48,067] INFO Deleting index /data/kafka-logs/__consumer_offsets-13/00000000000000000000.timeindex.deleted (kafka.log.TimeIndex)
[2016-11-28 19:58:48,171] INFO Successfully authenticated client: authenticationID=consumer-12-stage@REALM_NAME; authorizationID=consumer-12-stage@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:48,171] INFO Setting authorizedID: consumer-12-stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:48,197] INFO Deleting index /data/kafka-logs/__consumer_offsets-13/00000000000002062052.index.deleted (kafka.log.OffsetIndex)
[2016-11-28 19:58:48,197] INFO Deleting index /data/kafka-logs/__consumer_offsets-13/00000000000002062052.timeindex.deleted (kafka.log.TimeIndex)
[2016-11-28 19:58:50,706] INFO Successfully authenticated client: authenticationID=kafka_stage@REALM_NAME; authorizationID=kafka_stage@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:50,706] INFO Setting authorizedID: kafka_stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:54,123] INFO Successfully authenticated client: authenticationID=kafka_stage/node_1003@REALM_NAME; authorizationID=kafka_stage/node_1003@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:54,123] INFO Setting authorizedID: kafka_stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:54,328] INFO Successfully authenticated client: authenticationID=kafka_stage/node_1001@REALM_NAME; authorizationID=kafka_stage/node_1001@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:54,328] INFO Setting authorizedID: kafka_stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:54,678] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:54,678] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:55,860] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:55,860] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:57,801] INFO Successfully authenticated client: authenticationID=kafka_stage@REALM_NAME; authorizationID=kafka_stage@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:58:57,801] INFO Setting authorizedID: kafka_stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:07,332] INFO Successfully authenticated client: authenticationID=producer-49@REALM_NAME; authorizationID=producer-49@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:07,332] INFO Setting authorizedID: producer-49 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:07,881] INFO Successfully authenticated client: authenticationID=producer-473@REALM_NAME; authorizationID=producer-473@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:07,881] INFO Setting authorizedID: producer-473 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:07,960] INFO Successfully authenticated client: authenticationID=producer-15@REALM_NAME; authorizationID=producer-15@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:07,960] INFO Setting authorizedID: producer-15 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:08,165] INFO Successfully authenticated client: authenticationID=producer-473@REALM_NAME; authorizationID=producer-473@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:08,166] INFO Setting authorizedID: producer-473 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:08,813] INFO Successfully authenticated client: authenticationID=producer-15@REALM_NAME; authorizationID=producer-15@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:08,813] INFO Setting authorizedID: producer-15 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:08,914] INFO Successfully authenticated client: authenticationID=auth@REALM_NAME; authorizationID=auth@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:08,914] INFO Setting authorizedID: auth (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:09,021] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:09,021] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:09,353] INFO Successfully authenticated client: authenticationID=producer-24@REALM_NAME; authorizationID=producer-24@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:09,353] INFO Setting authorizedID: producer-24 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:09,612] INFO Successfully authenticated client: authenticationID=producer-49@REALM_NAME; authorizationID=producer-49@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:09,612] INFO Setting authorizedID: producer-49 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:09,701] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:09,701] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:09,756] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:09,756] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:09,779] INFO Successfully authenticated client: authenticationID=producer-49@REALM_NAME; authorizationID=producer-49@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:09,779] INFO Setting authorizedID: producer-49 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:10,042] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:10,042] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:10,415] INFO Successfully authenticated client: authenticationID=auth@REALM_NAME; authorizationID=auth@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:10,415] INFO Setting authorizedID: auth (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:10,508] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:10,508] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:10,736] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:10,736] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:11,418] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:11,419] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:11,669] INFO Successfully authenticated client: authenticationID=producer-472@REALM_NAME; authorizationID=producer-472@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:11,669] INFO Setting authorizedID: producer-472 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:11,797] INFO Successfully authenticated client: authenticationID=producer-471@REALM_NAME; authorizationID=producer-471@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:11,797] INFO Setting authorizedID: producer-471 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:12,122] INFO Successfully authenticated client: authenticationID=producer-472@REALM_NAME; authorizationID=producer-472@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:12,122] INFO Setting authorizedID: producer-472 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:12,810] INFO Successfully authenticated client: authenticationID=topic_19@REALM_NAME; authorizationID=topic_19@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:12,810] INFO Setting authorizedID: topic_19 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:13,241] INFO Successfully authenticated client: authenticationID=kafka_stage/node_1003@REALM_NAME; authorizationID=kafka_stage/node_1003@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:13,241] INFO Setting authorizedID: kafka_stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:13,303] INFO Successfully authenticated client: authenticationID=topic_19@REALM_NAME; authorizationID=topic_19@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:13,303] INFO Setting authorizedID: topic_19 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:13,465] INFO Successfully authenticated client: authenticationID=producer-24@REALM_NAME; authorizationID=producer-24@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:13,465] INFO Setting authorizedID: producer-24 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:13,605] INFO Successfully authenticated client: authenticationID=topic_19@REALM_NAME; authorizationID=topic_19@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:13,605] INFO Setting authorizedID: topic_19 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:13,641] INFO Successfully authenticated client: authenticationID=producer-473@REALM_NAME; authorizationID=producer-473@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:13,641] INFO Setting authorizedID: producer-473 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:13,743] INFO Successfully authenticated client: authenticationID=topic_19@REALM_NAME; authorizationID=topic_19@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:13,743] INFO Setting authorizedID: topic_19 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:13,760] INFO Successfully authenticated client: authenticationID=topic_19@REALM_NAME; authorizationID=topic_19@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:13,760] INFO Setting authorizedID: topic_19 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:14,010] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:14,010] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:14,132] INFO Successfully authenticated client: authenticationID=producer-49@REALM_NAME; authorizationID=producer-49@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:14,132] INFO Setting authorizedID: producer-49 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:14,306] INFO Successfully authenticated client: authenticationID=producer-24@REALM_NAME; authorizationID=producer-24@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:14,306] INFO Setting authorizedID: producer-24 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:14,307] INFO Successfully authenticated client: authenticationID=producer-471@REALM_NAME; authorizationID=producer-471@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:14,307] INFO Setting authorizedID: producer-471 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:14,398] INFO Successfully authenticated client: authenticationID=topic_19@REALM_NAME; authorizationID=topic_19@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:14,399] INFO Setting authorizedID: topic_19 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:14,483] INFO Successfully authenticated client: authenticationID=producer-49@REALM_NAME; authorizationID=producer-49@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:14,484] INFO Setting authorizedID: producer-49 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:14,674] INFO Successfully authenticated client: authenticationID=producer-23@REALM_NAME; authorizationID=producer-23@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:14,674] INFO Setting authorizedID: producer-23 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:14,800] INFO Successfully authenticated client: authenticationID=kafka_stage@REALM_NAME; authorizationID=kafka_stage@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:14,800] INFO Setting authorizedID: kafka_stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:15,016] INFO Successfully authenticated client: authenticationID=producer-49@REALM_NAME; authorizationID=producer-49@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:15,016] INFO Setting authorizedID: producer-49 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:15,771] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:15,771] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:15,920] INFO Rolled new log segment for 'topic_33-0' in 9 ms. (kafka.log.Log)
[2016-11-28 19:59:16,889] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:16,889] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:19,601] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:19,601] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:20,069] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:20,069] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:21,344] INFO Successfully authenticated client: authenticationID=producer-24@REALM_NAME; authorizationID=producer-24@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:21,345] INFO Setting authorizedID: producer-24 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:21,596] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:21,596] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:22,121] INFO Successfully authenticated client: authenticationID=topic_19@REALM_NAME; authorizationID=topic_19@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:22,121] INFO Setting authorizedID: topic_19 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:23,967] INFO Successfully authenticated client: authenticationID=producer-0@REALM_NAME; authorizationID=producer-0@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:23,967] INFO Setting authorizedID: producer-0 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:24,036] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:24,036] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:26,159] INFO Successfully authenticated client: authenticationID=kafka_stage/node_1003@REALM_NAME; authorizationID=kafka_stage/node_1003@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:26,159] INFO Setting authorizedID: kafka_stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:26,340] INFO Successfully authenticated client: authenticationID=consumer-12-stage@REALM_NAME; authorizationID=consumer-12-stage@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:26,340] INFO Setting authorizedID: consumer-12-stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:26,365] INFO Successfully authenticated client: authenticationID=kafka_stage/node_1001@REALM_NAME; authorizationID=kafka_stage/node_1001@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:26,365] INFO Setting authorizedID: kafka_stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:26,565] INFO Successfully authenticated client: authenticationID=consumer-12-stage@REALM_NAME; authorizationID=consumer-12-stage@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:26,565] INFO Setting authorizedID: consumer-12-stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:26,566] INFO Successfully authenticated client: authenticationID=consumer-12-stage@REALM_NAME; authorizationID=consumer-12-stage@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:26,566] INFO Setting authorizedID: consumer-12-stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:26,595] INFO Successfully authenticated client: authenticationID=producer-46@REALM_NAME; authorizationID=producer-46@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:26,595] INFO Setting authorizedID: producer-46 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:26,798] INFO Successfully authenticated client: authenticationID=consumer-12-stage@REALM_NAME; authorizationID=consumer-12-stage@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:26,798] INFO Setting authorizedID: consumer-12-stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:26,866] INFO Successfully authenticated client: authenticationID=consumer-12-stage@REALM_NAME; authorizationID=consumer-12-stage@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:26,866] INFO Setting authorizedID: consumer-12-stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:26,879] INFO Successfully authenticated client: authenticationID=producer-46@REALM_NAME; authorizationID=producer-46@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:26,879] INFO Setting authorizedID: producer-46 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:26,894] INFO Successfully authenticated client: authenticationID=consumer-12-stage@REALM_NAME; authorizationID=consumer-12-stage@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:26,894] INFO Setting authorizedID: consumer-12-stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:26,985] INFO Successfully authenticated client: authenticationID=consumer-12-stage@REALM_NAME; authorizationID=consumer-12-stage@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:26,985] INFO Setting authorizedID: consumer-12-stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:27,188] INFO Successfully authenticated client: authenticationID=consumer-12-stage@REALM_NAME; authorizationID=consumer-12-stage@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:27,188] INFO Setting authorizedID: consumer-12-stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:27,856] INFO Successfully authenticated client: authenticationID=producer-46@REALM_NAME; authorizationID=producer-46@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:27,856] INFO Setting authorizedID: producer-46 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:27,955] INFO Successfully authenticated client: authenticationID=producer-46@REALM_NAME; authorizationID=producer-46@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:27,956] INFO Setting authorizedID: producer-46 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:28,135] INFO Successfully authenticated client: authenticationID=consumer-12-stage@REALM_NAME; authorizationID=consumer-12-stage@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:28,135] INFO Setting authorizedID: consumer-12-stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:28,325] INFO Successfully authenticated client: authenticationID=consumer-12-stage@REALM_NAME; authorizationID=consumer-12-stage@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:28,325] INFO Setting authorizedID: consumer-12-stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:28,510] INFO Successfully authenticated client: authenticationID=consumer-12-stage@REALM_NAME; authorizationID=consumer-12-stage@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:28,510] INFO Setting authorizedID: consumer-12-stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:28,721] INFO Successfully authenticated client: authenticationID=consumer-12-stage@REALM_NAME; authorizationID=consumer-12-stage@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:28,721] INFO Setting authorizedID: consumer-12-stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:29,693] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:29,693] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:30,743] INFO Successfully authenticated client: authenticationID=kafka_stage@REALM_NAME; authorizationID=kafka_stage@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:30,743] INFO Setting authorizedID: kafka_stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:30,874] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:30,874] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:36,654] INFO Successfully authenticated client: authenticationID=producer-23@REALM_NAME; authorizationID=producer-23@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:36,654] INFO Setting authorizedID: producer-23 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:37,595] INFO Successfully authenticated client: authenticationID=producer-49@REALM_NAME; authorizationID=producer-49@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:37,595] INFO Setting authorizedID: producer-49 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:37,853] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:37,853] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:37,973] INFO Successfully authenticated client: authenticationID=producer-473@REALM_NAME; authorizationID=producer-473@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:37,973] INFO Setting authorizedID: producer-473 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:38,105] INFO Successfully authenticated client: authenticationID=producer-15@REALM_NAME; authorizationID=producer-15@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:38,105] INFO Setting authorizedID: producer-15 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:38,254] INFO Successfully authenticated client: authenticationID=producer-473@REALM_NAME; authorizationID=producer-473@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:38,254] INFO Setting authorizedID: producer-473 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:38,981] INFO Successfully authenticated client: authenticationID=producer-15@REALM_NAME; authorizationID=producer-15@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:38,981] INFO Setting authorizedID: producer-15 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:39,366] INFO Successfully authenticated client: authenticationID=producer-471@REALM_NAME; authorizationID=producer-471@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:39,366] INFO Setting authorizedID: producer-471 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:39,388] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:39,388] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:40,188] INFO Successfully authenticated client: authenticationID=producer-49@REALM_NAME; authorizationID=producer-49@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:40,188] INFO Setting authorizedID: producer-49 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:40,574] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:40,574] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:41,351] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:41,352] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:41,428] INFO Successfully authenticated client: authenticationID=auth@REALM_NAME; authorizationID=auth@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:41,428] INFO Setting authorizedID: auth (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:41,539] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:41,539] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:41,565] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:41,565] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:42,218] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:42,218] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:42,936] INFO Successfully authenticated client: authenticationID=auth@REALM_NAME; authorizationID=auth@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:42,936] INFO Setting authorizedID: auth (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:42,954] INFO Successfully authenticated client: authenticationID=topic_19@REALM_NAME; authorizationID=topic_19@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:42,954] INFO Setting authorizedID: topic_19 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:42,974] INFO Successfully authenticated client: authenticationID=kafka_stage@REALM_NAME; authorizationID=kafka_stage@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:42,974] INFO Setting authorizedID: kafka_stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:43,369] INFO Rolled new log segment for 'topic_28-2' in 40 ms. (kafka.log.Log)
[2016-11-28 19:59:43,374] INFO Successfully authenticated client: authenticationID=kafka_stage/node_1003@REALM_NAME; authorizationID=kafka_stage/node_1003@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:43,374] INFO Setting authorizedID: kafka_stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:43,384] INFO Successfully authenticated client: authenticationID=topic_19@REALM_NAME; authorizationID=topic_19@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:43,384] INFO Setting authorizedID: topic_19 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:43,945] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:43,945] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:44,329] INFO Successfully authenticated client: authenticationID=producer-471@REALM_NAME; authorizationID=producer-471@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:44,329] INFO Setting authorizedID: producer-471 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:44,367] INFO Successfully authenticated client: authenticationID=producer-24@REALM_NAME; authorizationID=producer-24@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:44,367] INFO Setting authorizedID: producer-24 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:44,463] INFO Successfully authenticated client: authenticationID=topic_19@REALM_NAME; authorizationID=topic_19@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:44,463] INFO Setting authorizedID: topic_19 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:44,630] INFO Successfully authenticated client: authenticationID=producer-472@REALM_NAME; authorizationID=producer-472@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:44,630] INFO Setting authorizedID: producer-472 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:45,960] INFO Rolled new log segment for 'topic_33-1' in 17 ms. (kafka.log.Log)
[2016-11-28 19:59:46,700] INFO Successfully authenticated client: authenticationID=producer-472@REALM_NAME; authorizationID=producer-472@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:46,700] INFO Setting authorizedID: producer-472 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:46,818] INFO Successfully authenticated client: authenticationID=producer-24@REALM_NAME; authorizationID=producer-24@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:46,818] INFO Setting authorizedID: producer-24 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:46,988] INFO Successfully authenticated client: authenticationID=producer-49@REALM_NAME; authorizationID=producer-49@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:46,988] INFO Setting authorizedID: producer-49 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:47,068] INFO Successfully authenticated client: authenticationID=producer-49@REALM_NAME; authorizationID=producer-49@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:47,068] INFO Setting authorizedID: producer-49 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:47,510] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:47,510] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:47,526] INFO Successfully authenticated client: authenticationID=producer-49@REALM_NAME; authorizationID=producer-49@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:47,526] INFO Setting authorizedID: producer-49 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:48,289] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:48,289] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:48,645] INFO Successfully authenticated client: authenticationID=producer-473@REALM_NAME; authorizationID=producer-473@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:48,645] INFO Setting authorizedID: producer-473 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:49,025] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:49,025] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:49,317] INFO Successfully authenticated client: authenticationID=producer-471@REALM_NAME; authorizationID=producer-471@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:49,317] INFO Setting authorizedID: producer-471 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:49,400] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:49,400] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:49,703] INFO Successfully authenticated client: authenticationID=producer-23@REALM_NAME; authorizationID=producer-23@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:49,703] INFO Setting authorizedID: producer-23 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:51,694] INFO Successfully authenticated client: authenticationID=producer-49@REALM_NAME; authorizationID=producer-49@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:51,694] INFO Setting authorizedID: producer-49 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:53,450] INFO Successfully authenticated client: authenticationID=producer-24@REALM_NAME; authorizationID=producer-24@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:53,450] INFO Setting authorizedID: producer-24 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:53,858] INFO Successfully authenticated client: authenticationID=producer-24@REALM_NAME; authorizationID=producer-24@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:53,858] INFO Setting authorizedID: producer-24 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:56,592] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:56,592] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:56,610] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:56,610] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:56,801] INFO Rolled new log segment for 'topic_5-0' in 7 ms. (kafka.log.Log)
[2016-11-28 19:59:58,191] INFO Successfully authenticated client: authenticationID=kafka_stage/node_1003@REALM_NAME; authorizationID=kafka_stage/node_1003@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:58,191] INFO Setting authorizedID: kafka_stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:58,399] INFO Successfully authenticated client: authenticationID=kafka_stage/node_1001@REALM_NAME; authorizationID=kafka_stage/node_1001@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:58,399] INFO Setting authorizedID: kafka_stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:59,660] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:59,661] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 19:59:59,992] INFO Rolled new log segment for 'topic_37-0' in 102 ms. (kafka.log.Log)
[2016-11-28 20:00:00,074] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:00,074] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:01,345] INFO Rolled new log segment for 'topic_14-1' in 337 ms. (kafka.log.Log)
[2016-11-28 20:00:01,694] INFO Rolled new log segment for 'topic_17-2' in 149 ms. (kafka.log.Log)
[2016-11-28 20:00:02,206] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:02,206] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:03,391] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:03,391] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:06,452] INFO Successfully authenticated client: authenticationID=consumer-12-stage@REALM_NAME; authorizationID=consumer-12-stage@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:06,452] INFO Setting authorizedID: consumer-12-stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:06,717] INFO Successfully authenticated client: authenticationID=consumer-12-stage@REALM_NAME; authorizationID=consumer-12-stage@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:06,717] INFO Setting authorizedID: consumer-12-stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:06,718] INFO Successfully authenticated client: authenticationID=consumer-12-stage@REALM_NAME; authorizationID=consumer-12-stage@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:06,718] INFO Setting authorizedID: consumer-12-stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:06,804] INFO Successfully authenticated client: authenticationID=producer-46@REALM_NAME; authorizationID=producer-46@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:06,804] INFO Setting authorizedID: producer-46 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:06,896] INFO Successfully authenticated client: authenticationID=consumer-12-stage@REALM_NAME; authorizationID=consumer-12-stage@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:06,896] INFO Setting authorizedID: consumer-12-stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:06,998] INFO Successfully authenticated client: authenticationID=producer-46@REALM_NAME; authorizationID=producer-46@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:06,998] INFO Setting authorizedID: producer-46 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:07,065] INFO Successfully authenticated client: authenticationID=consumer-12-stage@REALM_NAME; authorizationID=consumer-12-stage@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:07,065] INFO Setting authorizedID: consumer-12-stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:07,127] INFO Successfully authenticated client: authenticationID=consumer-12-stage@REALM_NAME; authorizationID=consumer-12-stage@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:07,127] INFO Setting authorizedID: consumer-12-stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:07,352] INFO Successfully authenticated client: authenticationID=consumer-12-stage@REALM_NAME; authorizationID=consumer-12-stage@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:07,352] INFO Setting authorizedID: consumer-12-stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:07,353] INFO Successfully authenticated client: authenticationID=consumer-12-stage@REALM_NAME; authorizationID=consumer-12-stage@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:07,353] INFO Setting authorizedID: consumer-12-stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:07,970] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:07,970] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:07,990] INFO Successfully authenticated client: authenticationID=producer-49@REALM_NAME; authorizationID=producer-49@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:07,990] INFO Setting authorizedID: producer-49 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:08,006] INFO Successfully authenticated client: authenticationID=producer-46@REALM_NAME; authorizationID=producer-46@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:08,006] INFO Setting authorizedID: producer-46 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:08,055] INFO Successfully authenticated client: authenticationID=producer-46@REALM_NAME; authorizationID=producer-46@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:08,055] INFO Setting authorizedID: producer-46 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:08,125] INFO Successfully authenticated client: authenticationID=producer-473@REALM_NAME; authorizationID=producer-473@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:08,125] INFO Setting authorizedID: producer-473 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:08,265] INFO Successfully authenticated client: authenticationID=producer-15@REALM_NAME; authorizationID=producer-15@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:08,265] INFO Setting authorizedID: producer-15 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:08,295] INFO Successfully authenticated client: authenticationID=consumer-12-stage@REALM_NAME; authorizationID=consumer-12-stage@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:08,295] INFO Setting authorizedID: consumer-12-stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:08,365] INFO Successfully authenticated client: authenticationID=producer-473@REALM_NAME; authorizationID=producer-473@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:08,365] INFO Setting authorizedID: producer-473 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:08,432] INFO Successfully authenticated client: authenticationID=consumer-12-stage@REALM_NAME; authorizationID=consumer-12-stage@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:08,432] INFO Setting authorizedID: consumer-12-stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:08,982] INFO Successfully authenticated client: authenticationID=producer-0@REALM_NAME; authorizationID=producer-0@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:08,982] INFO Setting authorizedID: producer-0 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:09,053] INFO Successfully authenticated client: authenticationID=consumer-12-stage@REALM_NAME; authorizationID=consumer-12-stage@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:09,053] INFO Setting authorizedID: consumer-12-stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:09,104] INFO Successfully authenticated client: authenticationID=consumer-12-stage@REALM_NAME; authorizationID=consumer-12-stage@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:09,104] INFO Setting authorizedID: consumer-12-stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:09,148] INFO Successfully authenticated client: authenticationID=producer-15@REALM_NAME; authorizationID=producer-15@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:09,148] INFO Setting authorizedID: producer-15 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:09,206] INFO Successfully authenticated client: authenticationID=producer-23@REALM_NAME; authorizationID=producer-23@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:09,206] INFO Setting authorizedID: producer-23 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:09,420] INFO Successfully authenticated client: authenticationID=producer-471@REALM_NAME; authorizationID=producer-471@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:09,420] INFO Setting authorizedID: producer-471 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:09,494] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:09,495] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:10,604] INFO Successfully authenticated client: authenticationID=producer-49@REALM_NAME; authorizationID=producer-49@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:10,604] INFO Setting authorizedID: producer-49 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:11,580] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:11,580] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:12,481] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:12,481] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:12,508] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:12,508] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:12,588] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:12,588] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:13,508] INFO Successfully authenticated client: authenticationID=kafka_stage/node_1003@REALM_NAME; authorizationID=kafka_stage/node_1003@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:13,508] INFO Setting authorizedID: kafka_stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:13,940] INFO Successfully authenticated client: authenticationID=auth@REALM_NAME; authorizationID=auth@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:13,940] INFO Setting authorizedID: auth (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:14,055] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:14,055] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:14,746] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:14,746] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:15,450] INFO Successfully authenticated client: authenticationID=auth@REALM_NAME; authorizationID=auth@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:15,450] INFO Setting authorizedID: auth (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:15,902] INFO Successfully authenticated client: authenticationID=kafka_stage@REALM_NAME; authorizationID=kafka_stage@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:15,902] INFO Setting authorizedID: kafka_stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:16,454] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:16,454] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:16,873] INFO Successfully authenticated client: authenticationID=producer-24@REALM_NAME; authorizationID=producer-24@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:16,873] INFO Setting authorizedID: producer-24 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:17,581] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:17,581] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:19,228] INFO Successfully authenticated client: authenticationID=producer-472@REALM_NAME; authorizationID=producer-472@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:19,228] INFO Setting authorizedID: producer-472 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:19,323] INFO Successfully authenticated client: authenticationID=producer-24@REALM_NAME; authorizationID=producer-24@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:19,323] INFO Setting authorizedID: producer-24 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:19,370] INFO Successfully authenticated client: authenticationID=producer-471@REALM_NAME; authorizationID=producer-471@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:19,370] INFO Setting authorizedID: producer-471 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:19,468] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:19,468] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:19,634] INFO Successfully authenticated client: authenticationID=producer-472@REALM_NAME; authorizationID=producer-472@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:19,634] INFO Setting authorizedID: producer-472 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:21,995] INFO Successfully authenticated client: authenticationID=producer-49@REALM_NAME; authorizationID=producer-49@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:21,995] INFO Setting authorizedID: producer-49 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:22,223] INFO Successfully authenticated client: authenticationID=producer-23@REALM_NAME; authorizationID=producer-23@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:22,223] INFO Setting authorizedID: producer-23 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:23,298] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:23,298] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:23,526] INFO Successfully authenticated client: authenticationID=producer-24@REALM_NAME; authorizationID=producer-24@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:23,526] INFO Setting authorizedID: producer-24 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:23,651] INFO Successfully authenticated client: authenticationID=producer-473@REALM_NAME; authorizationID=producer-473@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:23,651] INFO Setting authorizedID: producer-473 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:24,048] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:24,048] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:24,331] INFO Successfully authenticated client: authenticationID=producer-471@REALM_NAME; authorizationID=producer-471@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:24,331] INFO Setting authorizedID: producer-471 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:26,370] INFO Successfully authenticated client: authenticationID=producer-24@REALM_NAME; authorizationID=producer-24@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:26,370] INFO Setting authorizedID: producer-24 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:26,769] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:26,769] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:28,131] INFO Successfully authenticated client: authenticationID=kafka_stage@REALM_NAME; authorizationID=kafka_stage@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:28,131] INFO Setting authorizedID: kafka_stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:29,575] INFO Successfully authenticated client: authenticationID=producer-49@REALM_NAME; authorizationID=producer-49@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:29,575] INFO Setting authorizedID: producer-49 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:30,226] INFO Successfully authenticated client: authenticationID=kafka_stage/node_1003@REALM_NAME; authorizationID=kafka_stage/node_1003@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:30,226] INFO Setting authorizedID: kafka_stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:30,434] INFO Successfully authenticated client: authenticationID=kafka_stage/node_1001@REALM_NAME; authorizationID=kafka_stage/node_1001@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:30,434] INFO Setting authorizedID: kafka_stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:31,617] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:31,617] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:33,027] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:33,027] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:37,218] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:37,218] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:38,187] INFO Successfully authenticated client: authenticationID=producer-473@REALM_NAME; authorizationID=producer-473@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:38,187] INFO Setting authorizedID: producer-473 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:38,227] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:38,227] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:38,398] INFO Successfully authenticated client: authenticationID=producer-49@REALM_NAME; authorizationID=producer-49@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:38,398] INFO Setting authorizedID: producer-49 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:38,444] INFO Successfully authenticated client: authenticationID=producer-15@REALM_NAME; authorizationID=producer-15@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:38,444] INFO Setting authorizedID: producer-15 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:38,509] INFO Successfully authenticated client: authenticationID=producer-473@REALM_NAME; authorizationID=producer-473@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:38,509] INFO Setting authorizedID: producer-473 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:39,293] INFO Successfully authenticated client: authenticationID=producer-15@REALM_NAME; authorizationID=producer-15@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:39,293] INFO Setting authorizedID: producer-15 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:39,964] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:39,964] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:41,727] INFO Successfully authenticated client: authenticationID=producer-23@REALM_NAME; authorizationID=producer-23@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:41,727] INFO Setting authorizedID: producer-23 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:42,626] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:42,626] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:43,402] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:43,402] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:43,579] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:43,579] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:43,638] INFO Successfully authenticated client: authenticationID=kafka_stage/node_1003@REALM_NAME; authorizationID=kafka_stage/node_1003@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:43,638] INFO Setting authorizedID: kafka_stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:43,663] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:43,663] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:44,235] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:44,235] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:44,426] INFO Successfully authenticated client: authenticationID=producer-471@REALM_NAME; authorizationID=producer-471@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:44,426] INFO Setting authorizedID: producer-471 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:44,828] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:44,828] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:44,964] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:44,964] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:46,463] INFO Successfully authenticated client: authenticationID=auth@REALM_NAME; authorizationID=auth@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:46,463] INFO Setting authorizedID: auth (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:46,660] INFO Successfully authenticated client: authenticationID=consumer-12-stage@REALM_NAME; authorizationID=consumer-12-stage@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:46,660] INFO Setting authorizedID: consumer-12-stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:46,853] INFO Successfully authenticated client: authenticationID=consumer-12-stage@REALM_NAME; authorizationID=consumer-12-stage@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:46,853] INFO Setting authorizedID: consumer-12-stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:46,860] INFO Successfully authenticated client: authenticationID=consumer-12-stage@REALM_NAME; authorizationID=consumer-12-stage@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:46,860] INFO Setting authorizedID: consumer-12-stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:46,911] INFO Successfully authenticated client: authenticationID=producer-46@REALM_NAME; authorizationID=producer-46@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:46,911] INFO Setting authorizedID: producer-46 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:46,989] INFO Successfully authenticated client: authenticationID=consumer-12-stage@REALM_NAME; authorizationID=consumer-12-stage@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:46,990] INFO Setting authorizedID: consumer-12-stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:47,114] INFO Successfully authenticated client: authenticationID=producer-46@REALM_NAME; authorizationID=producer-46@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:47,114] INFO Setting authorizedID: producer-46 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:47,252] INFO Successfully authenticated client: authenticationID=consumer-12-stage@REALM_NAME; authorizationID=consumer-12-stage@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:47,252] INFO Setting authorizedID: consumer-12-stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:47,301] INFO Successfully authenticated client: authenticationID=consumer-12-stage@REALM_NAME; authorizationID=consumer-12-stage@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:47,301] INFO Setting authorizedID: consumer-12-stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:47,523] INFO Successfully authenticated client: authenticationID=consumer-12-stage@REALM_NAME; authorizationID=consumer-12-stage@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:47,523] INFO Setting authorizedID: consumer-12-stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:47,575] INFO Successfully authenticated client: authenticationID=consumer-12-stage@REALM_NAME; authorizationID=consumer-12-stage@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:47,575] INFO Setting authorizedID: consumer-12-stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:47,975] INFO Successfully authenticated client: authenticationID=auth@REALM_NAME; authorizationID=auth@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:47,975] INFO Setting authorizedID: auth (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:48,154] INFO Successfully authenticated client: authenticationID=producer-46@REALM_NAME; authorizationID=producer-46@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:48,154] INFO Setting authorizedID: producer-46 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:48,162] INFO Successfully authenticated client: authenticationID=producer-46@REALM_NAME; authorizationID=producer-46@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:48,162] INFO Setting authorizedID: producer-46 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:48,479] INFO Successfully authenticated client: authenticationID=consumer-12-stage@REALM_NAME; authorizationID=consumer-12-stage@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:48,479] INFO Setting authorizedID: consumer-12-stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:48,649] INFO Successfully authenticated client: authenticationID=consumer-12-stage@REALM_NAME; authorizationID=consumer-12-stage@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:48,649] INFO Setting authorizedID: consumer-12-stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:48,971] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:48,971] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:49,276] INFO Successfully authenticated client: authenticationID=consumer-12-stage@REALM_NAME; authorizationID=consumer-12-stage@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:49,276] INFO Setting authorizedID: consumer-12-stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:49,310] INFO Successfully authenticated client: authenticationID=consumer-12-stage@REALM_NAME; authorizationID=consumer-12-stage@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:49,310] INFO Setting authorizedID: consumer-12-stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:49,397] INFO Successfully authenticated client: authenticationID=producer-24@REALM_NAME; authorizationID=producer-24@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:49,397] INFO Setting authorizedID: producer-24 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:49,629] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:49,629] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:50,126] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:50,126] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:51,761] INFO Successfully authenticated client: authenticationID=producer-472@REALM_NAME; authorizationID=producer-472@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:51,761] INFO Setting authorizedID: producer-472 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:51,879] INFO Successfully authenticated client: authenticationID=producer-24@REALM_NAME; authorizationID=producer-24@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:51,879] INFO Setting authorizedID: producer-24 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:51,910] INFO Successfully authenticated client: authenticationID=producer-471@REALM_NAME; authorizationID=producer-471@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:51,910] INFO Setting authorizedID: producer-471 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:52,142] INFO Successfully authenticated client: authenticationID=producer-472@REALM_NAME; authorizationID=producer-472@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:52,142] INFO Setting authorizedID: producer-472 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:53,985] INFO Successfully authenticated client: authenticationID=producer-0@REALM_NAME; authorizationID=producer-0@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:53,985] INFO Setting authorizedID: producer-0 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:54,747] INFO Successfully authenticated client: authenticationID=producer-23@REALM_NAME; authorizationID=producer-23@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:54,747] INFO Setting authorizedID: producer-23 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:55,811] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:55,811] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:56,155] INFO Successfully authenticated client: authenticationID=producer-473@REALM_NAME; authorizationID=producer-473@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:56,155] INFO Setting authorizedID: producer-473 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:56,994] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:56,994] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:56,999] INFO Successfully authenticated client: authenticationID=producer-49@REALM_NAME; authorizationID=producer-49@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:56,999] INFO Setting authorizedID: producer-49 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:59,065] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:59,065] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:59,342] INFO Successfully authenticated client: authenticationID=producer-471@REALM_NAME; authorizationID=producer-471@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:59,342] INFO Setting authorizedID: producer-471 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:00:59,378] INFO Rolled new log segment for 'topic_18-0' in 1 ms. (kafka.log.Log)
[2016-11-28 20:01:01,098] INFO Successfully authenticated client: authenticationID=kafka_stage@REALM_NAME; authorizationID=kafka_stage@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:01:01,098] INFO Setting authorizedID: kafka_stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:01:02,259] INFO Successfully authenticated client: authenticationID=kafka_stage/node_1003@REALM_NAME; authorizationID=kafka_stage/node_1003@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:01:02,259] INFO Setting authorizedID: kafka_stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:01:02,327] INFO Rolled new log segment for 'topic_29-1' in 1 ms. (kafka.log.Log)
[2016-11-28 20:01:02,455] INFO Successfully authenticated client: authenticationID=kafka_stage/node_1001@REALM_NAME; authorizationID=kafka_stage/node_1001@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:01:02,455] INFO Setting authorizedID: kafka_stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:01:05,337] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:01:05,337] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:01:08,263] INFO Successfully authenticated client: authenticationID=producer-473@REALM_NAME; authorizationID=producer-473@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:01:08,263] INFO Setting authorizedID: producer-473 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:01:08,461] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:01:08,461] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:01:08,584] INFO Successfully authenticated client: authenticationID=producer-15@REALM_NAME; authorizationID=producer-15@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:01:08,584] INFO Setting authorizedID: producer-15 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:01:08,595] INFO Successfully authenticated client: authenticationID=producer-473@REALM_NAME; authorizationID=producer-473@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:01:08,595] INFO Setting authorizedID: producer-473 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:01:08,808] INFO Successfully authenticated client: authenticationID=producer-49@REALM_NAME; authorizationID=producer-49@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:01:08,808] INFO Setting authorizedID: producer-49 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:01:08,831] INFO Successfully authenticated client: authenticationID=producer-24@REALM_NAME; authorizationID=producer-24@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:01:08,831] INFO Setting authorizedID: producer-24 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:01:09,451] INFO Successfully authenticated client: authenticationID=producer-15@REALM_NAME; authorizationID=producer-15@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:01:09,452] INFO Setting authorizedID: producer-15 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:01:09,631] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:01:09,631] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:01:09,732] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:01:09,732] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:01:10,105] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:01:10,106] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:01:10,160] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:01:10,160] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:01:10,990] INFO Successfully authenticated client: authenticationID=producer-49@REALM_NAME; authorizationID=producer-49@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:01:10,990] INFO Setting authorizedID: producer-49 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:01:10,990] INFO Successfully authenticated client: authenticationID=producer-49@REALM_NAME; authorizationID=producer-49@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:01:10,990] INFO Setting authorizedID: producer-49 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:01:11,573] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:01:11,573] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:01:12,083] INFO Successfully authenticated client: authenticationID=producer-49@REALM_NAME; authorizationID=producer-49@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:01:12,083] INFO Setting authorizedID: producer-49 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:01:13,288] INFO Successfully authenticated client: authenticationID=kafka_stage@REALM_NAME; authorizationID=kafka_stage@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:01:13,288] INFO Setting authorizedID: kafka_stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:01:13,488] INFO Successfully authenticated client: authenticationID=producer-49@REALM_NAME; authorizationID=producer-49@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:01:13,488] INFO Setting authorizedID: producer-49 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:01:13,623] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:01:13,623] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:01:13,759] INFO Successfully authenticated client: authenticationID=kafka_stage/node_1003@REALM_NAME; authorizationID=kafka_stage/node_1003@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:01:13,759] INFO Setting authorizedID: kafka_stage (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:01:14,639] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:01:14,639] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:01:15,003] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:01:15,003] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:01:16,539] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:01:16,539] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:01:16,747] INFO Successfully authenticated client: authenticationID=producer-23@REALM_NAME; authorizationID=producer-23@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:01:16,747] INFO Setting authorizedID: producer-23 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:01:17,345] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:01:17,345] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:01:17,480] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:01:17,480] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:01:18,416] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:01:18,416] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:01:18,975] INFO Successfully authenticated client: authenticationID=auth@REALM_NAME; authorizationID=auth@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:01:18,975] INFO Setting authorizedID: auth (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:01:19,430] INFO Successfully authenticated client: authenticationID=producer-471@REALM_NAME; authorizationID=producer-471@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:01:19,430] INFO Setting authorizedID: producer-471 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:01:20,200] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:01:20,200] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:01:20,492] INFO Successfully authenticated client: authenticationID=auth@REALM_NAME; authorizationID=auth@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:01:20,492] INFO Setting authorizedID: auth (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:01:21,488] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:01:21,488] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:01:21,687] INFO Successfully authenticated client: authenticationID=producer-48@REALM_NAME; authorizationID=producer-48@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:01:21,687] INFO Setting authorizedID: producer-48 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:01:21,913] INFO Successfully authenticated client: authenticationID=producer-24@REALM_NAME; authorizationID=producer-24@REALM_NAME. (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:01:21,913] INFO Setting authorizedID: producer-24 (org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler)
[2016-11-28 20:02:15,162] INFO Scheduling log segment 1412162 for log topic_18-1 for deletion. (kafka.log.Log)
[2016-11-28 20:02:15,163] INFO Scheduling log segment 2747868 for log topic_12-1 for deletion. (kafka.log.Log)
[2016-11-28 20:02:15,163] INFO Scheduling log segment 2470743 for log topic_35-0 for deletion. (kafka.log.Log)
[2016-11-28 20:02:15,163] INFO Scheduling log segment 3747975 for log topic_14-1 for deletion. (kafka.log.Log)
[2016-11-28 20:02:15,163] INFO Scheduling log segment 3488232 for log topic_5-0 for deletion. (kafka.log.Log)
[2016-11-28 20:02:15,163] INFO Scheduling log segment 3210714 for log topic_17-1 for deletion. (kafka.log.Log)
[2016-11-28 20:02:15,167] INFO Scheduling log segment 1513571 for log topic_29-0 for deletion. (kafka.log.Log)
[2016-11-28 20:02:15,168] INFO Scheduling log segment 5026324 for log topic_28-2 for deletion. (kafka.log.Log)
[2016-11-28 20:02:15,168] INFO Scheduling log segment 2421349 for log topic_39-0 for deletion. (kafka.log.Log)
[2016-11-28 20:02:15,179] INFO Scheduling log segment 2851361 for log topic_33-0 for deletion. (kafka.log.Log)
[2016-11-28 20:02:15,179] INFO Scheduling log segment 10869635 for log topic_36-0 for deletion. (kafka.log.Log)
[2016-11-28 20:02:15,179] INFO Scheduling log segment 3210316 for log topic_17-2 for deletion. (kafka.log.Log)
[2016-11-28 20:02:15,179] INFO Scheduling log segment 3769711 for log topic_37-1 for deletion. (kafka.log.Log)
[2016-11-28 20:02:15,179] INFO Scheduling log segment 3210378 for log topic_17-0 for deletion. (kafka.log.Log)
[2016-11-28 20:02:15,179] INFO Scheduling log segment 1513725 for log topic_29-1 for deletion. (kafka.log.Log)
[2016-11-28 20:02:15,180] INFO Scheduling log segment 3748057 for log topic_14-0 for deletion. (kafka.log.Log)
[2016-11-28 20:02:15,180] INFO Scheduling log segment 5026211 for log topic_28-1 for deletion. (kafka.log.Log)
[2016-11-28 20:02:15,180] INFO Scheduling log segment 8561189 for log topic_4-1 for deletion. (kafka.log.Log)
[2016-11-28 20:02:15,180] INFO Scheduling log segment 1412161 for log topic_18-0 for deletion. (kafka.log.Log)
[2016-11-28 20:02:15,180] INFO Scheduling log segment 2747835 for log topic_12-0 for deletion. (kafka.log.Log)
[2016-11-28 20:02:15,180] INFO Scheduling log segment 2851394 for log topic_33-1 for deletion. (kafka.log.Log)
[2016-11-28 20:02:15,180] INFO Scheduling log segment 3770120 for log topic_37-0 for deletion. (kafka.log.Log)
[2016-11-28 20:03:15,163] INFO Deleting segment 1412162 from log topic_18-1. (kafka.log.Log)
[2016-11-28 20:03:15,163] INFO Deleting segment 2747868 from log topic_12-1. (kafka.log.Log)
[2016-11-28 20:03:15,163] INFO Deleting segment 3488232 from log topic_5-0. (kafka.log.Log)
[2016-11-28 20:03:15,163] INFO Deleting segment 3747975 from log topic_14-1. (kafka.log.Log)
[2016-11-28 20:03:15,163] INFO Deleting segment 2470743 from log topic_35-0. (kafka.log.Log)
[2016-11-28 20:03:15,167] INFO Deleting segment 3210714 from log topic_17-1. (kafka.log.Log)
[2016-11-28 20:03:15,430] INFO Deleting index /data/kafka-logs/topic_12-1/00000000000002747868.index.deleted (kafka.log.OffsetIndex)
[2016-11-28 20:03:15,320] INFO Deleting index /data/kafka-logs/topic_14-1/00000000000003747975.index.deleted (kafka.log.OffsetIndex)
[2016-11-28 20:03:15,336] INFO Deleting index /data/kafka-logs/topic_5-0/00000000000003488232.index.deleted (kafka.log.OffsetIndex)
[2016-11-28 20:03:15,168] INFO Deleting segment 1513571 from log topic_29-0. (kafka.log.Log)
[2016-11-28 20:03:15,168] INFO Deleting segment 5026324 from log topic_28-2. (kafka.log.Log)
[2016-11-28 20:03:15,179] INFO Deleting segment 2421349 from log topic_39-0. (kafka.log.Log)
[2016-11-28 20:03:15,433] INFO Deleting index /data/kafka-logs/topic_14-1/00000000000003747975.timeindex.deleted (kafka.log.TimeIndex)
[2016-11-28 20:03:15,252] INFO Deleting index /data/kafka-logs/topic_35-0/00000000000002470743.index.deleted (kafka.log.OffsetIndex)
[2016-11-28 20:03:15,433] INFO Deleting segment 2851361 from log topic_33-0. (kafka.log.Log)
[2016-11-28 20:03:15,433] INFO Deleting index /data/kafka-logs/topic_35-0/00000000000002470743.timeindex.deleted (kafka.log.TimeIndex)
[2016-11-28 20:03:15,433] INFO Deleting segment 10869635 from log topic_36-0. (kafka.log.Log)
[2016-11-28 20:03:15,433] INFO Deleting index /data/kafka-logs/topic_12-1/00000000000002747868.timeindex.deleted (kafka.log.TimeIndex)
[2016-11-28 20:03:15,268] INFO Deleting index /data/kafka-logs/topic_18-1/00000000000001412162.index.deleted (kafka.log.OffsetIndex)
[2016-11-28 20:03:15,434] INFO Deleting index /data/kafka-logs/topic_18-1/00000000000001412162.timeindex.deleted (kafka.log.TimeIndex)
[2016-11-28 20:03:15,434] INFO Deleting segment 3210316 from log topic_17-2. (kafka.log.Log)
[2016-11-28 20:03:15,434] INFO Deleting segment 3769711 from log topic_37-1. (kafka.log.Log)
[2016-11-28 20:03:15,433] INFO Deleting index /data/kafka-logs/topic_5-0/00000000000003488232.timeindex.deleted (kafka.log.TimeIndex)
[2016-11-28 20:03:15,434] INFO Deleting segment 3210378 from log topic_17-0. (kafka.log.Log)
[2016-11-28 20:03:15,476] INFO Deleting segment 1513725 from log topic_29-1. (kafka.log.Log)
[2016-11-28 20:03:15,566] INFO Deleting index /data/kafka-logs/topic_29-1/00000000000001513725.index.deleted (kafka.log.OffsetIndex)
[2016-11-28 20:03:15,566] INFO Deleting index /data/kafka-logs/topic_29-1/00000000000001513725.timeindex.deleted (kafka.log.TimeIndex)
[2016-11-28 20:03:15,566] INFO Deleting segment 3748057 from log topic_14-0. (kafka.log.Log)
[2016-11-28 20:03:15,569] INFO Deleting index /data/kafka-logs/topic_29-0/00000000000001513571.index.deleted (kafka.log.OffsetIndex)
[2016-11-28 20:03:15,569] INFO Deleting index /data/kafka-logs/topic_29-0/00000000000001513571.timeindex.deleted (kafka.log.TimeIndex)
[2016-11-28 20:03:15,569] INFO Deleting segment 5026211 from log topic_28-1. (kafka.log.Log)
[2016-11-28 20:03:15,593] INFO Deleting index /data/kafka-logs/topic_17-2/00000000000003210316.index.deleted (kafka.log.OffsetIndex)
[2016-11-28 20:03:15,593] INFO Deleting index /data/kafka-logs/topic_17-2/00000000000003210316.timeindex.deleted (kafka.log.TimeIndex)
[2016-11-28 20:03:15,593] INFO Deleting segment 8561189 from log topic_4-1. (kafka.log.Log)
[2016-11-28 20:03:15,627] INFO Deleting index /data/kafka-logs/topic_39-0/00000000000002421349.index.deleted (kafka.log.OffsetIndex)
[2016-11-28 20:03:15,627] INFO Deleting index /data/kafka-logs/topic_39-0/00000000000002421349.timeindex.deleted (kafka.log.TimeIndex)
[2016-11-28 20:03:15,627] INFO Deleting segment 1412161 from log topic_18-0. (kafka.log.Log)
[2016-11-28 20:03:15,658] INFO Deleting index /data/kafka-logs/topic_17-1/00000000000003210714.index.deleted (kafka.log.OffsetIndex)
[2016-11-28 20:03:15,658] INFO Deleting index /data/kafka-logs/topic_17-0/00000000000003210378.index.deleted (kafka.log.OffsetIndex)
[2016-11-28 20:03:15,658] INFO Deleting index /data/kafka-logs/topic_17-1/00000000000003210714.timeindex.deleted (kafka.log.TimeIndex)
[2016-11-28 20:03:15,658] INFO Deleting index /data/kafka-logs/topic_17-0/00000000000003210378.timeindex.deleted (kafka.log.TimeIndex)
[2016-11-28 20:03:15,658] INFO Deleting segment 2747835 from log topic_12-0. (kafka.log.Log)
[2016-11-28 20:03:15,658] INFO Deleting segment 2851394 from log topic_33-1. (kafka.log.Log)
[2016-11-28 20:03:15,683] INFO Deleting index /data/kafka-logs/topic_37-1/00000000000003769711.index.deleted (kafka.log.OffsetIndex)
[2016-11-28 20:03:15,683] INFO Deleting index /data/kafka-logs/topic_37-1/00000000000003769711.timeindex.deleted (kafka.log.TimeIndex)
[2016-11-28 20:03:15,683] INFO Deleting segment 3770120 from log topic_37-0. (kafka.log.Log)
[2016-11-28 20:03:15,724] INFO Deleting index /data/kafka-logs/topic_18-0/00000000000001412161.index.deleted (kafka.log.OffsetIndex)
[2016-11-28 20:03:15,724] INFO Deleting index /data/kafka-logs/topic_18-0/00000000000001412161.timeindex.deleted (kafka.log.TimeIndex)
[2016-11-28 20:03:15,769] INFO Deleting index /data/kafka-logs/topic_12-0/00000000000002747835.index.deleted (kafka.log.OffsetIndex)
[2016-11-28 20:03:15,769] INFO Deleting index /data/kafka-logs/topic_12-0/00000000000002747835.timeindex.deleted (kafka.log.TimeIndex)
[2016-11-28 20:03:15,778] INFO Deleting index /data/kafka-logs/topic_33-0/00000000000002851361.index.deleted (kafka.log.OffsetIndex)
[2016-11-28 20:03:15,778] INFO Deleting index /data/kafka-logs/topic_33-0/00000000000002851361.timeindex.deleted (kafka.log.TimeIndex)
[2016-11-28 20:03:15,803] INFO Deleting index /data/kafka-logs/topic_36-0/00000000000010869635.index.deleted (kafka.log.OffsetIndex)
[2016-11-28 20:03:15,803] INFO Deleting index /data/kafka-logs/topic_36-0/00000000000010869635.timeindex.deleted (kafka.log.TimeIndex)
[2016-11-28 20:03:15,827] INFO Deleting index /data/kafka-logs/topic_14-0/00000000000003748057.index.deleted (kafka.log.OffsetIndex)
[2016-11-28 20:03:15,827] INFO Deleting index /data/kafka-logs/topic_14-0/00000000000003748057.timeindex.deleted (kafka.log.TimeIndex)
[2016-11-28 20:03:15,839] INFO Deleting index /data/kafka-logs/topic_33-1/00000000000002851394.index.deleted (kafka.log.OffsetIndex)
[2016-11-28 20:03:15,839] INFO Deleting index /data/kafka-logs/topic_33-1/00000000000002851394.timeindex.deleted (kafka.log.TimeIndex)
[2016-11-28 20:03:15,847] INFO Deleting index /data/kafka-logs/topic_37-0/00000000000003770120.index.deleted (kafka.log.OffsetIndex)
[2016-11-28 20:03:15,847] INFO Deleting index /data/kafka-logs/topic_37-0/00000000000003770120.timeindex.deleted (kafka.log.TimeIndex)
[2016-11-28 20:03:15,877] INFO Deleting index /data/kafka-logs/topic_28-1/00000000000005026211.index.deleted (kafka.log.OffsetIndex)
[2016-11-28 20:03:15,877] INFO Deleting index /data/kafka-logs/topic_28-1/00000000000005026211.timeindex.deleted (kafka.log.TimeIndex)
[2016-11-28 20:03:15,880] INFO Deleting index /data/kafka-logs/topic_4-1/00000000000008561189.index.deleted (kafka.log.OffsetIndex)
[2016-11-28 20:03:15,880] INFO Deleting index /data/kafka-logs/topic_4-1/00000000000008561189.timeindex.deleted (kafka.log.TimeIndex)
[2016-11-28 20:03:15,882] INFO Deleting index /data/kafka-logs/topic_28-2/00000000000005026324.index.deleted (kafka.log.OffsetIndex)
[2016-11-28 20:03:15,882] INFO Deleting index /data/kafka-logs/topic_28-2/00000000000005026324.timeindex.deleted (kafka.log.TimeIndex)
[2016-11-28 20:09:15,726] INFO Rolled new log segment for 'topic_43-0' in 1 ms. (kafka.log.Log)
[2016-11-28 20:22:12,616] INFO Rolled new log segment for '__consumer_offsets-35' in 12 ms. (kafka.log.Log)
[2016-11-28 20:23:18,274] INFO Deleting segment 0 from log __consumer_offsets-35. (kafka.log.Log)
[2016-11-28 20:23:18,274] INFO Deleting segment 76989 from log __consumer_offsets-35. (kafka.log.Log)
[2016-11-28 20:23:18,275] INFO Deleting index /data/kafka-logs/__consumer_offsets-35/00000000000000000000.index.deleted (kafka.log.OffsetIndex)
[2016-11-28 20:23:18,275] INFO Deleting index /data/kafka-logs/__consumer_offsets-35/00000000000000000000.timeindex.deleted (kafka.log.TimeIndex)
[2016-11-28 20:23:18,368] INFO Deleting index /data/kafka-logs/__consumer_offsets-35/00000000000000076989.index.deleted (kafka.log.OffsetIndex)
[2016-11-28 20:23:18,368] INFO Deleting index /data/kafka-logs/__consumer_offsets-35/00000000000000076989.timeindex.deleted (kafka.log.TimeIndex)
[2016-11-28 20:47:15,162] INFO Scheduling log segment 1323262 for log topic_19-0 for deletion. (kafka.log.Log)
[2016-11-28 20:47:15,172] INFO Scheduling log segment 1323268 for log topic_19-1 for deletion. (kafka.log.Log)
[2016-11-28 20:48:15,172] INFO Deleting segment 1323262 from log topic_19-0. (kafka.log.Log)
[2016-11-28 20:48:15,184] INFO Deleting segment 1323268 from log topic_19-1. (kafka.log.Log)
[2016-11-28 20:48:15,262] INFO Deleting index /data/kafka-logs/topic_19-1/00000000000001323268.index.deleted (kafka.log.OffsetIndex)
[2016-11-28 20:48:15,262] INFO Deleting index /data/kafka-logs/topic_19-0/00000000000001323262.index.deleted (kafka.log.OffsetIndex)
[2016-11-28 20:48:15,262] INFO Deleting index /data/kafka-logs/topic_19-1/00000000000001323268.timeindex.deleted (kafka.log.TimeIndex)
[2016-11-28 20:48:15,262] INFO Deleting index /data/kafka-logs/topic_19-0/00000000000001323262.timeindex.deleted (kafka.log.TimeIndex)
[2016-11-28 21:07:15,163] INFO Scheduling log segment 1669790058 for log topic_42-0 for deletion. (kafka.log.Log)
[2016-11-28 21:08:15,164] INFO Deleting segment 1669790058 from log topic_42-0. (kafka.log.Log)
[2016-11-28 21:08:15,654] INFO Deleting index /data/kafka-logs/topic_42-0/00000000001669790058.index.deleted (kafka.log.OffsetIndex)
[2016-11-28 21:08:15,654] INFO Deleting index /data/kafka-logs/topic_42-0/00000000001669790058.timeindex.deleted (kafka.log.TimeIndex)
[2016-11-28 21:12:15,163] INFO Scheduling log segment 1115268223 for log topic_42-1 for deletion. (kafka.log.Log)
[2016-11-28 21:13:15,163] INFO Deleting segment 1115268223 from log topic_42-1. (kafka.log.Log)
[2016-11-28 21:13:15,459] INFO Deleting index /data/kafka-logs/topic_42-1/00000000001115268223.index.deleted (kafka.log.OffsetIndex)
[2016-11-28 21:13:15,460] INFO Deleting index /data/kafka-logs/topic_42-1/00000000001115268223.timeindex.deleted (kafka.log.TimeIndex)
[2016-11-28 21:17:15,163] INFO Scheduling log segment 1115429103 for log topic_42-2 for deletion. (kafka.log.Log)
[2016-11-28 21:18:15,163] INFO Deleting segment 1115429103 from log topic_42-2. (kafka.log.Log)
[2016-11-28 21:18:15,376] INFO Deleting index /data/kafka-logs/topic_42-2/00000000001115429103.index.deleted (kafka.log.OffsetIndex)
[2016-11-28 21:18:15,376] INFO Deleting index /data/kafka-logs/topic_42-2/00000000001115429103.timeindex.deleted (kafka.log.TimeIndex)
[2016-11-28 21:32:05,946] INFO [Kafka Server 1002], shutting down (kafka.server.KafkaServer)
[2016-11-28 21:32:05,947] INFO [Kafka Server 1002], Starting controlled shutdown (kafka.server.KafkaServer)
[2016-11-28 21:32:06,637] INFO [Kafka Server 1002], Remaining partitions to move: topic_3-0,topic_18-1,topic_39-0,__consumer_offsets-9,__consumer_offsets-42,__consumer_offsets-21,connect-offsets-4,topic_17-1,__consumer_offsets-30,connect-config-0,connect-offsets-16,__consumer_offsets-45,topic_30-1,connect-offsets-13,__consumer_offsets-12,connect-offsets-1,__consumer_offsets-24,topic_19-1,topic_23-0,topic_24-0,topic_4-0,__consumer_offsets-0,topic_21-2,__consumer_offsets-33,__consumer_offsets-15,connect-offsets-10,__consumer_offsets-48,topic_6-1,topic_22-2,topic_13-2,topic_42-2,topic_31-1,topic_11-1,topic_0_get-1,topic_20-1,topic_44-2,__consumer_offsets-3,connect-offsets-22,topic_0-1,__consumer_offsets-36,topic_8-1,topic_7-1,connect-offsets-7,topic_0_post-0,topic_15-1,topic_41-0,__consumer_offsets-18,topic_28-1,__consumer_offsets-27,__consumer_offsets-39,topic_12-0,__consumer_offsets-6,connect-offsets-19 (kafka.server.KafkaServer)
[2016-11-28 21:32:06,638] INFO [Kafka Server 1002], Error code from controller: 0 (kafka.server.KafkaServer)
[2016-11-28 21:32:11,639] WARN [Kafka Server 1002], Retrying controlled shutdown after the previous attempt failed... (kafka.server.KafkaServer)
[2016-11-28 21:32:12,114] INFO [Kafka Server 1002], Remaining partitions to move: topic_3-0,topic_18-1,topic_39-0,__consumer_offsets-9,__consumer_offsets-42,__consumer_offsets-21,connect-offsets-4,topic_17-1,__consumer_offsets-30,connect-config-0,connect-offsets-16,__consumer_offsets-45,topic_30-1,connect-offsets-13,__consumer_offsets-12,connect-offsets-1,__consumer_offsets-24,topic_19-1,topic_23-0,topic_24-0,topic_4-0,__consumer_offsets-0,topic_21-2,__consumer_offsets-33,__consumer_offsets-15,connect-offsets-10,__consumer_offsets-48,topic_6-1,topic_22-2,topic_13-2,topic_42-2,topic_31-1,topic_11-1,topic_0_get-1,topic_20-1,topic_44-2,__consumer_offsets-3,connect-offsets-22,topic_0-1,__consumer_offsets-36,topic_8-1,topic_7-1,connect-offsets-7,topic_0_post-0,topic_15-1,topic_41-0,__consumer_offsets-18,topic_28-1,__consumer_offsets-27,__consumer_offsets-39,topic_12-0,__consumer_offsets-6,connect-offsets-19 (kafka.server.KafkaServer)
[2016-11-28 21:32:12,114] INFO [Kafka Server 1002], Error code from controller: 0 (kafka.server.KafkaServer)
[2016-11-28 21:32:17,114] WARN [Kafka Server 1002], Retrying controlled shutdown after the previous attempt failed... (kafka.server.KafkaServer)
[2016-11-28 21:32:17,543] INFO [Kafka Server 1002], Remaining partitions to move: topic_3-0,topic_18-1,topic_39-0,__consumer_offsets-9,__consumer_offsets-42,__consumer_offsets-21,connect-offsets-4,topic_17-1,__consumer_offsets-30,connect-config-0,connect-offsets-16,__consumer_offsets-45,topic_30-1,connect-offsets-13,__consumer_offsets-12,connect-offsets-1,__consumer_offsets-24,topic_19-1,topic_23-0,topic_24-0,topic_4-0,__consumer_offsets-0,topic_21-2,__consumer_offsets-33,__consumer_offsets-15,connect-offsets-10,__consumer_offsets-48,topic_6-1,topic_22-2,topic_13-2,topic_42-2,topic_31-1,topic_11-1,topic_0_get-1,topic_20-1,topic_44-2,__consumer_offsets-3,connect-offsets-22,topic_0-1,__consumer_offsets-36,topic_8-1,topic_7-1,connect-offsets-7,topic_0_post-0,topic_15-1,topic_41-0,__consumer_offsets-18,topic_28-1,__consumer_offsets-27,__consumer_offsets-39,topic_12-0,__consumer_offsets-6,connect-offsets-19 (kafka.server.KafkaServer)
[2016-11-28 21:32:17,543] INFO [Kafka Server 1002], Error code from controller: 0 (kafka.server.KafkaServer)
[2016-11-28 21:32:22,544] WARN [Kafka Server 1002], Retrying controlled shutdown after the previous attempt failed... (kafka.server.KafkaServer)
[2016-11-28 21:32:22,545] WARN [Kafka Server 1002], Proceeding to do an unclean shutdown as all the controlled shutdown attempts failed (kafka.server.KafkaServer)
[2016-11-28 21:32:22,587] INFO [Socket Server on Broker 1002], Shutting down (kafka.network.SocketServer)