SQLStreams

the messaging platform that is just Postgres

You last visited on 9999-99-99 Show what's new since then

lease reclaimed from expired worker [SQL0026]

Edit this page
code SQL0026 · log event at warn — degraded but self-healing, or a durable data consequence; an operator should learn of it eventually
the log line · Report this thread
SQL0026 Log event at warn

As it arrives in your log — example values stand where yours will:

level=WARN msg="lease reclaimed from expired worker" code=SQL0026 schema=sqlstreams stream_id=1 group_id=7 low=4100 high=4200

A consumer stopped renewing a range lease and it expired; the range returned to the claimable pool and another consumer redelivers its messages. Attempt counts survive the reclaim. Frequent reclaims point at consumers dying mid-batch or processing that outruns the lease’s margins.

brandon Site Admin brandon profile Posts: 677

Helpful info.

  1. the leases this group holds now

    SELECT
    	token,
    	low,
    	high,
    	expires_at,
    	reclaims
    FROM {schema}.claim_lease_{stream_id}
    WHERE consumer_group_id = {group_id}
    ORDER BY low;
  2. what the reclaimed range left behind

    SELECT
    	message_id,
    	status,
    	attempts,
    	last_error
    FROM {schema}.exception_queue_{stream_id}
    WHERE consumer_group_id = {group_id}
    	AND message_id BETWEEN {low} AND {high}
    ORDER BY message_id;
Nothing pasted yet — the queries above show their blanks.

Looking for a different code? Search every thread.