pulsar-io/canal/src/main/java/org/apache/pulsar/io/canal/CanalAbstractSource.java [156:163]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        @Override
        public Optional<String> getKey() {
            return Optional.of(Long.toString(id));
        }

        @Override
        public V getValue() {
            return record;
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/source/AbstractSource.java [119:126]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        @Override
        public Optional<String> getKey() {
            return Optional.of(Long.toString(id));
        }

        @Override
        public V getValue() {
            return record;
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -