Received: from malur.postgresql.org ([217.196.149.56]) by arkaria.postgresql.org with esmtps (TLS1.3:ECDHE_RSA_AES_256_GCM_SHA384:256) (Exim 4.92) (envelope-from ) id 1p8e6N-00070k-P6 for pgsql-hackers@arkaria.postgresql.org; Fri, 23 Dec 2022 09:12:27 +0000 Received: from localhost ([127.0.0.1] helo=malur.postgresql.org) by malur.postgresql.org with esmtp (Exim 4.92) (envelope-from ) id 1p8e6M-0007vE-C2 for pgsql-hackers@arkaria.postgresql.org; Fri, 23 Dec 2022 09:12:26 +0000 Received: from magus.postgresql.org ([2a02:c0:301:0:ffff::29]) by malur.postgresql.org with esmtps (TLS1.3:ECDHE_RSA_AES_256_GCM_SHA384:256) (Exim 4.92) (envelope-from ) id 1p8e6M-0007v5-0r for pgsql-hackers@lists.postgresql.org; Fri, 23 Dec 2022 09:12:26 +0000 Received: from esa13.fujitsucc.c3s2.iphmx.com ([68.232.156.96]) by magus.postgresql.org with esmtps (TLS1.2:ECDHE_RSA_AES_256_GCM_SHA384:256) (Exim 4.92) (envelope-from ) id 1p8e6J-0006ZG-Dy for pgsql-hackers@lists.postgresql.org; Fri, 23 Dec 2022 09:12:25 +0000 DKIM-Signature: v=1; a=rsa-sha256; c=simple/simple; d=fujitsu.com; i=@fujitsu.com; q=dns/txt; s=fj1; t=1671786744; x=1703322744; h=from:to:cc:subject:date:message-id:references: in-reply-to:content-transfer-encoding:mime-version; bh=Od7grfg768URfdpBxQMmuFujjpeYKld+nNDgIwJv5pY=; b=hQzQA5L0zFeT5/wG9NgL0Qc3MOM+W1U7bn0CIDFO4zkEchpaJRP9Zx49 7wkgog0M8+dhx59aGka+8lWPiDZ36BEuPocAPMi+Hb20Hsxst2J2mWrJB coNvBro6AeVQs5KL/JVSBGjStqTvPF7vcbvDVePczO0HYFVyoKbXHSiJ6 hO4fObdTep5hHY5dPVVRtbjq0rCc2BGgFpIA1GILs5fNTYKOGyOqbsaOo 0yCrkfyQowHwIG/qGS2AcQKqnZ2rEl3ZdNuLfTzgTC9gvynJtigywUW3r qIHRGOyKN5etGN+l3pPrnWYCt6x+PNa2ds0hwhb4Pt0F36dCckQPucHHi A==; X-IronPort-AV: E=McAfee;i="6500,9779,10569"; a="72926308" X-IronPort-AV: E=Sophos;i="5.96,268,1665414000"; d="scan'208";a="72926308" Received: from mail-tycjpn01lp2170.outbound.protection.outlook.com (HELO JPN01-TYC-obe.outbound.protection.outlook.com) ([104.47.23.170]) by ob1.fujitsucc.c3s2.iphmx.com with ESMTP/TLS/ECDHE-RSA-AES256-GCM-SHA384; 23 Dec 2022 18:12:22 +0900 ARC-Seal: i=1; a=rsa-sha256; s=arcselector9901; d=microsoft.com; cv=none; b=S+cITtdcaf1A1Y18WV658HLSJ9IG89boyxU1X6vngptwdjjIQqTTENTt/yDkCMZDQ1nmA+QyIbZ++0MqOYcKnh4CAMW6evWJ5q3rzu07nHRfRkAOR8raTpnEv1D36hPd57oNDaVt+yBISYkC0itxB75fVww6zO/S50Uc88KhyJ2MvNGnc/3nXPA5MJysT0ubvC0w4BbLHAEQ9ded2b1X+N209qN0P3yWd+hlX7ou+kuFpRfARWJUfbbR9fyAmeEgKk3uZtJ84z62a1YQ4KReKIi9ibY97ief9qWZe1YNrwg//XFN/YjqJl0uTi5qsRe5yVbgkDKqDVyAkU112bnmWQ== ARC-Message-Signature: i=1; a=rsa-sha256; c=relaxed/relaxed; d=microsoft.com; s=arcselector9901; h=From:Date:Subject:Message-ID:Content-Type:MIME-Version:X-MS-Exchange-AntiSpam-MessageData-ChunkCount:X-MS-Exchange-AntiSpam-MessageData-0:X-MS-Exchange-AntiSpam-MessageData-1; bh=Od7grfg768URfdpBxQMmuFujjpeYKld+nNDgIwJv5pY=; b=RV23BM1hVETHJmWmLRXBaYop4Mvq8t95MX373XxgXP+5UXq77KGbqpVugIKPBprzVvVwCqRjt5M5aZvssLy1yOuJrTUWtqixvFLTTUjLcxhMiXyk+kaeQtWARaSqXzgMsOXJ16oSt1mv68WuZpVEMxe1t10fwrnMHlrJVSdFa1oKGUT73oyv/P0frw4JWfVvwEq1D3iRdN1V0CqTCH4ZeQWSuYBxKorJDlCBKF5L0Da0NE+qOYUFkhBmFyhweLSgpu2C4AGcQVoN6jcSuQjPbX0DyH9ZTRe6LCclgDjQpHtqe9HbdLAHQCyhL/vCzBBwtX7ZIbnlTCGhpLhSvUbIxg== ARC-Authentication-Results: i=1; mx.microsoft.com 1; spf=pass smtp.mailfrom=fujitsu.com; dmarc=pass action=none header.from=fujitsu.com; dkim=pass header.d=fujitsu.com; arc=none Received: from TYAPR01MB5866.jpnprd01.prod.outlook.com (2603:1096:404:8056::13) by TYAPR01MB5722.jpnprd01.prod.outlook.com (2603:1096:404:8059::9) with Microsoft SMTP Server (version=TLS1_2, cipher=TLS_ECDHE_RSA_WITH_AES_256_GCM_SHA384) id 15.20.5944.6; Fri, 23 Dec 2022 09:12:18 +0000 Received: from TYAPR01MB5866.jpnprd01.prod.outlook.com ([fe80::ff85:d4ae:eada:b3e7]) by TYAPR01MB5866.jpnprd01.prod.outlook.com ([fe80::ff85:d4ae:eada:b3e7%9]) with mapi id 15.20.5924.022; Fri, 23 Dec 2022 09:12:18 +0000 From: "Hayato Kuroda (Fujitsu)" To: "shiy.fnst@fujitsu.com" , Amit Kapila CC: Kyotaro Horiguchi , "sawada.mshk@gmail.com" , "smithpb2250@gmail.com" , "dilipbalaut@gmail.com" , "pgsql-hackers@lists.postgresql.org" Subject: RE: Force streaming every change in logical decoding Thread-Topic: Force streaming every change in logical decoding Thread-Index: AdkJOXtow5rglkccSriZUb5HH+ZxggDI5a8AAM6a6XAABwKQAAEn7FzwAANimgAAKwjggAACOKGAAAD/tIAACLhKgAABx28AACQCKAAAAV/RgAADcDcAAAbaXqAAI/4UAAAFoXMgAAEbdHA= Date: Fri, 23 Dec 2022 09:12:18 +0000 Message-ID: References: <20221222.164507.1962968929109173863.horikyota.ntt@gmail.com> In-Reply-To: Accept-Language: ja-JP, en-US Content-Language: ja-JP X-MS-Has-Attach: X-MS-TNEF-Correlator: msip_labels: =?utf-8?B?TVNJUF9MYWJlbF9hNzI5NWNjMS1kMjc5LTQyYWMtYWI0ZC0zYjBmNGZlY2Uw?= =?utf-8?B?NTBfQWN0aW9uSWQ9ODFkZGIxMzAtZjM1ZC00MzE2LTg4ZmQtMzc2ZmY4MjYz?= =?utf-8?B?ZDBiO01TSVBfTGFiZWxfYTcyOTVjYzEtZDI3OS00MmFjLWFiNGQtM2IwZjRm?= =?utf-8?B?ZWNlMDUwX0NvbnRlbnRCaXRzPTA7TVNJUF9MYWJlbF9hNzI5NWNjMS1kMjc5?= =?utf-8?B?LTQyYWMtYWI0ZC0zYjBmNGZlY2UwNTBfRW5hYmxlZD10cnVlO01TSVBfTGFi?= =?utf-8?B?ZWxfYTcyOTVjYzEtZDI3OS00MmFjLWFiNGQtM2IwZjRmZWNlMDUwX01ldGhv?= =?utf-8?B?ZD1TdGFuZGFyZDtNU0lQX0xhYmVsX2E3Mjk1Y2MxLWQyNzktNDJhYy1hYjRk?= =?utf-8?B?LTNiMGY0ZmVjZTA1MF9OYW1lPUZVSklUU1UtUkVTVFJJQ1RFRO+/ou++gA==?= =?utf-8?B?776LO01TSVBfTGFiZWxfYTcyOTVjYzEtZDI3OS00MmFjLWFiNGQtM2IwZjRm?= =?utf-8?B?ZWNlMDUwX1NldERhdGU9MjAyMi0xMi0yM1QwODozMTozNVo7TVNJUF9MYWJl?= =?utf-8?B?bF9hNzI5NWNjMS1kMjc5LTQyYWMtYWI0ZC0zYjBmNGZlY2UwNTBfU2l0ZUlk?= =?utf-8?Q?=3Da19f121d-81e1-4858-a9d8-736e267fd4c7;?= authentication-results: dkim=none (message not signed) header.d=none;dmarc=none action=none header.from=fujitsu.com; x-ms-publictraffictype: Email x-ms-traffictypediagnostic: TYAPR01MB5866:EE_|TYAPR01MB5722:EE_ x-ms-office365-filtering-correlation-id: 0e3d1337-2841-4dec-7d7b-08dae4c5ca8c x-ms-exchange-senderadcheck: 1 x-ms-exchange-antispam-relay: 0 x-microsoft-antispam: BCL:0; x-microsoft-antispam-message-info: BOpHFopH2fkE1TcEfGnoW1X5dnZNH0ReLHrPJd+RfeHw5stqHDoT5kTKuF2eOiUbt+vSkIzrKMF067aSU5+ksJH+JN+RaTvJqdBr2X2QzBli1thVRwl7jRCYpBCanJprnYEFuWrBy8qc1nwX909TlWv9EejGzrlX/c6cPdqR7x+Ld5uKpTrKoeKeOqhNgvW11uA3c2hix8tz3M+dY7TvP59CYHOdVHbQrFVSRnlRheFYF46rie18w5JaDV8T7Osdq6F1zP9/n+Nlr4BbHwERURKEW66wSoVTxQOu750hvgkHCBGtlyemPMp7p6wV18INrN4yuqvsF/+cDk+l+9VIreEQKtXrL9eG2V60aZQgUl6INVqzwXG8fVy+892Ca/si7QECqUyH15bJF96C0cj0S+kUqq7qZYilDDRrADbzLS/DHkH5aZtBq9XsdxaKhFWhfzaY80cIb9qPrmwTnxHPnMxu75KhdSKKRXKxwcz5X3Assl5q9jomx+PphWbpSLg9lfHwLLlhxxsdqv7WuIJMtRIKwFOm/XHbvFjx+t5zALDp9y1L4V8AYHlJ3BCpnHBBLslp2NhJ4Vm6haUvMswyfzd2FA2cri7DaXJL6XWvloTdwJKKlcer67PXJhSOawXvVvgqH51b9gF3B8tY0yIyASKwU/xFj+zJTMLTUv5/AJz78ApLj+fXueyq905Ydk9u1AmGSgnQdxfvb98OMwt7YlAdibDgq0tsPVbKMVFh+1s= x-forefront-antispam-report: CIP:255.255.255.255;CTRY:;LANG:en;SCL:1;SRV:;IPV:NLI;SFV:NSPM;H:TYAPR01MB5866.jpnprd01.prod.outlook.com;PTR:;CAT:NONE;SFS:(13230022)(4636009)(346002)(136003)(39860400002)(396003)(376002)(366004)(451199015)(1590799012)(83380400001)(86362001)(8936002)(38100700002)(122000001)(82960400001)(2906002)(38070700005)(52536014)(5660300002)(41300700001)(55016003)(478600001)(6506007)(76116006)(26005)(9686003)(7696005)(66946007)(186003)(66446008)(66476007)(316002)(54906003)(66556008)(8676002)(64756008)(71200400001)(110136005)(4326008)(1580799009)(85182001)(558084003)(33656002);DIR:OUT;SFP:1101; x-ms-exchange-antispam-messagedata-chunkcount: 1 x-ms-exchange-antispam-messagedata-0: =?utf-8?B?YWU3Tlk0NG9wbG5kOVZQUGZJVStQbHhlMWpxbkgvc1dlSWxqTnAwN0VpcWF1?= =?utf-8?B?dGlpTERPb0k2QW9Ja2Q4WHpmeHpkTjg2a0R0b0JaV0xXOHREQjQ5QWJwUncx?= =?utf-8?B?b1pRbFRScVVhaGh3dWJkRklmLzVZVzkyWXQ2QUZDZVFucnU4NnpQc3pwb3pr?= =?utf-8?B?ejRaWlQ2bEszS2NjTCthTVhaSERxQ0Q2QTVDcDA4Y0Z4YStWWU1rV2s1Sm9V?= =?utf-8?B?M1FlVDY3bW1aWTFyZTIraytZQm5tdVFSeUFTMG5LV0NQNWpVU1VKOHBRMGhE?= =?utf-8?B?cmN5b3c0T2g1SmpNWEpHSi9ZT2JCL1FnQmdvcGkzc3dTQmFvVWI0ajNUTUdL?= =?utf-8?B?QThzQTdnV1FlQWRseEZxdm5pTnlpeFJtTm55djlpTHA2SWlnL0tWT1BMeUpI?= =?utf-8?B?ZzhYMWJOMEJpeDBKbmdnNkZkYXRyaUtvUEhRVkRWZ2ZhZ0pLdDZNUUszT1Ra?= =?utf-8?B?RmJBNisrbVprTjZuVExzY050MWhxMDRBTXB5bnJId3VmaXlSY1dhVVZXbW9S?= =?utf-8?B?U2xibFprQ3ZQQk9xVnZ4UkZmSDJqbldRblFGcER2UXZXMnMyRGgrLzBuejFI?= =?utf-8?B?eVoyTEpGbXZzMnM0NXQ3ekk5STd1V1NYaDFTcjRRODhUcWo4Z0FGUEFacVhY?= =?utf-8?B?VnYzRzdxWVpyWTZDUkJueko5dW11Ky9sUlcvcmJjOEJPN2FTa1JXR2dNVXhm?= =?utf-8?B?Rmdua05HRmcrQ1ppdGZRTXlPZnphcVRHekJmSTNZK2IvckI4V2VuUmdoZDMz?= =?utf-8?B?cXp2NEYxTG9OcGdXUVNoMytwTGdteSs0UDB2elJXbUlHTTFoTGZiUzZmQlBL?= =?utf-8?B?SHdMb0xLS3VnQVpLcGlNV0F6dnhkTElJQys0VUo0Q1Z6R1V0NlpoTmNobXAy?= =?utf-8?B?cFhIZkNyWUcwSldOVnBFbEdFVlBtZUsyVmtQSDQxOEtHY3pWYlladXpTb2Z3?= =?utf-8?B?RHVYNU96SDFacjF0ZkJBL3BFMlRRU09NZ0FXWVV0UWpFKzFLY1hFRFRJUHli?= =?utf-8?B?NlpHU3JjSVR6UFRLYmN4NTBza3kyeS9QcXFMQUhVRTVWbXEzWTNPV2dBYUNh?= =?utf-8?B?ZzZPZDkxOThoTDcxeXdXV0MvUkw2UmVWWlk1ODlXci9MYlVtUzVCTlN5NXFB?= =?utf-8?B?eVhQUXR2SWx0bnd1bjlyTmRiOWtqczBpa1RBRG52RCs2UTR3VldyYzhsNjIz?= =?utf-8?B?ZVlhTDBJdXc3dmNUcHl6S3ZVK0YvRUJNd3FxR3BDUTJVWTlvczB2REs1ZVJ2?= =?utf-8?B?bTVncmdXN2JnNlhzZjhVUW1qSXFqUTFLdnUvSjFGM1VhNXM0SjRnREVwQVF5?= =?utf-8?B?MVU5TW1SZW5vNTQ1Z05KcnV1ZDhBTWhKU0h1SENsS1hzc1pMeVZjZlVweXMx?= =?utf-8?B?UVB4UW1HZ0RHaVZKekV3VGNxZ0RPd2ZpN002aUNlZHBzOEZMTHpHaGhRT0Rl?= =?utf-8?B?ZjJtZHVpSWRMU1F1RG5xRXhHc3VxTWNSdCtaOTk1eUF4WGpscXVzVUswRW91?= =?utf-8?B?MHNIZ3c1Sk5ZMFpBUVl1TVhhcm5DenJGMjRVUnkycFRvNkE0dWpKTHhUNEVa?= =?utf-8?B?N0lCV3Q5K2Vqekc2VFFOSVZ1dTdYNTZXRVI0SFEvYUpoSWg4SVZtWDZKU0JO?= =?utf-8?B?dlpXaFVFanFIS3VLeVg1V3lMRGxCMFQ1ZXd3R0RxTmRhQzI2MjNGSmc2ZjJs?= =?utf-8?B?Zit4V0ZGQUVDWWQ0aCttdkdKU1paQUdiaVV0d080RmFVVndncHM0UUppTkVU?= =?utf-8?B?U0hBRWVYcmZqWnQ0Q0tYdkg5TmFtbEFzZkJkS2ovVWwwdWMxRUFjSVl1cTdS?= =?utf-8?B?VFlvQVFsTUxNWTZTOGY5YktuN2ZXb0hwaU43TkpMNHdVdVVibVpjMTNocE1w?= =?utf-8?B?U0E2cUNwRUh2WXNnL3k4L2pyYU1QdHBNKy9XZ1Jjd25hNmRoM1R5N2xOR1Zv?= =?utf-8?B?UWdJcWVQOUxpdU5CSEtwek11ajdsN3k3YmFFejdHbXBkVHRjWkxIVlYyL1pz?= =?utf-8?B?ZjZzMitBekpENkcwOHdVZHZlT25BOEdSR2o1azJXc1JrYWJiMXJhcnJEQjl0?= =?utf-8?B?dENyWmdPZWo2NHUycTJOM3BwbGRiNlZsS2dETWFTTS9PcmFjb0g5TUZEY3Q4?= =?utf-8?B?MmxwVEd1K1RpQmhvMTFtbGJxL0dlTGowUFpEa0czK0lVTm9CKzVGbThMQ3lq?= =?utf-8?B?eEE9PQ==?= Content-Type: text/plain; charset="utf-8" Content-Transfer-Encoding: base64 MIME-Version: 1.0 X-OriginatorOrg: fujitsu.com X-MS-Exchange-CrossTenant-AuthAs: Internal X-MS-Exchange-CrossTenant-AuthSource: TYAPR01MB5866.jpnprd01.prod.outlook.com X-MS-Exchange-CrossTenant-Network-Message-Id: 0e3d1337-2841-4dec-7d7b-08dae4c5ca8c X-MS-Exchange-CrossTenant-originalarrivaltime: 23 Dec 2022 09:12:18.3929 (UTC) X-MS-Exchange-CrossTenant-fromentityheader: Hosted X-MS-Exchange-CrossTenant-id: a19f121d-81e1-4858-a9d8-736e267fd4c7 X-MS-Exchange-CrossTenant-mailboxtype: HOSTED X-MS-Exchange-CrossTenant-userprincipalname: 7dh/NxbCzd5/9Hp8r1j6DtfEb84+8i/sl3oXGKrKC5umCv9ZKGRDwwjcbUC86fkCNLq91zDX6ii/H+EXNAXboQlsef/ugkZZuS4HpYS2cis= X-MS-Exchange-Transport-CrossTenantHeadersStamped: TYAPR01MB5722 List-Id: List-Help: List-Subscribe: List-Post: List-Owner: List-Archive: Archived-At: Precedence: bulk RGVhciBTaGksDQoNCj4gSSBhbHNvIGZpeGVkIEt1cm9kYS1zYW4ncyBjb21tZW50c1sxXS4NCg0K VGhhbmtzIGZvciB1cGRhdGluZyB0aGUgcGF0Y2ghIEkgY29uZmlybWVkIHRoYXQgbXkgY29tbWVu dHMgd2VyZSBmaXhlZCBhbmQNCnlvdXIgcGF0Y2ggY291bGQgcGFzcyBzdWJzY3JpcHRpb24gYW5k IHRlc3RfZGVjb2RpbmcgdGVzdHMuIEkgdGhpbmsgd2UgY2FuDQpjaGFuZ2UgdGhlIHN0YXR1cyB0 byAiUmVhZHkgZm9yIENvbW1pdHRlciIuDQoNCkJlc3QgUmVnYXJkcywNCkhheWF0byBLdXJvZGEN CkZVSklUU1UgTElNSVRFRA0KDQo=