StreamRecordConsumer
interface StreamRecordConsumer
Emits an Airbyte RECORD message for the Stream associated with this instance.
The purpose of this interface is twofold:
to encapsulate a performance-minded implementation behind a simple abstraction;
to decorate the RECORD messages with
a) meta-fields in the record data, and
b) field value changes and the motivating reason for these in the record metadata.Content copied to clipboard