用 emqx eval 'mria_rlog:status().' 的输出结果是(已做脱敏处理):
./emqx eval 'mria_rlog:status().'
#{role => replicant,backend => rlog,shards_down => [],
shard_stats =>
#{'$mria_meta_shard' =>
#{message_queue_len => 0,state => normal,
upstream =>
'emqx-xxxx-yyyyy@emqx-xxxx-core.svc.cluster.local',
bootstrap_num_keys => 3,bootstrap_time => 2,lag => 0,
last_imported_trans => 28,replayq_len => 0},
emqx_common_shard =>
#{message_queue_len => 0,state => normal,
upstream =>
'emqx-xxxx-yyyyy@emqx-xxxx-core.svc.cluster.local',
bootstrap_num_keys => 7,bootstrap_time => 4,lag => 0,
last_imported_trans => 12,replayq_len => 0},
emqx_cm_shard =>
#{message_queue_len => 0,state => normal,
upstream =>
'emqx-xxxx-yyyyy@emqx-xxxx-core.svc.cluster.local',
bootstrap_num_keys => 300,bootstrap_time => 389,lag => -6,
last_imported_trans => 38259296,replayq_len => 0},
emqx_exclusive_shard =>
#{message_queue_len => 0,state => normal,
upstream =>
'emqx-xxxx-yyyyy@emqx-xxxx-core.svc.cluster.local',
bootstrap_num_keys => 1,bootstrap_time => 2,lag => 0,
last_imported_trans => 0,replayq_len => 0},
route_shard =>
#{message_queue_len => 0,state => normal,
upstream =>
'emqx-xxxx-yyyyy@emqx-xxxx-core.svc.cluster.local',
bootstrap_num_keys => 305,bootstrap_time => 358,lag => -2,
last_imported_trans => 35908433,replayq_len => 0},
emqx_shared_sub_shard =>
#{message_queue_len => 0,state => normal,
upstream =>
'emqx-xxxx-yyyyy@emqx-xxxx-core.svc.cluster.local',
bootstrap_num_keys => 2,bootstrap_time => 2,lag => 0,
last_imported_trans => 45254,replayq_len => 0},
emqx_cluster_rpc_shard =>
#{message_queue_len => 0,state => normal,
upstream =>
'emqx-xxxx-yyyyy@emqx-xxxx-core.svc.cluster.local',
bootstrap_num_keys => 4,bootstrap_time => 3,lag => 0,
last_imported_trans => 90,replayq_len => 0},
emqx_authn_shard =>
#{message_queue_len => 0,state => normal,
upstream =>
'emqx-xxxx-yyyyy@emqx-xxxx-core.svc.cluster.local',
bootstrap_num_keys => 3,bootstrap_time => 2,lag => 0,
last_imported_trans => 1,replayq_len => 0},
emqx_acl_sharded =>
#{message_queue_len => 0,state => normal,
upstream =>
'emqx-xxxx-yyyyy@emqx-xxxx-core.svc.cluster.local',
bootstrap_num_keys => 1,bootstrap_time => 1,lag => 0,
last_imported_trans => 0,replayq_len => 0},
emqx_dashboard_shard =>
#{message_queue_len => 0,state => normal,
upstream =>
'emqx-xxxx-yyyyy@emqx-xxxx-core.svc.cluster.local',
bootstrap_num_keys => 4,bootstrap_time => 2,lag => 0,
last_imported_trans => 62448,replayq_len => 0},
emqx_retainer_shard =>
#{message_queue_len => 0,state => normal,
upstream =>
'emqx-xxxx-yyyyy@emqx-xxxx-core.svc.cluster.local',
bootstrap_num_keys => 6,bootstrap_time => 4,lag => 0,
last_imported_trans => 9934951,replayq_len => 0},
emqx_psk_shard =>
#{message_queue_len => 0,state => normal,
upstream =>
'emqx-xxxx-yyyyy@emqx-xxxx-core.svc.cluster.local',
bootstrap_num_keys => 1,bootstrap_time => 1,lag => 0,
last_imported_trans => 0,replayq_len => 0},
emqx_telemetry_shard =>
#{message_queue_len => 0,state => normal,
upstream =>
'emqx-xxxx-yyyyy@emqx-xxxx-core.svc.cluster.local',
bootstrap_num_keys => 2,bootstrap_time => 1,lag => 0,
last_imported_trans => 1,replayq_len => 0}},
shards_in_sync =>
['$mria_meta_shard',emqx_acl_sharded,emqx_authn_shard,
emqx_cluster_rpc_shard,emqx_cm_shard,emqx_common_shard,
emqx_dashboard_shard,emqx_exclusive_shard,emqx_psk_shard,
emqx_retainer_shard,emqx_shared_sub_shard,emqx_telemetry_shard,
route_shard]}
宕机的pod是replicant的,部署方式是k8s,使用daemonset方式部署