Function producer_offsets_upsert_sql 

pub fn producer_offsets_upsert_sql() -> String

The producer watermark’s upsert, shared with the capture-aware writers that must run it through their own exec (the row is replicated data, not connection-local bookkeeping) rather than through upsert_producer_seq.