niknikhil025
niknikhil025
earlier we changed from 1 to 2. Then we changed back from 2 to 1
we changed in postgresql.conf and restarted the postgresql service on all nodes
@wallyqs ```python import nats import json import gzip async def send_data(): queue_name = "somestream" nc = await nats.connect("nats://127.0.0.1", user_credentials="admin.creds") js = nc.jetstream() stream_name = "somestream" data = {"RandomKey": "ABC"} s...
RECENT LOGS [2453688] 2024/01/15 06:16:05.273300 [INF] JetStream cluster new consumer leader for 'ADUCTL447Q7CNBNXRFG6YRXZI4YZQBZOSAVVRUH5742SPG2ZGHJO5A3M > agent_stream > 35755_766' [2453688] 2024/01/15 06:16:06.713819 [ERR] 60.241.109.18:55447 - cid:9720059 - authentication error [2453688] 2024/01/15 06:16:15.879093...
nats-py==2.6.0 we are authenticating using nkeys This happens with our golang client too when subscribing or sending messages to jetstream queue. It timesout when connecting to nats itself. We will...
authentication is for some clients which do not have permissions updated and that is fine for us. The ones with correct credentials are also not able to communicate. I will...
> By stream having 200k subscribers, do you mean 200k consumers? Yes. All are consuming different subjects in the stream. so each subject is subscribed by 1 consumer and these...
This is what happens when we restart our nats cluster after upgrading nats-server to nats-server: v2.10.9 [1094386] 2024/01/15 08:36:28.759778 [INF] JetStream cluster new consumer leader for 'ADUCTL447Q7CNBNXRFG6YRXZI4YZQBZOSAVVRUH5742SPG2ZGHJO5A3M > agent_stream >...
After a while these are the logs getting this once in a while [1094386] 2024/01/15 08:57:59.064555 [INF] JetStream cluster new consumer leader for 'ADUCTL447Q7CNBNXRFG6YRXZI4YZQBZOSAVVRUH5742SPG2ZGHJO5A3M > abc_stream > 36341' [1094386] 2024/01/15...
now pushing to stream is working but now we are not able to subscribe to the channel stream -> abc_stream has channel -> channel_abc.> there are around 100K consumers right...