diff --git a/doc/src/sgml/ref/pg_createsubscriber.sgml b/doc/src/sgml/ref/pg_createsubscriber.sgml
index 0fcd30d..d2bbef3 100644
--- a/doc/src/sgml/ref/pg_createsubscriber.sgml
+++ b/doc/src/sgml/ref/pg_createsubscriber.sgml
@@ -166,13 +166,8 @@ PostgreSQL documentation
- Enables two-phase commit for the subscription. When the option is
- provided, it is explicitly enabled. By default, two-phase commit is
- off.
- Two-phase commit ensures atomicity in logical replication for prepared
- transactions. See the
- two_phase
- documentation for more details.
+ Enables two_phase
+ commit for the subscription. The default is false.
diff --git a/src/bin/pg_basebackup/pg_createsubscriber.c b/src/bin/pg_basebackup/pg_createsubscriber.c
index ce11ab7..799e49b 100644
--- a/src/bin/pg_basebackup/pg_createsubscriber.c
+++ b/src/bin/pg_basebackup/pg_createsubscriber.c
@@ -229,7 +229,7 @@ usage(void)
printf(_(" -P, --publisher-server=CONNSTR publisher connection string\n"));
printf(_(" -s, --socketdir=DIR socket directory to use (default current dir.)\n"));
printf(_(" -t, --recovery-timeout=SECS seconds to wait for recovery to end\n"));
- printf(_(" -T, --enable-two-phase enable two-phase commit for the subscription\n"));
+ printf(_(" -T, --enable-two-phase enable two-phase commit for the subscription\n"));
printf(_(" -U, --subscriber-username=NAME user name for subscriber connection\n"));
printf(_(" -v, --verbose output verbose messages\n"));
printf(_(" --config-file=FILENAME use specified main server configuration\n"
@@ -459,7 +459,7 @@ store_pub_sub_info(const struct CreateSubscriberOptions *opt,
conninfo = concat_conninfo_dbname(pub_base_conninfo, cell->val);
dbinfo[i].pubconninfo = conninfo;
dbinfo[i].dbname = cell->val;
- dbinfo[i].two_phase = opt->two_phase; /* Set two-phase option */
+ dbinfo[i].two_phase = opt->two_phase;
if (num_pubs > 0)
dbinfo[i].pubname = pubcell->val;
else
@@ -484,7 +484,7 @@ store_pub_sub_info(const struct CreateSubscriberOptions *opt,
dbinfo[i].pubname ? dbinfo[i].pubname : "(auto)",
dbinfo[i].replslotname ? dbinfo[i].replslotname : "(auto)",
dbinfo[i].pubconninfo);
- pg_log_debug("subscriber(%d): subscription: %s ; connection string: %s, --enable-two-phase: %s", i,
+ pg_log_debug("subscriber(%d): subscription: %s ; connection string: %s, two_phase: %s", i,
dbinfo[i].subname ? dbinfo[i].subname : "(auto)",
dbinfo[i].subconninfo,
dbinfo[i].two_phase ? "true" : "false");