Below is the example handle duplicate rows in Oracle Streams.
BEGIN
DBMS_APPLY_ADM.SET_PARAMETER(
apply_name => 'STREAMS_APPLY',
parameter => 'allow_duplicate_rows',
value => 'Y');
END;
/
