@Override
    public void collect(RowData rowData) {
      count++;
      consumedValues.add(rowData);
    }
A source output that validates the output.
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/test/java/org/apache/amoro/flink/read/hidden/kafka/TestKafkaSourceReader.java