Handling SqlError Due to CONNECTION_ENDED in Effect-Kafka Message Handlers
Hi, I'm a bit new to using scope and concurrency (fork, forkScoped, forkDaemon etc). I'm using the effect library for kafka (effect-kafka). Inside message handlers handling messages coming in when consuming/subscribing a topic, I am relying on a service doing a call with pgsql and effect-sql. Always inside these message handlers, I get SqlError due to CONNECTION_ENDED. Seems someone else using sql connection and it ending because that scope is somehow closing. Anything I should look out for in this instance?
Production-grade applications in TypeScript.
6,221Members
Resources
Recent Announcements
Similar Threads
Was this page helpful?
