My configuration is a integrated downstream configuration

In this demo

extract ext1 -> pmp1 -> rep1 will process one table new_test1 of oggsrc schema

extract ext2 -> pmp2 -> rep2 will process one table new_test2 of oggsrc schema

extract ext3 -> pmp3 -> rep3 will process remaining tables of oggsrc schema

parameter files for extract

Extract ext1
userid oggadm@srcdb password Welcome1
tranlogoptions mininguser oggadmdwn@mngdb miningpassword Welcome1
tranlogoptions integratedparams (max_sga_size 128, downstream_real_time_mine Y)
exttrail ./dirdat/xa
DDL INCLUDE ALL
table oggsrc.new_test1;

Extract ext2
userid oggadm@srcdb password Welcome1
tranlogoptions mininguser oggadmdwn@mngdb miningpassword Welcome1
tranlogoptions integratedparams (max_sga_size 128, downstream_real_time_mine Y)
exttrail ./dirdat/xb
DDL INCLUDE ALL
table oggsrc.new_test2;

In ext3 we need to exclude new_test1 and new_test2 tables as they already been processed in ext1 and ext2. For this we will use TABLEEXCLUDE

Extract ext3
userid oggadm@srcdb password Welcome1
tranlogoptions mininguser oggadmdwn@mngdb miningpassword Welcome1
tranlogoptions integratedparams (max_sga_size 128, downstream_real_time_mine Y)
exttrail ./dirdat/xc
DDL INCLUDE ALL
TABLEEXCLUDE oggsrc.new_test1;
TABLEEXCLUDE oggsrc.new_test2;
table oggsrc.*;

register and add extract

ext1

GGSCI (oel6-node05.localdomain as oggadm@srcdb) 53> register extract ext1 database

2020-06-17 16:19:00  WARNING OGG-02064  Oracle compatibility version 11.2.0.0.0 has limited datatype support for integrated capture. Version 11.2.0.3 required for full support.

2020-06-17 16:19:11  INFO    OGG-02003  Extract EXT1 successfully registered with database at SCN 1683289.


GGSCI (oel6-node05.localdomain as oggadm@srcdb) 54> add extract ext1, integrated tranlog, begin now
EXTRACT (Integrated) added.


GGSCI (oel6-node05.localdomain as oggadm@srcdb) 55> add exttrail ./dirdat/xa, extract ext1, megabytes 10
EXTTRAIL added.

ext2

GGSCI (oel6-node05.localdomain as oggadm@srcdb) 56> register extract ext2 database

2020-06-17 16:20:06  WARNING OGG-02064  Oracle compatibility version 11.2.0.0.0 has limited datatype support for integrated capture. Version 11.2.0.3 required for full support.

2020-06-17 16:20:18  INFO    OGG-02003  Extract EXT2 successfully registered with database at SCN 1684114.


GGSCI (oel6-node05.localdomain as oggadm@srcdb) 57> add extract ext2, integrated tranlog, begin now
EXTRACT (Integrated) added.


GGSCI (oel6-node05.localdomain as oggadm@srcdb) 58> add exttrail ./dirdat/xb, extract ext2, megabytes 10
EXTTRAIL added.

ext3

GGSCI (oel6-node05.localdomain as oggadm@srcdb) 59> register extract ext3 database

2020-06-17 16:20:33  WARNING OGG-02064  Oracle compatibility version 11.2.0.0.0 has limited datatype support for integrated capture. Version 11.2.0.3 required for full support.

2020-06-17 16:20:44  INFO    OGG-02003  Extract EXT3 successfully registered with database at SCN 1684904.


GGSCI (oel6-node05.localdomain as oggadm@srcdb) 60> add extract ext3, integrated tranlog, begin now
EXTRACT (Integrated) added.


GGSCI (oel6-node05.localdomain as oggadm@srcdb) 61> add exttrail ./dirdat/xc, extract ext3, megabytes 10
EXTTRAIL added.

parameter files for pump

pump will be transeferring trail files xa, xb and xc generated from extract ext1, ext2 and ext3 respectively

pmp1

Extract pmp1
userid oggadm, password Welcome1
rmthost oel6-node04.localdomain, mgrport 7909
rmttrail ./dirdat/xa
passthru
--DDL INCLUDE ALL
table oggsrc.*;

pmp2

Extract pmp2
userid oggadm, password Welcome1
rmthost oel6-node04.localdomain, mgrport 7909
rmttrail ./dirdat/xb
passthru
--DDL INCLUDE ALL
table oggsrc.*;

pmp3

Extract pmp3
userid oggadm, password Welcome1
rmthost oel6-node04.localdomain, mgrport 7909
rmttrail ./dirdat/xc
passthru
--DDL INCLUDE ALL
table oggsrc.*;

add pump

GGSCI (oel6-node05.localdomain as oggadm@srcdb) 75> add extract pmp1, exttrailsource ./dirdat/xa
EXTRACT added.


GGSCI (oel6-node05.localdomain as oggadm@srcdb) 76> add rmttrail ./dirdat/xa, extract pmp1, megabytes 10
RMTTRAIL added.

GGSCI (oel6-node05.localdomain as oggadm@srcdb) 77> add extract pmp2, exttrailsource ./dirdat/xb
EXTRACT added.


GGSCI (oel6-node05.localdomain as oggadm@srcdb) 78> add rmttrail ./dirdat/xb, extract pmp2, megabytes 10
RMTTRAIL added.



GGSCI (oel6-node05.localdomain as oggadm@srcdb) 79> add extract pmp3, exttrailsource ./dirdat/xc
EXTRACT added.


GGSCI (oel6-node05.localdomain as oggadm@srcdb) 80> add rmttrail ./dirdat/xc, extract pmp3, megabytes 10
RMTTRAIL added.

start extract and pump

extract

GGSCI (oel6-node05.localdomain as oggadm@srcdb) 62> start extract ext1

Sending START request to MANAGER ...
EXTRACT EXT1 starting


GGSCI (oel6-node05.localdomain as oggadm@srcdb) 63>  start extract ext2

Sending START request to MANAGER ...
EXTRACT EXT2 starting


GGSCI (oel6-node05.localdomain as oggadm@srcdb) 64>  start extract ext3

Sending START request to MANAGER ...
EXTRACT EXT3 starting

pump

GGSCI (oel6-node05.localdomain as oggadm@srcdb) 82> start extract pmp1

Sending START request to MANAGER ...
EXTRACT PMP1 starting


GGSCI (oel6-node05.localdomain as oggadm@srcdb) 83> start extract pmp2

Sending START request to MANAGER ...
EXTRACT PMP2 starting


GGSCI (oel6-node05.localdomain as oggadm@srcdb) 84> start extract pmp3

Sending START request to MANAGER ...
EXTRACT PMP3 starting

check status

GGSCI (oel6-node05.localdomain as oggadm@srcdb) 99> info all

Program     Status      Group       Lag at Chkpt  Time Since Chkpt

MANAGER     RUNNING
EXTRACT     RUNNING     EXT1        00:00:05      00:00:05
EXTRACT     RUNNING     EXT2        00:00:03      00:00:07
EXTRACT     RUNNING     EXT3        00:00:02      00:00:01
EXTRACT     STOPPED     EXT_123     00:00:06      04:59:14
EXTRACT     STOPPED     EXT_MPLX    00:00:03      02:16:09
EXTRACT     RUNNING     PMP1        00:00:00      00:00:05
EXTRACT     RUNNING     PMP2        00:00:00      00:00:08
EXTRACT     RUNNING     PMP3        00:00:00      00:00:08
EXTRACT     STOPPED     PMP_123     00:00:00      04:59:13

verify trail files associated with right extract and pump

./dirdat/xa with ext1 and pmp1

GGSCI (oel6-node05.localdomain as oggadm@srcdb) 96> info exttrail ./dirdat/xa

       Extract Trail: ./dirdat/xa
        Seqno Length: 9
   Flip Seqno Length: no
             Extract: EXT1
               Seqno: 0
                 RBA: 2171
           File Size: 10M

       Extract Trail: ./dirdat/xa
        Seqno Length: 9
   Flip Seqno Length: no
             Extract: EXT_MPLX
               Seqno: 0
                 RBA: 21913
           File Size: 10M

       Extract Trail: ./dirdat/xa
        Seqno Length: 9
   Flip Seqno Length: no
             Extract: PMP1
               Seqno: 0
                 RBA: 2242
           File Size: 10M

./dirdat/xb with ext2 and pmp2

GGSCI (oel6-node05.localdomain as oggadm@srcdb) 97> info exttrail ./dirdat/xb

       Extract Trail: ./dirdat/xb
        Seqno Length: 9
   Flip Seqno Length: no
             Extract: EXT2
               Seqno: 0
                 RBA: 2172
           File Size: 10M

       Extract Trail: ./dirdat/xb
        Seqno Length: 9
   Flip Seqno Length: no
             Extract: EXT_MPLX
               Seqno: 0
                 RBA: 21913
           File Size: 10M

       Extract Trail: ./dirdat/xb
        Seqno Length: 9
   Flip Seqno Length: no
             Extract: PMP2
               Seqno: 0
                 RBA: 2243
           File Size: 10M

./dirdat/xc with ext3 and pmp3

GGSCI (oel6-node05.localdomain as oggadm@srcdb) 98> info exttrail ./dirdat/xc

       Extract Trail: ./dirdat/xc
        Seqno Length: 9
   Flip Seqno Length: no
             Extract: EXT3
               Seqno: 0
                 RBA: 2569
           File Size: 10M

       Extract Trail: ./dirdat/xc
        Seqno Length: 9
   Flip Seqno Length: no
             Extract: EXT_MPLX
               Seqno: 0
                 RBA: 24862
           File Size: 10M

       Extract Trail: ./dirdat/xc
        Seqno Length: 9
   Flip Seqno Length: no
             Extract: PMP3
               Seqno: 0
                 RBA: 2640
           File Size: 10M

parameter file for replicat

rep1

Replicat rep1
SETENV(ORACLE_HOME="/u01/app/oracle/product/11.2.0/db_1")
SETENV(ORACLE_SID = "tgtdb")
AssumeTargetDefs
DiscardFile ./dirrpt/rep1.dsc, Purge
UserID oggadm, Password Welcome1
--showsyntax
DDL INCLUDE ALL
DDLERROR DEFAULT IGNORE
map oggsrc.new_test1, target oggtrg.*;

rep2 – for demo i have taken different map statement but it is same as rep1. so you can use wildcard in target or full table name.

don’t use partial name with wild card like

(map oggsrc.new_test2, target oggtrg.new*) it will be used as (oggtrg.newnew_test2) which is incorrect

Replicat rep2
SETENV(ORACLE_HOME="/u01/app/oracle/product/11.2.0/db_1")
SETENV(ORACLE_SID = "tgtdb")
AssumeTargetDefs
DiscardFile ./dirrpt/rep2.dsc, Purge
UserID oggadm, Password Welcome1
--showsyntax
DDL INCLUDE ALL
DDLERROR DEFAULT IGNORE
map oggsrc.new_test2, target oggtrg.new_test2;

rep3 – it will exclude tables new_test1 and new_test2. and will serve as mapping for remaining tables

Replicat rep3
SETENV(ORACLE_HOME="/u01/app/oracle/product/11.2.0/db_1")
SETENV(ORACLE_SID = "tgtdb")
AssumeTargetDefs
DiscardFile ./dirrpt/rep3.dsc, Purge
UserID oggadm, Password Welcome1
--showsyntax
DDL INCLUDE ALL
DDLERROR DEFAULT IGNORE
MAPEXCLUDE oggsrc.new_test1;
MAPEXCLUDE oggsrc.new_test2;
map oggsrc.*, target oggtrg.*;

add replicat

GGSCI (oel6-node04.localdomain) 113> add replicat rep1 , exttrail ./dirdat/xa, nodbcheckpoint
REPLICAT added.


GGSCI (oel6-node04.localdomain) 114> add replicat rep2 , exttrail ./dirdat/xb, nodbcheckpoint
REPLICAT added.


GGSCI (oel6-node04.localdomain) 115> add replicat rep3 , exttrail ./dirdat/xc, nodbcheckpoint

REPLICAT added.

start replicat

GGSCI (oel6-node04.localdomain) 117> start replicat rep1

Sending START request to MANAGER ...
REPLICAT REP1 starting


GGSCI (oel6-node04.localdomain) 118> start replicat rep2

Sending START request to MANAGER ...
REPLICAT REP2 starting


GGSCI (oel6-node04.localdomain) 119> start replicat rep3

Sending START request to MANAGER ...
REPLICAT REP3 starting

verify replicat status

GGSCI (oel6-node04.localdomain) 129> info all

Program     Status      Group       Lag at Chkpt  Time Since Chkpt

MANAGER     RUNNING
REPLICAT    RUNNING     REP1        00:00:00      00:00:03
REPLICAT    RUNNING     REP2        00:00:00      00:00:08
REPLICAT    RUNNING     REP3        00:00:00      00:00:08
REPLICAT    STOPPED     REP_123     00:00:00      04:51:33

Now you can test the replication