[2020-10-06 22:33:21,156] INFO (pool-4-thread-6 kafka.log.Log 66) [Log partition=test-perf-18, dir=/data01/kafka/log] Recovering unflushed segment 71311328
3
[2020-10-06 22:33:21,157] INFO (pool-4-thread-6 kafka.log.Log 66) [Log partition=test-perf-18, dir=/data01/kafka/log] Loading producer state till offset 71
3113283 with message format version 2
[2020-10-06 22:33:21,444] INFO (pool-10-thread-2 kafka.log.Log 66) [Log partition=cloudeng_client_log-15, dir=/data07/kafka/log] Recovering unflushed segment
 141423701
[2020-10-06 22:33:21,445] INFO (pool-10-thread-2 kafka.log.Log 66) [Log partition=cloudeng_client_log-15, dir=/data07/kafka/log] Loading producer state till
offset 141423701 with message format version 2
[2020-10-06 22:33:22,652] INFO (pool-9-thread-11 kafka.log.ProducerStateManager 66) [ProducerStateManager partition=lyjt_hbase_audit_log-16] Writing producer
 snapshot at offset 17381273
[2020-10-06 22:33:22,743] INFO (pool-9-thread-11 kafka.log.Log 66) [Log partition=lyjt_hbase_audit_log-16, dir=/data06/kafka/log] Loading producer state till
 offset 17381273 with message format version 2
[2020-10-06 22:33:22,829] INFO (pool-9-thread-11 kafka.log.ProducerStateManager 66) [ProducerStateManager partition=lyjt_hbase_audit_log-16] Loading producer
 state from snapshot file '/data06/kafka/log/lyjt_hbase_audit_log-16/00000000000017381273.snapshot'
[2020-10-06 22:33:22,829] INFO (pool-9-thread-11 kafka.log.Log 66) [Log partition=lyjt_hbase_audit_log-16, dir=/data06/kafka/log] Completed load of log with
31 segments, log start offset 16678071 and log end offset 17381273 in 505452 ms

[2020-10-06 22:36:52,665] INFO (pool-10-thread-3 kafka.log.ProducerStateManager 66) [ProducerStateManager partition=druid_dlc_nginx_access_log-25] Loading pr
oducer state from snapshot file '/data07/kafka/log/druid_dlc_nginx_access_log-25/00000000009812215977.snapshot'
[2020-10-06 22:36:52,665] INFO (pool-10-thread-3 kafka.log.Log 66) [Log partition=druid_dlc_nginx_access_log-25, dir=/data07/kafka/log] Completed load of log
 with 38 segments, log start offset 9720935796 and log end offset 9812215977 in 239366 ms
[2020-10-06 22:36:59,575] INFO (pool-5-thread-12 kafka.log.ProducerStateManager 66) [ProducerStateManager partition=Kafka_OutChain-2] Loading producer state
from snapshot file '/data02/kafka/log/Kafka_OutChain-2/00000000000155664784.snapshot'
[2020-10-06 22:36:59,576] INFO (pool-5-thread-12 kafka.log.Log 66) [Log partition=Kafka_OutChain-2, dir=/data02/kafka/log] Completed load of log with 48 segm
ents, log start offset 155312194 and log end offset 155664784 in 516355 ms
[2020-10-06 22:37:00,181] INFO (pool-5-thread-12 kafka.log.Log 66) [Log partition=eb_cef_packetbeat_mysql-10, dir=/data02/kafka/log] Recovering unflushed seg
ment 992585879
[2020-10-06 22:37:00,181] INFO (pool-5-thread-12 kafka.log.Log 66) [Log partition=eb_cef_packetbeat_mysql-10, dir=/data02/kafka/log] Loading producer state t
ill offset 992585879 with message format version 2
[2020-10-06 22:37:00,181] INFO (pool-5-thread-12 kafka.log.ProducerStateManager 66) [ProducerStateManager partition=eb_cef_packetbeat_mysql-10] Writing produ
cer snapshot at offset 992585879
[2020-10-06 22:37:00,406] INFO (pool-5-thread-12 kafka.log.Log 66) [Log partition=eb_cef_packetbeat_mysql-10, dir=/data02/kafka/log] Loading producer state t
ill offset 992585879 with message format version 2
[2020-10-06 22:37:00,407] INFO (pool-5-thread-12 kafka.log.Log 66) [Log partition=eb_cef_packetbeat_mysql-10, dir=/data02/kafka/log] Completed load of log wi
th 1 segments, log start offset 992585879 and log end offset 992585879 in 258 ms
[2020-10-06 22:37:00,636] WARN (pool-5-thread-12 kafka.log.Log 70) [Log partition=eb_json_superset-19, dir=/data02/kafka/log] Found a corrupted index file co
rresponding to log file /data02/kafka/log/eb_json_superset-19/00000000000000013056.log due to Corrupt time index found, time index file (/data02/kafka/log/eb
_json_superset-19/00000000000000013056.timeindex) has non-zero size but the last timestamp is 0 which is less than the first timestamp 1601644830183}, recove
ring segment and rebuilding index files...
[2020-10-06 22:37:00,636] INFO (pool-5-thread-12 kafka.log.Log 66) [Log partition=eb_json_superset-19, dir=/data02/kafka/log] Loading producer state till off
set 13056 with message format version 2
[2020-10-06 22:37:00,674] INFO (pool-5-thread-12 kafka.log.ProducerStateManager 66) [ProducerStateManager partition=eb_json_superset-19] Writing producer sna
pshot at offset 13056
[2020-10-06 22:37:00,745] INFO (pool-5-thread-12 kafka.log.ProducerStateManager 66) [ProducerStateManager partition=eb_json_superset-19] Writing producer sna
pshot at offset 13065
[2020-10-06 22:37:00,745] INFO (pool-5-thread-12 kafka.log.Log 66) [Log partition=eb_json_superset-19, dir=/data02/kafka/log] Recovering unflushed segment 13
056
[2020-10-06 22:37:00,745] INFO (pool-5-thread-12 kafka.log.ProducerStateManager 66) [ProducerStateManager partition=eb_json_superset-19] Writing producer sna
pshot at offset 13065
[2020-10-06 22:37:00,745] INFO (pool-5-thread-12 kafka.log.Log 66) [Log partition=eb_json_superset-19, dir=/data02/kafka/log] Recovering unflushed segment 13
056
[2020-10-06 22:37:00,745] INFO (pool-5-thread-12 kafka.log.Log 66) [Log partition=eb_json_superset-19, dir=/data02/kafka/log] Loading producer state till off
set 13056 with message format version 2
[2020-10-06 22:37:00,745] INFO (pool-5-thread-12 kafka.log.ProducerStateManager 66) [ProducerStateManager partition=eb_json_superset-19] Loading producer sta
te from snapshot file '/data02/kafka/log/eb_json_superset-19/00000000000000013056.snapshot'
[2020-10-06 22:37:00,745] INFO (pool-5-thread-12 kafka.log.ProducerStateManager 66) [ProducerStateManager partition=eb_json_superset-19] Writing producer sna
pshot at offset 13065
[2020-10-06 22:37:00,746] INFO (pool-5-thread-12 kafka.log.Log 66) [Log partition=eb_json_superset-19, dir=/data02/kafka/log] Loading producer state till off
set 13065 with message format version 2
[2020-10-06 22:37:00,746] INFO (pool-5-thread-12 kafka.log.ProducerStateManager 66) [ProducerStateManager partition=eb_json_superset-19] Loading producer sta
te from snapshot file '/data02/kafka/log/eb_json_superset-19/00000000000000013065.snapshot'
[2020-10-06 22:37:00,746] INFO (pool-5-thread-12 kafka.log.Log 66) [Log partition=eb_json_superset-19, dir=/data02/kafka/log] Completed load of log with 1 se
gments, log start offset 13056 and log end offset 13065 in 156 ms
[2020-10-06 22:37:01,141] INFO (pool-5-thread-12 kafka.log.Log 66) [Log partition=td_skyeye_dns-9, dir=/data02/kafka/log] Recovering unflushed segment 170
[2020-10-06 22:37:01,141] INFO (pool-5-thread-12 kafka.log.Log 66) [Log partition=td_skyeye_dns-9, dir=/data02/kafka/log] Loading producer state till offset
170 with message format version 2
[2020-10-06 22:37:01,141] INFO (pool-5-thread-12 kafka.log.ProducerStateManager 66) [ProducerStateManager partition=td_skyeye_dns-9] Writing producer snapsho
t at offset 170
[2020-10-06 22:37:01,173] INFO (pool-5-thread-12 kafka.log.Log 66) [Log partition=td_skyeye_dns-9, dir=/data02/kafka/log] Loading producer state till offset
170 with message format version 2
[2020-10-06 22:37:01,173] INFO (pool-5-thread-12 kafka.log.Log 66) [Log partition=td_skyeye_dns-9, dir=/data02/kafka/log] Completed load of log with 1 segmen
ts, log start offset 170 and log end offset 170 in 32 ms
[2020-10-06 22:37:02,093] INFO (pool-5-thread-12 kafka.log.Log 66) [Log partition=td_skyeye_file-13, dir=/data02/kafka/log] Recovering unflushed segment 0
[2020-10-06 22:37:02,094] INFO (pool-5-thread-12 kafka.log.Log 66) [Log partition=td_skyeye_file-13, dir=/data02/kafka/log] Loading producer state till offse
t 0 with message format version 2
[2020-10-06 22:37:02,094] INFO (pool-5-thread-12 kafka.log.Log 66) [Log partition=td_skyeye_file-13, dir=/data02/kafka/log] Loading producer state till offse
t 0 with message format version 2
[2020-10-06 22:37:02,094] INFO (pool-5-thread-12 kafka.log.Log 66) [Log partition=td_skyeye_file-13, dir=/data02/kafka/log] Loading producer state till offse
t 0 with message format version 2
[2020-10-06 22:37:02,094] INFO (pool-5-thread-12 kafka.log.Log 66) [Log partition=td_skyeye_file-13, dir=/data02/kafka/log] Loading producer state till offse
t 0 with message format version 2
[2020-10-06 22:37:02,094] INFO (pool-5-thread-12 kafka.log.Log 66) [Log partition=td_skyeye_file-13, dir=/data02/kafka/log] Completed load of log with 1 segm
ents, log start offset 0 and log end offset 0 in 1 ms
[2020-10-06 22:37:11,891] INFO (pool-5-thread-1 kafka.log.ProducerStateManager 66) [ProducerStateManager partition=eb_json_unix-2] Writing producer snapshot
at offset 433775129
[2020-10-06 22:37:11,891] INFO (pool-5-thread-1 kafka.log.Log 66) [Log partition=eb_json_unix-2, dir=/data02/kafka/log] Loading producer state till offset 43
3775129 with message format version 2
[2020-10-06 22:37:11,893] INFO (pool-5-thread-1 kafka.log.ProducerStateManager 66) [ProducerStateManager partition=eb_json_unix-2] Loading producer state fro
m snapshot file '/data02/kafka/log/eb_json_unix-2/00000000000433775129.snapshot'
[2020-10-06 22:37:11,893] INFO (pool-5-thread-1 kafka.log.Log 66) [Log partition=eb_json_unix-2, dir=/data02/kafka/log] Completed load of log with 14 segment
s, log start offset 420401133 and log end offset 433775129 in 399525 ms
[2020-10-06 22:37:17,728] INFO (pool-5-thread-5 kafka.log.ProducerStateManager 66) [ProducerStateManager partition=eb_cef_secdns-7] Writing producer snapshot
 at offset 1182734771
[2020-10-06 22:37:17,728] INFO (pool-5-thread-5 kafka.log.Log 66) [Log partition=eb_cef_secdns-7, dir=/data02/kafka/log] Recovering unflushed segment 1182561
923
[2020-10-06 22:37:17,728] INFO (pool-5-thread-5 kafka.log.Log 66) [Log partition=eb_cef_secdns-7, dir=/data02/kafka/log] Loading producer state till offset 1
182561923 with message format version 2
[2020-10-06 22:37:17,729] INFO (pool-5-thread-5 kafka.log.ProducerStateManager 66) [ProducerStateManager partition=eb_cef_secdns-7] Loading producer state fr
om snapshot file '/data02/kafka/log/eb_cef_secdns-7/00000000001182561923.snapshot'
[2020-10-06 22:37:18,301] INFO (pool-5-thread-5 kafka.log.ProducerStateManager 66) [ProducerStateManager partition=eb_cef_secdns-7] Writing producer snapshot
 at offset 1182734771
[2020-10-06 22:37:18,302] INFO (pool-5-thread-5 kafka.log.Log 66) [Log partition=eb_cef_secdns-7, dir=/data02/kafka/log] Loading producer state till offset 1
182734771 with message format version 2
[2020-10-06 22:37:18,302] INFO (pool-5-thread-5 kafka.log.ProducerStateManager 66) [ProducerStateManager partition=eb_cef_secdns-7] Loading producer state fr
om snapshot file '/data02/kafka/log/eb_cef_secdns-7/00000000001182734771.snapshot'
[2020-10-06 22:37:18,302] INFO (pool-5-thread-5 kafka.log.Log 66) [Log partition=eb_cef_secdns-7, dir=/data02/kafka/log] Completed load of log with 3 segment
s, log start offset 1180600853 and log end offset 1182734771 in 62849 ms
[2020-10-06 22:37:18,302] INFO (pool-5-thread-5 kafka.log.Log 66) [Log partition=eb_cef_secdns-7, dir=/data02/kafka/log] Completed load of log with 3 segment
s, log start offset 1180600853 and log end offset 1182734771 in 62849 ms
[2020-10-06 22:37:23,693] INFO (pool-5-thread-8 kafka.log.ProducerStateManager 66) [ProducerStateManager partition=druid_dlc_nginx_k8s_access_log-2] Writing
producer snapshot at offset 2735816194
[2020-10-06 22:37:23,694] INFO (pool-5-thread-8 kafka.log.Log 66) [Log partition=druid_dlc_nginx_k8s_access_log-2, dir=/data02/kafka/log] Recovering unflushe
d segment 2735454535
[2020-10-06 22:37:23,694] INFO (pool-5-thread-8 kafka.log.Log 66) [Log partition=druid_dlc_nginx_k8s_access_log-2, dir=/data02/kafka/log] Loading producer st
ate till offset 2735454535 with message format version 2
[2020-10-06 22:37:23,695] INFO (pool-5-thread-8 kafka.log.ProducerStateManager 66) [ProducerStateManager partition=druid_dlc_nginx_k8s_access_log-2] Loading
producer state from snapshot file '/data02/kafka/log/druid_dlc_nginx_k8s_access_log-2/00000000002735454535.snapshot'
[2020-10-06 22:37:24,537] INFO (pool-5-thread-8 kafka.log.ProducerStateManager 66) [ProducerStateManager partition=druid_dlc_nginx_k8s_access_log-2] Writing
producer snapshot at offset 2735816194
[2020-10-06 22:37:24,537] INFO (pool-5-thread-8 kafka.log.Log 66) [Log partition=druid_dlc_nginx_k8s_access_log-2, dir=/data02/kafka/log] Loading producer st
ate till offset 2735816194 with message format version 2
[2020-10-06 22:37:24,538] INFO (pool-5-thread-8 kafka.log.ProducerStateManager 66) [ProducerStateManager partition=druid_dlc_nginx_k8s_access_log-2] Loading
producer state from snapshot file '/data02/kafka/log/druid_dlc_nginx_k8s_access_log-2/00000000002735816194.snapshot'
[2020-10-06 22:37:24,538] INFO (pool-5-thread-8 kafka.log.Log 66) [Log partition=druid_dlc_nginx_k8s_access_log-2, dir=/data02/kafka/log] Completed load of l
og with 20 segments, log start offset 2702439276 and log end offset 2735816194 in 55908 ms
[2020-10-06 22:37:24,961] INFO (pool-5-thread-10 kafka.log.ProducerStateManager 66) [ProducerStateManager partition=eb_json_gitlab-8] Writing producer snapsh
ot at offset 230180396
[2020-10-06 22:37:24,962] INFO (pool-5-thread-10 kafka.log.Log 66) [Log partition=eb_json_gitlab-8, dir=/data02/kafka/log] Recovering unflushed segment 22977
5012
[2020-10-06 22:37:24,962] INFO (pool-5-thread-10 kafka.log.Log 66) [Log partition=eb_json_gitlab-8, dir=/data02/kafka/log] Loading producer state till offset
 229775012 with message format version 2
[2020-10-06 22:37:24,962] INFO (pool-5-thread-10 kafka.log.ProducerStateManager 66) [ProducerStateManager partition=eb_json_gitlab-8] Loading producer state
from snapshot file '/data02/kafka/log/eb_json_gitlab-8/00000000000229775012.snapshot'
[2020-10-06 22:37:26,208] INFO (pool-5-thread-10 kafka.log.ProducerStateManager 66) [ProducerStateManager partition=eb_json_gitlab-8] Writing producer snapsh
ot at offset 230180396
[2020-10-06 22:37:26,209] INFO (pool-5-thread-10 kafka.log.Log 66) [Log partition=eb_json_gitlab-8, dir=/data02/kafka/log] Loading producer state till offset
 230180396 with message format version 2
[2020-10-06 22:37:26,208] INFO (pool-5-thread-10 kafka.log.ProducerStateManager 66) [ProducerStateManager partition=eb_json_gitlab-8] Writing producer snapsh
ot at offset 230180396
[2020-10-06 22:37:26,209] INFO (pool-5-thread-10 kafka.log.Log 66) [Log partition=eb_json_gitlab-8, dir=/data02/kafka/log] Loading producer state till offset
 230180396 with message format version 2
[2020-10-06 22:37:26,209] INFO (pool-5-thread-10 kafka.log.ProducerStateManager 66) [ProducerStateManager partition=eb_json_gitlab-8] Loading producer state
from snapshot file '/data02/kafka/log/eb_json_gitlab-8/00000000000230180396.snapshot'
[2020-10-06 22:37:26,209] INFO (pool-5-thread-10 kafka.log.Log 66) [Log partition=eb_json_gitlab-8, dir=/data02/kafka/log] Completed load of log with 3 segme
nts, log start offset 227316669 and log end offset 230180396 in 124164 ms
[2020-10-06 22:37:29,242] INFO (pool-5-thread-13 kafka.log.ProducerStateManager 66) [ProducerStateManager partition=druid_dlc_nginx_access_log-14] Writing pr
oducer snapshot at offset 9829311804
[2020-10-06 22:37:29,242] INFO (pool-5-thread-13 kafka.log.Log 66) [Log partition=druid_dlc_nginx_access_log-14, dir=/data02/kafka/log] Recovering unflushed
segment 9828074920
[2020-10-06 22:37:29,242] INFO (pool-5-thread-13 kafka.log.Log 66) [Log partition=druid_dlc_nginx_access_log-14, dir=/data02/kafka/log] Loading producer stat
e till offset 9828074920 with message format version 2
[2020-10-06 22:37:29,244] INFO (pool-5-thread-13 kafka.log.ProducerStateManager 66) [ProducerStateManager partition=druid_dlc_nginx_access_log-14] Loading pr
oducer state from snapshot file '/data02/kafka/log/druid_dlc_nginx_access_log-14/00000000009828074920.snapshot'
[2020-10-06 22:37:31,122] INFO (pool-5-thread-13 kafka.log.ProducerStateManager 66) [ProducerStateManager partition=druid_dlc_nginx_access_log-14] Writing pr
oducer snapshot at offset 9829311804
[2020-10-06 22:37:31,123] INFO (pool-5-thread-13 kafka.log.Log 66) [Log partition=druid_dlc_nginx_access_log-14, dir=/data02/kafka/log] Loading producer stat
e till offset 9829311804 with message format version 2
[2020-10-06 22:37:31,124] INFO (pool-5-thread-13 kafka.log.ProducerStateManager 66) [ProducerStateManager partition=druid_dlc_nginx_access_log-14] Loading pr
oducer state from snapshot file '/data02/kafka/log/druid_dlc_nginx_access_log-14/00000000009829311804.snapshot'
[2020-10-06 22:37:31,124] INFO (pool-5-thread-13 kafka.log.Log 66) [Log partition=druid_dlc_nginx_access_log-14, dir=/data02/kafka/log] Completed load of log
 with 38 segments, log start offset 9738685028 and log end offset 9829311804 in 142936 ms
[2020-10-06 22:37:40,958] INFO (pool-5-thread-9 kafka.log.ProducerStateManager 66) [ProducerStateManager partition=druid_dlc_busi_cloudkill_unknown-14] Writi
ng producer snapshot at offset 8168339987
[2020-10-06 22:37:40,958] INFO (pool-5-thread-9 kafka.log.Log 66) [Log partition=druid_dlc_busi_cloudkill_unknown-14, dir=/data02/kafka/log] Loading producer
 state till offset 8168339987 with message format version 2
[2020-10-06 22:37:40,959] INFO (pool-5-thread-9 kafka.log.ProducerStateManager 66) [ProducerStateManager partition=druid_dlc_busi_cloudkill_unknown-14] Loadi
ng producer state from snapshot file '/data02/kafka/log/druid_dlc_busi_cloudkill_unknown-14/00000000008168339987.snapshot'
[2020-10-06 22:37:40,958] INFO (pool-5-thread-9 kafka.log.Log 66) [Log partition=druid_dlc_busi_cloudkill_unknown-14, dir=/data02/kafka/log] Loading producer
 state till offset 8168339987 with message format version 2
[2020-10-06 22:37:40,959] INFO (pool-5-thread-9 kafka.log.ProducerStateManager 66) [ProducerStateManager partition=druid_dlc_busi_cloudkill_unknown-14] Loadi
ng producer state from snapshot file '/data02/kafka/log/druid_dlc_busi_cloudkill_unknown-14/00000000008168339987.snapshot'
[2020-10-06 22:37:40,959] INFO (pool-5-thread-9 kafka.log.Log 66) [Log partition=druid_dlc_busi_cloudkill_unknown-14, dir=/data02/kafka/log] Completed load o
f log with 11 segments, log start offset 8138347181 and log end offset 8168339987 in 502949 ms
[2020-10-06 22:37:45,925] INFO (pool-5-thread-14 kafka.log.ProducerStateManager 66) [ProducerStateManager partition=common_data_dns_114-5] Writing producer s
napshot at offset 172923631
[2020-10-06 22:37:45,926] INFO (pool-5-thread-14 kafka.log.Log 66) [Log partition=common_data_dns_114-5, dir=/data02/kafka/log] Loading producer state till o
ffset 172923631 with message format version 2
[2020-10-06 22:37:45,969] INFO (pool-5-thread-14 kafka.log.ProducerStateManager 66) [ProducerStateManager partition=common_data_dns_114-5] Loading producer s
tate from snapshot file '/data02/kafka/log/common_data_dns_114-5/00000000000172923631.snapshot'
[2020-10-06 22:37:45,970] INFO (pool-5-thread-14 kafka.log.Log 66) [Log partition=common_data_dns_114-5, dir=/data02/kafka/log] Completed load of log with 37
5 segments, log start offset 171475646 and log end offset 172923631 in 474488 ms
[2020-10-06 22:37:48,626] INFO (pool-5-thread-15 kafka.log.ProducerStateManager 66) [ProducerStateManager partition=cloudeng_client_log-73] Writing producer
snapshot at offset 42641589
[2020-10-06 22:37:48,627] INFO (pool-5-thread-15 kafka.log.Log 66) [Log partition=cloudeng_client_log-73, dir=/data02/kafka/log] Recovering unflushed segment
 42634484
[2020-10-06 22:37:48,627] INFO (pool-5-thread-15 kafka.log.Log 66) [Log partition=cloudeng_client_log-73, dir=/data02/kafka/log] Loading producer state till
offset 42634484 with message format version 2
[2020-10-06 22:37:48,627] INFO (pool-5-thread-15 kafka.log.ProducerStateManager 66) [ProducerStateManager partition=cloudeng_client_log-73] Loading producer
state from snapshot file '/data02/kafka/log/cloudeng_client_log-73/00000000000042634484.snapshot'
[2020-10-06 22:37:49,315] INFO (pool-5-thread-15 kafka.log.ProducerStateManager 66) [ProducerStateManager partition=cloudeng_client_log-73] Writing producer
snapshot at offset 42641589
[2020-10-06 22:37:49,316] INFO (pool-5-thread-15 kafka.log.Log 66) [Log partition=cloudeng_client_log-73, dir=/data02/kafka/log] Loading producer state till
offset 42641589 with message format version 2
[2020-10-06 22:37:49,316] INFO (pool-5-thread-15 kafka.log.ProducerStateManager 66) [ProducerStateManager partition=cloudeng_client_log-73] Loading producer
state from snapshot file '/data02/kafka/log/cloudeng_client_log-73/00000000000042641589.snapshot'
[2020-10-06 22:37:49,316] INFO (pool-5-thread-15 kafka.log.Log 66) [Log partition=cloudeng_client_log-73, dir=/data02/kafka/log] Completed load of log with 2
 segments, log start offset 42612816 and log end offset 42641589 in 73167 ms
[2020-10-06 22:37:49,316] INFO (pool-5-thread-15 kafka.log.ProducerStateManager 66) [ProducerStateManager partition=cloudeng_client_log-73] Loading producer
state from snapshot file '/data02/kafka/log/cloudeng_client_log-73/00000000000042641589.snapshot'
[2020-10-06 22:37:49,316] INFO (pool-5-thread-15 kafka.log.Log 66) [Log partition=cloudeng_client_log-73, dir=/data02/kafka/log] Completed load of log with 2
 segments, log start offset 42612816 and log end offset 42641589 in 73167 ms
[2020-10-06 22:37:53,946] INFO (pool-5-thread-2 kafka.log.ProducerStateManager 66) [ProducerStateManager partition=eb_json_iis-7] Writing producer snapshot a
t offset 753802531
[2020-10-06 22:37:53,947] INFO (pool-5-thread-2 kafka.log.Log 66) [Log partition=eb_json_iis-7, dir=/data02/kafka/log] Loading producer state till offset 753
802531 with message format version 2
[2020-10-06 22:37:53,947] INFO (pool-5-thread-2 kafka.log.ProducerStateManager 66) [ProducerStateManager partition=eb_json_iis-7] Loading producer state from
 snapshot file '/data02/kafka/log/eb_json_iis-7/00000000000753802531.snapshot'
[2020-10-06 22:37:53,948] INFO (pool-5-thread-2 kafka.log.Log 66) [Log partition=eb_json_iis-7, dir=/data02/kafka/log] Completed load of log with 8 segments,
 log start offset 749227246 and log end offset 753802531 in 477159 ms
[2020-10-06 22:37:59,712] INFO (pool-5-thread-7 kafka.log.ProducerStateManager 66) [ProducerStateManager partition=eb_raw_legendsec_flow-9] Writing producer
snapshot at offset 9566536144
[2020-10-06 22:37:59,713] INFO (pool-5-thread-7 kafka.log.Log 66) [Log partition=eb_raw_legendsec_flow-9, dir=/data02/kafka/log] Recovering unflushed segment
 9565707450
[2020-10-06 22:37:59,713] INFO (pool-5-thread-7 kafka.log.Log 66) [Log partition=eb_raw_legendsec_flow-9, dir=/data02/kafka/log] Loading producer state till
offset 9565707450 with message format version 2
[2020-10-06 22:37:59,719] INFO (pool-5-thread-7 kafka.log.ProducerStateManager 66) [ProducerStateManager partition=eb_raw_legendsec_flow-9] Loading producer
state from snapshot file '/data02/kafka/log/eb_raw_legendsec_flow-9/00000000009565707450.snapshot'
[2020-10-06 22:38:02,090] INFO (pool-5-thread-7 kafka.log.ProducerStateManager 66) [ProducerStateManager partition=eb_raw_legendsec_flow-9] Writing producer
snapshot at offset 9566536144
[2020-10-06 22:38:02,090] INFO (pool-5-thread-7 kafka.log.Log 66) [Log partition=eb_raw_legendsec_flow-9, dir=/data02/kafka/log] Loading producer state till
offset 9566536144 with message format version 2
[2020-10-06 22:38:02,096] INFO (pool-5-thread-7 kafka.log.ProducerStateManager 66) [ProducerStateManager partition=eb_raw_legendsec_flow-9] Loading producer
state from snapshot file '/data02/kafka/log/eb_raw_legendsec_flow-9/00000000009566536144.snapshot'
[2020-10-06 22:38:02,097] INFO (pool-5-thread-7 kafka.log.Log 66) [Log partition=eb_raw_legendsec_flow-9, dir=/data02/kafka/log] Completed load of log with 1
68 segments, log start offset 9365410515 and log end offset 9566536144 in 149232 ms
[2020-10-06 22:38:03,957] INFO (pool-5-thread-11 kafka.log.ProducerStateManager 66) [ProducerStateManager partition=druid_dlc_framework_stat_cloudkill_log-4]
 Writing producer snapshot at offset 47487345
[2020-10-06 22:38:02,097] INFO (pool-5-thread-7 kafka.log.Log 66) [Log partition=eb_raw_legendsec_flow-9, dir=/data02/kafka/log] Completed load of log with 1
68 segments, log start offset 9365410515 and log end offset 9566536144 in 149232 ms
[2020-10-06 22:38:03,957] INFO (pool-5-thread-11 kafka.log.ProducerStateManager 66) [ProducerStateManager partition=druid_dlc_framework_stat_cloudkill_log-4]
 Writing producer snapshot at offset 47487345
[2020-10-06 22:38:03,957] INFO (pool-5-thread-11 kafka.log.Log 66) [Log partition=druid_dlc_framework_stat_cloudkill_log-4, dir=/data02/kafka/log] Loading pr
oducer state till offset 47487345 with message format version 2
[2020-10-06 22:38:03,958] INFO (pool-5-thread-11 kafka.log.ProducerStateManager 66) [ProducerStateManager partition=druid_dlc_framework_stat_cloudkill_log-4]
 Loading producer state from snapshot file '/data02/kafka/log/druid_dlc_framework_stat_cloudkill_log-4/00000000000047487345.snapshot'
[2020-10-06 22:38:03,958] INFO (pool-5-thread-11 kafka.log.Log 66) [Log partition=druid_dlc_framework_stat_cloudkill_log-4, dir=/data02/kafka/log] Completed
load of log with 2 segments, log start offset 46473519 and log end offset 47487345 in 426943 ms
[2020-10-06 22:38:05,117] INFO (pool-5-thread-4 kafka.log.ProducerStateManager 66) [ProducerStateManager partition=eb_cef_dns_trace_log-26] Writing producer
snapshot at offset 1226963149
[2020-10-06 22:38:05,118] INFO (pool-5-thread-4 kafka.log.Log 66) [Log partition=eb_cef_dns_trace_log-26, dir=/data02/kafka/log] Recovering unflushed segment
 1226516783
[2020-10-06 22:38:05,118] INFO (pool-5-thread-4 kafka.log.Log 66) [Log partition=eb_cef_dns_trace_log-26, dir=/data02/kafka/log] Loading producer state till
offset 1226516783 with message format version 2
[2020-10-06 22:38:05,119] INFO (pool-5-thread-4 kafka.log.ProducerStateManager 66) [ProducerStateManager partition=eb_cef_dns_trace_log-26] Loading producer
state from snapshot file '/data02/kafka/log/eb_cef_dns_trace_log-26/00000000001226516783.snapshot'
[2020-10-06 22:38:07,523] INFO (pool-5-thread-4 kafka.log.ProducerStateManager 66) [ProducerStateManager partition=eb_cef_dns_trace_log-26] Writing producer
snapshot at offset 1226963149
[2020-10-06 22:38:07,524] INFO (pool-5-thread-4 kafka.log.Log 66) [Log partition=eb_cef_dns_trace_log-26, dir=/data02/kafka/log] Loading producer state till
offset 1226963149 with message format version 2
[2020-10-06 22:38:07,525] INFO (pool-5-thread-4 kafka.log.ProducerStateManager 66) [ProducerStateManager partition=eb_cef_dns_trace_log-26] Loading producer
state from snapshot file '/data02/kafka/log/eb_cef_dns_trace_log-26/00000000001226963149.snapshot'
[2020-10-06 22:38:07,525] INFO (pool-5-thread-4 kafka.log.Log 66) [Log partition=eb_cef_dns_trace_log-26, dir=/data02/kafka/log] Completed load of log with 1
6 segments, log start offset 1218843214 and log end offset 1226963149 in 144871 ms
[2020-10-06 22:38:12,097] INFO (pool-5-thread-3 kafka.log.ProducerStateManager 66) [ProducerStateManager partition=eb_raw_esxi-2] Writing producer snapshot a
t offset 28175614
[2020-10-06 22:38:12,106] INFO (pool-5-thread-3 kafka.log.Log 66) [Log partition=eb_raw_esxi-2, dir=/data02/kafka/log] Recovering unflushed segment 26588273
[2020-10-06 22:38:12,106] INFO (pool-5-thread-3 kafka.log.Log 66) [Log partition=eb_raw_esxi-2, dir=/data02/kafka/log] Loading producer state till offset 265
88273 with message format version 2
[2020-10-06 22:38:12,097] INFO (pool-5-thread-3 kafka.log.ProducerStateManager 66) [ProducerStateManager partition=eb_raw_esxi-2] Writing producer snapshot a
t offset 28175614
[2020-10-06 22:38:12,106] INFO (pool-5-thread-3 kafka.log.Log 66) [Log partition=eb_raw_esxi-2, dir=/data02/kafka/log] Recovering unflushed segment 26588273
[2020-10-06 22:38:12,106] INFO (pool-5-thread-3 kafka.log.Log 66) [Log partition=eb_raw_esxi-2, dir=/data02/kafka/log] Loading producer state till offset 265
88273 with message format version 2
[2020-10-06 22:38:12,106] INFO (pool-5-thread-3 kafka.log.ProducerStateManager 66) [ProducerStateManager partition=eb_raw_esxi-2] Loading producer state from
 snapshot file '/data02/kafka/log/eb_raw_esxi-2/00000000000026588273.snapshot'
[2020-10-06 22:38:16,380] INFO (pool-5-thread-6 kafka.log.ProducerStateManager 66) [ProducerStateManager partition=eb_json_asoc-3] Writing producer snapshot
at offset 29674416
[2020-10-06 22:38:16,507] INFO (pool-5-thread-6 kafka.log.Log 66) [Log partition=eb_json_asoc-3, dir=/data02/kafka/log] Recovering unflushed segment 28977775
[2020-10-06 22:38:16,507] INFO (pool-5-thread-6 kafka.log.Log 66) [Log partition=eb_json_asoc-3, dir=/data02/kafka/log] Loading producer state till offset 28
977775 with message format version 2
[2020-10-06 22:38:16,507] INFO (pool-5-thread-6 kafka.log.ProducerStateManager 66) [ProducerStateManager partition=eb_json_asoc-3] Loading producer state fro
m snapshot file '/data02/kafka/log/eb_json_asoc-3/00000000000028977775.snapshot'
[2020-10-06 22:38:20,206] INFO (pool-5-thread-3 kafka.log.ProducerStateManager 66) [ProducerStateManager partition=eb_raw_esxi-2] Writing producer snapshot a
t offset 28175614
[2020-10-06 22:38:20,207] INFO (pool-5-thread-3 kafka.log.Log 66) [Log partition=eb_raw_esxi-2, dir=/data02/kafka/log] Loading producer state till offset 281
75614 with message format version 2
[2020-10-06 22:38:20,207] INFO (pool-5-thread-3 kafka.log.ProducerStateManager 66) [ProducerStateManager partition=eb_raw_esxi-2] Loading producer state from
 snapshot file '/data02/kafka/log/eb_raw_esxi-2/00000000000028175614.snapshot'
[2020-10-06 22:38:20,207] INFO (pool-5-thread-3 kafka.log.Log 66) [Log partition=eb_raw_esxi-2, dir=/data02/kafka/log] Completed load of log with 2 segments,
 log start offset 24632203 and log end offset 28175614 in 363614 ms
[2020-10-06 22:38:20,450] INFO (pool-5-thread-6 kafka.log.ProducerStateManager 66) [ProducerStateManager partition=eb_json_asoc-3] Writing producer snapshot
at offset 29674416
[2020-10-06 22:38:20,450] INFO (pool-5-thread-6 kafka.log.Log 66) [Log partition=eb_json_asoc-3, dir=/data02/kafka/log] Loading producer state till offset 29
674416 with message format version 2
[2020-10-06 22:38:20,450] INFO (pool-5-thread-6 kafka.log.ProducerStateManager 66) [ProducerStateManager partition=eb_json_asoc-3] Loading producer state fro
m snapshot file '/data02/kafka/log/eb_json_asoc-3/00000000000029674416.snapshot'
[2020-10-06 22:38:20,450] INFO (pool-5-thread-6 kafka.log.Log 66) [Log partition=eb_json_asoc-3, dir=/data02/kafka/log] Completed load of log with 4 segments
, log start offset 26856402 and log end offset 29674416 in 302595 ms
[2020-10-06 22:38:20,450] INFO (pool-5-thread-6 kafka.log.ProducerStateManager 66) [ProducerStateManager partition=eb_json_asoc-3] Loading producer state fro
m snapshot file '/data02/kafka/log/eb_json_asoc-3/00000000000029674416.snapshot'
[2020-10-06 22:38:20,450] INFO (pool-5-thread-6 kafka.log.Log 66) [Log partition=eb_json_asoc-3, dir=/data02/kafka/log] Completed load of log with 4 segments
, log start offset 26856402 and log end offset 29674416 in 302595 ms
[2020-10-07 00:27:36,794] INFO (pool-4-thread-6 kafka.log.ProducerStateManager 66) [ProducerStateManager partition=test-perf-18] Writing producer snapshot
at offset 713113283
[2020-10-07 00:27:42,943] INFO (pool-4-thread-6 kafka.log.ProducerStateManager 66) [ProducerStateManager partition=test-perf-18] Writing producer snapshot
at offset 713134166
[2020-10-07 00:27:42,944] INFO (pool-4-thread-6 kafka.log.Log 66) [Log partition=test-perf-18, dir=/data01/kafka/log] Recovering unflushed segment 71313416
6
[2020-10-07 00:27:42,945] INFO (pool-4-thread-6 kafka.log.Log 66) [Log partition=test-perf-18, dir=/data01/kafka/log] Loading producer state till offset 71
3134166 with message format version 2
[2020-10-07 00:27:43,001] INFO (pool-4-thread-6 kafka.log.ProducerStateManager 66) [ProducerStateManager partition=test-perf-18] Loading producer state fro
m snapshot file '/data01/kafka/log/test-perf-18/00000000000713134166.snapshot'
[2020-10-07 00:27:49,390] INFO (pool-4-thread-6 kafka.log.ProducerStateManager 66) [ProducerStateManager partition=test-perf-18] Writing producer snapshot
at offset 713155048
[2020-10-07 00:27:49,390] INFO (pool-4-thread-6 kafka.log.Log 66) [Log partition=test-perf-18, dir=/data01/kafka/log] Recovering unflushed segment 71315504
8
[2020-10-07 00:27:49,391] INFO (pool-4-thread-6 kafka.log.Log 66) [Log partition=test-perf-18, dir=/data01/kafka/log] Loading producer state till offset 71
3155048 with message format version 2
[2020-10-07 00:27:49,426] INFO (pool-4-thread-6 kafka.log.ProducerStateManager 66) [ProducerStateManager partition=test-perf-18] Loading producer state fro
m snapshot file '/data01/kafka/log/test-perf-18/00000000000713155048.snapshot'
[2020-10-07 00:27:54,782] INFO (pool-4-thread-6 kafka.log.ProducerStateManager 66) [ProducerStateManager partition=test-perf-18] Writing producer snapshot 
at offset 713173155
[2020-10-07 00:27:54,792] INFO (pool-4-thread-6 kafka.log.Log 66) [Log partition=test-perf-18, dir=/data01/kafka/log] Loading producer state till offset 71
3173155 with message format version 2
[2020-10-07 00:27:54,828] INFO (pool-4-thread-6 kafka.log.ProducerStateManager 66) [ProducerStateManager partition=test-perf-18] Loading producer state fro
m snapshot file '/data01/kafka/log/test-perf-18/00000000000713173155.snapshot'
[2020-10-07 00:27:54,828] INFO (pool-4-thread-6 kafka.log.Log 66) [Log partition=test-perf-18, dir=/data01/kafka/log] Completed load of log with 1054 segme
nts, log start offset 691160692 and log end offset 713173155 in 7269910 ms