Received: from malur.postgresql.org ([217.196.149.56]) by arkaria.postgresql.org with esmtps (TLS1.3) tls TLS_ECDHE_RSA_WITH_AES_256_GCM_SHA384 (Exim 4.94.2) (envelope-from ) id 1tO33o-003khn-Ho for pgsql-admin@arkaria.postgresql.org; Wed, 18 Dec 2024 23:02:32 +0000 Received: from localhost ([127.0.0.1] helo=malur.postgresql.org) by malur.postgresql.org with esmtp (Exim 4.94.2) (envelope-from ) id 1tO33m-003DEF-Pp for pgsql-admin@arkaria.postgresql.org; Wed, 18 Dec 2024 23:02:30 +0000 Received: from magus.postgresql.org ([2a02:c0:301:0:ffff::29]) by malur.postgresql.org with esmtps (TLS1.3) tls TLS_ECDHE_RSA_WITH_AES_256_GCM_SHA384 (Exim 4.94.2) (envelope-from ) id 1tO33m-003DE6-Dn for pgsql-admin@lists.postgresql.org; Wed, 18 Dec 2024 23:02:30 +0000 Received: from mail-pj1-x102b.google.com ([2607:f8b0:4864:20::102b]) by magus.postgresql.org with esmtps (TLS1.3) tls TLS_ECDHE_RSA_WITH_AES_128_GCM_SHA256 (Exim 4.94.2) (envelope-from ) id 1tO33j-000U86-Eu for pgsql-admin@lists.postgresql.org; Wed, 18 Dec 2024 23:02:29 +0000 Received: by mail-pj1-x102b.google.com with SMTP id 98e67ed59e1d1-2eed82ca5b4so141919a91.2 for ; Wed, 18 Dec 2024 15:02:27 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20230601; t=1734562945; x=1735167745; darn=lists.postgresql.org; h=to:subject:message-id:date:from:mime-version:from:to:cc:subject :date:message-id:reply-to; bh=rw++A8Mg08qy8rG7TqCCKVHxwZ/QaL9ozSOUAq0rATE=; b=JLMtEyKm2O6JS3OyvU7GneevOz8AefEJ8+TusbMvsDpusZfSAhcCC6sG5fFdSiggQt Jz0hoKhHgDdB64UBGVAvCxRAxX8nuNQ0kLvwnCtz1ApgIMNU2/Wqs/5cMSwqGg7izAC7 WeYe/OPcFLtq3NDMYOsHbKBK9hxawG+owflpTmZDcztLIW7iLjAB2rzBQBhWfWIz7zYc Qp8ws8o+buuhOusUg6rzy6dZgBwHjYVdlBUxs7uBnSDA2BY/80oTReXhIO4zYvb6ZDIw 6CPZLO8/lXDBuWtmgK/MJz6uiL1xz6YC7+qYJLu8TuLIMlwR0yn62tZt0XHt20yF1h72 DmHQ== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20230601; t=1734562945; x=1735167745; h=to:subject:message-id:date:from:mime-version:x-gm-message-state :from:to:cc:subject:date:message-id:reply-to; bh=rw++A8Mg08qy8rG7TqCCKVHxwZ/QaL9ozSOUAq0rATE=; b=bsDuEkvIMe54LEbQoc0DMj5fzNzaaaWSF8RVZ6Ldf/XpKELKtsQW6dM3QvWijA2Ee1 BO/d74ZCP7j4tH3S9zsyZn5hqRMViT5GcGVGjh5hF05HBRUzzHMOwR83b5864vMqnOSA PJnJOIvV1rD7oReb1tJNQse07DM0LQ5ZOUUd8Duv0Tc/WYvqr+accJdhin2APKClINA+ ZrLDvGOy9H5gBfobBvcCICdJxK3a0P3S2TgFiuVaHw5wrUlg1nhn43+GoTn128G7w/zq 87Fk6PFBgS99Jp4RQRqPcv8I4loiEp6/nj7XkaheH6olQSbdSbG9KfOoSsyKYi2FBXMR bZiA== X-Gm-Message-State: AOJu0YzTVePleeU+dak9mQ9anDnMqKYINan+Ekqz0hWNMW0ngMmP9nCU q9djVGmCZGqJp4TRet2nPa1D+v4EeXe5Hl1FoxMNuGv8Rlog23Nfjf6GU2sDPwpah9YT2fTWSGM wdpOd/SJiHKmiWqsqqty1wVHfElSFvSNSRbo= X-Gm-Gg: ASbGnct0HNzyMLpxnuyX4xyUoM2PfiHnfktabMoI0f5MBhm4ay7c2vj4i02T1Qbtv8l g8fKjm4SI+NTntFJ8I022hm0loi1R/GK0CC2MjA== X-Google-Smtp-Source: AGHT+IFqMyCVVaue/4qNkAjqXnkub6FH45GJYdAEpfNZ03qbwfq6rZabJKMDaORY84UCNlYokl82w0G4aZFZ3yLZSr8= X-Received: by 2002:a17:90b:1c02:b0:2ee:59af:a432 with SMTP id 98e67ed59e1d1-2f2e9369d3fmr5944553a91.31.1734562944881; Wed, 18 Dec 2024 15:02:24 -0800 (PST) MIME-Version: 1.0 From: Edwin UY Date: Thu, 19 Dec 2024 12:01:48 +1300 Message-ID: Subject: Logical replication - SELECT * FROM pg_logical_slot_get_changes To: pgsql-admin@lists.postgresql.org Content-Type: multipart/alternative; boundary="0000000000002b9f27062993685d" List-Id: List-Help: List-Subscribe: List-Post: List-Owner: List-Archive: Archived-At: Precedence: bulk --0000000000002b9f27062993685d Content-Type: text/plain; charset="UTF-8" Hi, Just curious, what is the impact of running these and under what scenario would you necessarily run them? SELECT * FROM pg_logical_slot_get_changes('fivetran_replication_slot', NULL, NULL, 'stream-changes', '1'); SELECT * FROM pg_logical_slot_get_changes('fivetran_replication_slot', NULL, NULL, 'include-xids', '0'); Can you actually run this to tell logical replication to start/reset replicating from when? Regards, Ed --0000000000002b9f27062993685d Content-Type: text/html; charset="UTF-8" Content-Transfer-Encoding: quoted-printable
Hi,

Just cu= rious, what is the impact of running these and under=C2=A0 what scenario wo= uld you necessarily run them?

SELECT * FROM pg_log= ical_slot_get_changes('fivetran_replication_slot', NULL, NULL, '= ;stream-changes', '1');
SELECT * FROM pg_logical_slot_get_ch= anges('fivetran_replication_slot', NULL, NULL, 'include-xids= 9;, '0');

Can you actually run this to tel= l logical replication to start/reset replicating from when?
<= br>
Regards,
Ed

--0000000000002b9f27062993685d--