Cloudera exclusive components [Technical Preview]

Cloudera provides a set of NiFi components that are only available to its customers. Below you can find the list of these components.

In NiFi 1.25 clusters

Processors
  • CaptureChangeDebeziumDB2
  • CaptureChangeDebeziumMySQL
  • CaptureChangeDebeziumOracle
  • CaptureChangeDebeziumPostgreSQL
  • CaptureChangeDebeziumSQLServer
  • ConsumeKafka2CDP
  • ConsumeKafka2RecordCDP
  • ConvertProtobuf
  • DeleteCDPObjectStore
  • FetchCDPObjectStore
  • GetJiraIssue
  • InvokeGRPC
  • ListCDPObjectStore
  • ListenGRPC
  • ListenNetFlow
  • PublishKafka2CDP
  • PublishKafka2RecordCDP
  • PutCDPObjectStore
  • PutClouderaHiveQL
  • PutClouderaHiveStreaming
  • PutClouderaORC
  • PutIcebergCDC
  • PutJiraIssue
  • SelectClouderaHiveQL
  • TriggerClouderaHiveMetaStoreEvent
  • UpdateClouderaHiveTable
  • UpdateDeltaLakeTable
Controller Services
  • ActiveMQJMSConnectionFactoryProvider
  • ADLSIDBrokerCloudCredentialsProviderControllerService
  • AWSIDBrokerCloudCredentialsProviderControllerService
  • AzureBlobIDBrokerCloudCredentialsProviderControllerService
  • AzureServiceBusJMSConnectionFactoryProvider
  • CdpCredentialsProviderControllerService
  • CdpOauth2AccessTokenProviderControllerService
  • CiscoEmblemSyslogMessageReader
  • ClouderaHiveConnectionPool
  • ClouderaSchemaRegistry
  • CMLLookupService
  • EBCDICRecordReader
  • ImpalaConnectionPool
  • IPFIXReader
  • JiraRecordSink
  • PostgreSQLConnectionPool
  • RabbitMQJMSConnectionFactoryProvider
  • RedshiftConnectionPool
Parameter Providers
  • CyberArkConjurParameterProvider

In NiFi 2.0 clusters

Processors
  • CaptureChangeDebeziumDB2
  • CaptureChangeDebeziumMySQL
  • CaptureChangeDebeziumOracle
  • CaptureChangeDebeziumPostgreSQL
  • CaptureChangeDebeziumSQLServer
  • ConsumeKafka2CDP
  • ConsumeKafka2RecordCDP
  • ConsumePLC
  • ConvertProtobuf
  • DeleteCDPObjectStore
  • FetchCDPObjectStore
  • FetchPLC
  • GetJiraIssue
  • InvokeGRPC
  • ListCDPObjectStore
  • ListenGRPC
  • ListenNetFlow
  • PublishKafka2CDP
  • PublishKafka2RecordCDP
  • PutCDPObjectStore
  • PutClouderaHiveQL
  • PutClouderaHiveStreaming
  • PutClouderaORC
  • PutIcebergCDC
  • PutJiraIssue
  • PutPLC
  • SelectClouderaHiveQL
  • TriggerClouderaHiveMetaStoreEvent
  • UpdateClouderaHiveTable
  • UpdateDeltaLakeTable
Controller Services
  • ActiveMQJMSConnectionFactoryProvider
  • ADLSIDBrokerCloudCredentialsProviderControllerService
  • AWSIDBrokerCloudCredentialsProviderControllerService
  • AzureBlobIDBrokerCloudCredentialsProviderControllerService
  • AzureServiceBusJMSConnectionFactoryProvider
  • CdpCredentialsProviderControllerService
  • CdpOauth2AccessTokenProviderControllerService
  • CiscoEmblemSyslogMessageReader
  • ClouderaHiveConnectionPool
  • ClouderaSchemaRegistry
  • CMLLookupService
  • EBCDICRecordReader
  • GenericPLC4XConnectionPool
  • ImpalaConnectionPool
  • IPFIXReader
  • JiraRecordSink
  • PostgreSQLConnectionPool
  • ProxyPLC4XConnectionPool
  • RabbitMQJMSConnectionFactoryProvider
  • RedshiftConnectionPool
  • StandardPLC4XConnectionPool
Parameter Providers
  • CyberArkConjurParameterProvider