-
Notifications
You must be signed in to change notification settings - Fork 0
/
sys_subscribe.log
41 lines (23 loc) · 1.89 KB
/
sys_subscribe.log
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
admin is a system_account
subscribing ">" while I have a "watcher" looping on the issue, I see a consumer create for default account:
nats -s admin:admin@vxr-dev-nats01:1222 sub ">"
=================================================================================================
[#90] Received on "$JSC.ARU.msp_admin_devel.ZVKEYH8D"
\
[#91] Received on "$JSC.ARU.msp_admin_devel.g4JREczI"
[#92] Received on "$JS.API.CONSUMER.CREATE.KV_ANAGRAFICA" with reply "_R_.iaLxiT.kNh5rS"
Nats-Request-Info: {"acc":"default","rtt":31335994,"server":"vxr-dev-nats03","cluster":"fineco_stage"}
{"stream_name":"KV_ANAGRAFICA","config":{"deliver_policy":"by_start_sequence","deliver_subject":"_INBOX.47A4VX81ZC9NIBARC84W4G","opt_start_seq":21810,"ack_policy":"none","ack_wait":86400000000000,"max_deliver":1,"filter_subject":"$KV.ANAGRAFICA.>","replay_policy":"instant","flow_control":true,"idle_heartbeat":5000000000,"num_replicas":1,"mem_storage":true}}
[#93] Received on "_R_.iaLxiT.kNh5rS"
{"type":"io.nats.jetstream.api.v1.consumer_create_response","error":{"code":404,"err_code":10059,"description":"stream not found"}}
[#94] Received on "$NRG.AE._meta_" with reply "$NRG.R.NeE9Du8s"
ZVKEYH8DUU
[#95] Received on "$NRG.R.NeE9Du8s"
U6DChJ63X
[#96] Received on "$NRG.R.NeE9Du8s"
Ug4JREczI
While woriking consumer create requests look like :
[#13] Received on "$JS.API.CONSUMER.CREATE.KV_ANAGRAFICA" with reply "_R_.QxMSij.Pd1TNW"
Nats-Request-Info: {"acc":"msp_admin_devel","rtt":37794093,"server":"vxr-dev-nats01","cluster":"fineco_stage"}
{"stream_name":"KV_ANAGRAFICA","config":{"deliver_policy":"last_per_subject","deliver_subject":"_INBOX.W20DU0T6S7GALO874QGEIA","ack_policy":"none","ack_wait":86400000000000,"max_deliver":1,"filter_subject":"$KV.ANAGRAFICA.>","replay_policy":"instant","flow_control":true,"idle_heartbeat":5000000000,"num_replicas":1,"mem_storage":true}}
(acc: msp_admin_devel instead of acc: default)