Oracle connnector capture data from XStreams is very slow in certain scenario

            // 2. receive events while running
            while(context.isRunning()) {
                LOGGER.trace("Receiving LCR");
                xsOut.receiveLCRCallback(handler, XStreamOut.DEFAULT_MODE);
            }

        try {
            Class.forName("oracle.jdbc.driver.OracleDriver");
            String xStreamOutServerName = "DBZXOUT_TEST";

            Connection connection = DriverManager.getConnection("jdbc:oracle:oci:@10.177.83.9:1521/ycdb", "xstrmadmin" , "xsa");

            byte[] scn = XStreamUtility.convertSCNToPosition(new NUMBER(15600869L));
            LCRHandler lcrHandler = new LCRHandler();
            XStreamOut xout = XStreamOut.attach((OracleConnection) connection, xStreamOutServerName, scn, XStreamOut.DEFAULT_MODE);
            System.out.println("start to run!");
            while (true) {
                whileCount++;
                System.out.println(whileCount);
                if(whileCount > 30) {
                    System.out.println("xout detached");
                    xout.detach(XStreamOut.DEFAULT_MODE);
                    break;
                } else {
                    xout.receiveLCRCallback(lcrHandler , XStreamOut.DEFAULT_MODE);
                }

            }
        } catch (Exception e) {
            e.printStackTrace();
        }

public class LCRHandler implements XStreamLCRCallbackHandler {
    private int count = 0;
    public void processLCR(LCR lcr) throws StreamsException {

        if(lcr.getCommandType().equals("COMMIT")){
            return;
        }
        try {
            count++;
            long pos = XStreamUtility.getSCNFromPosition(lcr.getPosition()).longValue();
            System.out.println(String.format("count:%s ,transcationId:%s , sourcetime: %s , commandtype: %s , pos:%s", count ,
                    lcr.getTransactionId(),
                    lcr.getSourceTime(),
                    lcr.getCommandType(),
                    pos));
        } catch (SQLException e) {
            e.printStackTrace();
        }

    }

    public void processChunk(ChunkColumnValue chunkColumnValue) throws StreamsException {

    }

    public LCR createLCR() throws StreamsException {
        return null;
    }

    public ChunkColumnValue createChunk() throws StreamsException {
        return null;
    }
}