...
- Support for running multiple versions of the same component through additional versioning information provided in the NAR MANIFEST file
- Features/improvements related to Change Data Capture (CDC), including CaptureChangeMySQL, EnforceOrder, and PutDatabaseRecord processors, as well as a "Rollback on Failure" capability of some Put processors
- Provided two additional implementations of the Provenance Event Repository: WriteAheadProvenanceRepository, which is designed to be much faster than the PersistentProvenanceRepository; and EncryptedWriteAheadProvenanceRepository, which is capable of encrypting (and decrypting) the Provenance Events so that they are never written out as plain text on disk
- Introduced a record abstraction with controller services for reading and writing records from CSV, JSON, Avro, and Grok
- Added a new QueryRecord processor that allows SQL queries to be run over the contents of a FlowFile
- Added a new ConvertRecord processor that is capable of converting data between different data formats, using the above-mentioned controller services
- Added a new SplitRecord processor that is capable of splitting a large stream of record-oriented data into single records or smaller batches
- Added new processors for publishing record-oriented data to Kafka and consuming record-oriented data from Kafka (PublishKafkaRecord_0_10 and ConsumeKafkaRecord_0_10)
- Added new controller services for managing data schemas (AvroSchemaRegistry, HortonworksSchemaRegistry)
...