--let $rpl_server_count= 2
--source include/have_group_replication_plugin.inc
--source include/group_replication.inc


connect (conn1,127.0.0.1,root,,test,$SERVER_MYPORT_1,);
connect (conn2,127.0.0.1,root,,test,$SERVER_MYPORT_2,);
--disable_query_log
connection conn2;
SET SESSION sql_log_bin= 0;
call mtr.add_suppression("Slave SQL for channel");
call mtr.add_suppression("Can't find record");
call mtr.add_suppression("Plugin group_replication reported");
SET SESSION sql_log_bin= 1;
--disable_query_log

--echo [connect conn1]
connection conn1;
select * from performance_schema.replication_group_members;
CREATE TABLE t1 (c1 INT NOT NULL PRIMARY KEY, c2 INT);
INSERT INTO t1 VALUES (1,1);
--source include/rpl_sync.inc

--echo [connect conn2]
connection conn2;
--source include/rpl_sync.inc
SELECT * FROM t1;

--echo [connect conn1]
connection conn1;
XA START 'trx1';
DELETE FROM t1 WHERE c1=1;

--echo [connect conn2]
connection conn2;
select * from performance_schema.replication_group_members;
DELETE FROM t1 WHERE c1=1;
--source include/rpl_sync.inc
SELECT * FROM t1;

--echo [connect conn1]
connection conn1;
XA END 'trx1';
--error ER_XA_RBROLLBACK
XA PREPARE 'trx1';
SELECT * FROM t1;

--echo [connect conn2]
connection conn2;
select * from performance_schema.replication_group_members;


--echo [connect conn1]
connection conn1;
SHOW BINLOG EVENTS;
--source include/group_replication_end.inc