[NIFI-12382] Add DatabaseTableSchemaRegistry Service

• Type: New Feature
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.25.0, 2.0.0-M2
• Component/s: Extensions
• Assignee: Matt Burgess
• Reporter: Matt Burgess
• Created: 16/Nov/23 21:53
• Updated: 20/Jan/24 03:08
• Resolved: 04/Jan/24 04:25

Description

Sometimes it is necessary to get the table definition from a database as a NiFi Record Schema. This can help ensure that data in the flow adheres to the table definition rather than relying on type conversions and such.

This case proposes to add a controller service called DatabaseSchemaRegistry that uses a DBCPService and a table name, fetches the table metadata from the database, and creates a RecordSchema from it.

Issue Links

• links to: GitHub Pull Request #8042