-
Processors
-
AttributeRollingWindow 2.6.0.4.12.0.0-907
-
AttributesToCSV 2.6.0.4.12.0.0-907
-
AttributesToJSON 2.6.0.4.12.0.0-907
-
CalculateParquetOffsets 2.6.0.4.12.0.0-907
-
CalculateParquetRowGroupOffsets 2.6.0.4.12.0.0-907
-
CalculateRecordStats 2.6.0.4.12.0.0-907
-
CaptureChangeDebeziumDB2 2.6.0.4.12.0.0-907
-
CaptureChangeDebeziumMongoDB 2.6.0.4.12.0.0-907
-
CaptureChangeDebeziumMySQL 2.6.0.4.12.0.0-907
-
CaptureChangeDebeziumOracle 2.6.0.4.12.0.0-907
-
CaptureChangeDebeziumPostgreSQL 2.6.0.4.12.0.0-907
-
CaptureChangeDebeziumSQLServer 2.6.0.4.12.0.0-907
-
CaptureChangeMySQL 2.6.0.4.12.0.0-907
-
CompressContent 2.6.0.4.12.0.0-907
-
ConnectWebSocket 2.6.0.4.12.0.0-907
-
ConsumeAMQP 2.6.0.4.12.0.0-907
-
ConsumeAzureEventHub 2.6.0.4.12.0.0-907
-
ConsumeBoxEnterpriseEvents 2.6.0.4.12.0.0-907
-
ConsumeBoxEvents 2.6.0.4.12.0.0-907
-
ConsumeElasticsearch 2.6.0.4.12.0.0-907
-
ConsumeGCPubSub 2.6.0.4.12.0.0-907
-
ConsumeIMAP 2.6.0.4.12.0.0-907
-
ConsumeJMS 2.6.0.4.12.0.0-907
-
ConsumeKafka 2.6.0.4.12.0.0-907
-
ConsumeKafka_2_6 2.6.0.4.12.0.0-907
-
ConsumeKafka2CDP 2.6.0.4.12.0.0-907
-
ConsumeKafka2RecordCDP 2.6.0.4.12.0.0-907
-
ConsumeKafkaRecord_2_6 2.6.0.4.12.0.0-907
-
ConsumeKinesisStream 2.6.0.4.12.0.0-907
-
ConsumeMQTT 2.6.0.4.12.0.0-907
-
ConsumeMQTTIIoT 2.6.0.4.12.0.0-907
-
ConsumePLC 2.6.0.4.12.0.0-907
-
ConsumePOP3 2.6.0.4.12.0.0-907
-
ConsumeSlack 2.6.0.4.12.0.0-907
-
ConsumeTwitter 2.6.0.4.12.0.0-907
-
ConsumeWindowsEventLog 2.6.0.4.12.0.0-907
-
ControlRate 2.6.0.4.12.0.0-907
-
ConvertAvroToParquet 2.6.0.4.12.0.0-907
-
ConvertCharacterSet 2.6.0.4.12.0.0-907
-
ConvertProtobuf 2.6.0.4.12.0.0-907
-
ConvertRecord 2.6.0.4.12.0.0-907
-
CopyAzureBlobStorage_v12 2.6.0.4.12.0.0-907
-
CopyS3Object 2.6.0.4.12.0.0-907
-
CountText 2.6.0.4.12.0.0-907
-
CreateBoxFileMetadataInstance 2.6.0.4.12.0.0-907
-
CreateBoxMetadataTemplate 2.6.0.4.12.0.0-907
-
CreateHadoopSequenceFile 2.6.0.4.12.0.0-907
-
CryptographicHashContent 2.6.0.4.12.0.0-907
-
DebugFlow 2.6.0.4.12.0.0-907
-
DecryptContentAge 2.6.0.4.12.0.0-907
-
DecryptContentPGP 2.6.0.4.12.0.0-907
-
DeduplicateRecord 2.6.0.4.12.0.0-907
-
DeleteAzureBlobStorage_v12 2.6.0.4.12.0.0-907
-
DeleteAzureDataLakeStorage 2.6.0.4.12.0.0-907
-
DeleteBoxFileMetadataInstance 2.6.0.4.12.0.0-907
-
DeleteByQueryElasticsearch 2.6.0.4.12.0.0-907
-
DeleteCDPObjectStore 2.6.0.4.12.0.0-907
-
DeleteDynamoDB 2.6.0.4.12.0.0-907
-
DeleteFile 2.6.0.4.12.0.0-907
-
DeleteGCSObject 2.6.0.4.12.0.0-907
-
DeleteGridFS 2.6.0.4.12.0.0-907
-
DeleteHBaseCells 2.6.0.4.12.0.0-907
-
DeleteHBaseRow 2.6.0.4.12.0.0-907
-
DeleteHDFS 2.6.0.4.12.0.0-907
-
DeleteMongo 2.6.0.4.12.0.0-907
-
DeleteS3Object 2.6.0.4.12.0.0-907
-
DeleteSFTP 2.6.0.4.12.0.0-907
-
DeleteSQS 2.6.0.4.12.0.0-907
-
DetectDuplicate 2.6.0.4.12.0.0-907
-
DistributeLoad 2.6.0.4.12.0.0-907
-
DuplicateFlowFile 2.6.0.4.12.0.0-907
-
EncodeContent 2.6.0.4.12.0.0-907
-
EncryptContentAge 2.6.0.4.12.0.0-907
-
EncryptContentPGP 2.6.0.4.12.0.0-907
-
EnforceOrder 2.6.0.4.12.0.0-907
-
EvaluateJsonPath 2.6.0.4.12.0.0-907
-
EvaluateXPath 2.6.0.4.12.0.0-907
-
EvaluateXQuery 2.6.0.4.12.0.0-907
-
ExecuteGraphQuery 2.6.0.4.12.0.0-907
-
ExecuteGraphQueryRecord 2.6.0.4.12.0.0-907
-
ExecuteGroovyScript 2.6.0.4.12.0.0-907
-
ExecuteProcess 2.6.0.4.12.0.0-907
-
ExecuteScript 2.6.0.4.12.0.0-907
-
ExecuteSparkInteractive 2.6.0.4.12.0.0-907
-
ExecuteSQL 2.6.0.4.12.0.0-907
-
ExecuteSQLRecord 2.6.0.4.12.0.0-907
-
ExecuteStreamCommand 2.6.0.4.12.0.0-907
-
ExtractAvroMetadata 2.6.0.4.12.0.0-907
-
ExtractDocumentText 2.6.0.4.12.0.0-907
-
ExtractEmailAttachments 2.6.0.4.12.0.0-907
-
ExtractEmailHeaders 2.6.0.4.12.0.0-907
-
ExtractGrok 2.6.0.4.12.0.0-907
-
ExtractHL7Attributes 2.6.0.4.12.0.0-907
-
ExtractImageMetadata 2.6.0.4.12.0.0-907
-
ExtractMediaMetadata 2.6.0.4.12.0.0-907
-
ExtractRecordSchema 2.6.0.4.12.0.0-907
-
ExtractStructuredBoxFileMetadata 2.6.0.4.12.0.0-907
-
ExtractText 2.6.0.4.12.0.0-907
-
FetchAzureBlobStorage_v12 2.6.0.4.12.0.0-907
-
FetchAzureDataLakeStorage 2.6.0.4.12.0.0-907
-
FetchBoxFile 2.6.0.4.12.0.0-907
-
FetchBoxFileInfo 2.6.0.4.12.0.0-907
-
FetchBoxFileMetadataInstance 2.6.0.4.12.0.0-907
-
FetchBoxFileRepresentation 2.6.0.4.12.0.0-907
-
FetchCDPObjectStore 2.6.0.4.12.0.0-907
-
FetchDistributedMapCache 2.6.0.4.12.0.0-907
-
FetchDropbox 2.6.0.4.12.0.0-907
-
FetchFile 2.6.0.4.12.0.0-907
-
FetchFTP 2.6.0.4.12.0.0-907
-
FetchGCSObject 2.6.0.4.12.0.0-907
-
FetchGoogleDrive 2.6.0.4.12.0.0-907
-
FetchGridFS 2.6.0.4.12.0.0-907
-
FetchHBaseRow 2.6.0.4.12.0.0-907
-
FetchHDFS 2.6.0.4.12.0.0-907
-
FetchParquet 2.6.0.4.12.0.0-907
-
FetchPLC 2.6.0.4.12.0.0-907
-
FetchS3Object 2.6.0.4.12.0.0-907
-
FetchSFTP 2.6.0.4.12.0.0-907
-
FetchSmb 2.6.0.4.12.0.0-907
-
FilterAttribute 2.6.0.4.12.0.0-907
-
FlattenJson 2.6.0.4.12.0.0-907
-
ForkEnrichment 2.6.0.4.12.0.0-907
-
ForkRecord 2.6.0.4.12.0.0-907
-
GenerateFlowFile 2.6.0.4.12.0.0-907
-
GenerateRecord 2.6.0.4.12.0.0-907
-
GenerateTableFetch 2.6.0.4.12.0.0-907
-
GeoEnrichIP 2.6.0.4.12.0.0-907
-
GeoEnrichIPRecord 2.6.0.4.12.0.0-907
-
GeohashRecord 2.6.0.4.12.0.0-907
-
GetAsanaObject 2.6.0.4.12.0.0-907
-
GetAwsPollyJobStatus 2.6.0.4.12.0.0-907
-
GetAwsTextractJobStatus 2.6.0.4.12.0.0-907
-
GetAwsTranscribeJobStatus 2.6.0.4.12.0.0-907
-
GetAwsTranslateJobStatus 2.6.0.4.12.0.0-907
-
GetAzureEventHub 2.6.0.4.12.0.0-907
-
GetAzureQueueStorage_v12 2.6.0.4.12.0.0-907
-
GetBoxFileCollaborators 2.6.0.4.12.0.0-907
-
GetBoxGroupMembers 2.6.0.4.12.0.0-907
-
GetCouchbase 2.6.0.4.12.0.0-907
-
GetDynamoDB 2.6.0.4.12.0.0-907
-
GetElasticsearch 2.6.0.4.12.0.0-907
-
GetFile 2.6.0.4.12.0.0-907
-
GetFileResource 2.6.0.4.12.0.0-907
-
GetFTP 2.6.0.4.12.0.0-907
-
GetGcpVisionAnnotateFilesOperationStatus 2.6.0.4.12.0.0-907
-
GetGcpVisionAnnotateImagesOperationStatus 2.6.0.4.12.0.0-907
-
GetHBase 2.6.0.4.12.0.0-907
-
GetHDFS 2.6.0.4.12.0.0-907
-
GetHDFSEvents 2.6.0.4.12.0.0-907
-
GetHDFSFileInfo 2.6.0.4.12.0.0-907
-
GetHDFSSequenceFile 2.6.0.4.12.0.0-907
-
GetHubSpot 2.6.0.4.12.0.0-907
-
GetJiraIssue 2.6.0.4.12.0.0-907
-
GetMongo 2.6.0.4.12.0.0-907
-
GetMongoRecord 2.6.0.4.12.0.0-907
-
GetS3ObjectMetadata 2.6.0.4.12.0.0-907
-
GetS3ObjectTags 2.6.0.4.12.0.0-907
-
GetSFTP 2.6.0.4.12.0.0-907
-
GetShopify 2.6.0.4.12.0.0-907
-
GetSlackReaction 2.6.0.4.12.0.0-907
-
GetSmbFile 2.6.0.4.12.0.0-907
-
GetSNMP 2.6.0.4.12.0.0-907
-
GetSnowflakeIngestStatus 2.6.0.4.12.0.0-907
-
GetSolr 2.6.0.4.12.0.0-907
-
GetSplunk 2.6.0.4.12.0.0-907
-
GetSQS 2.6.0.4.12.0.0-907
-
GetTCP 2.6.0.4.12.0.0-907
-
GetWorkdayReport 2.6.0.4.12.0.0-907
-
GetZendesk 2.6.0.4.12.0.0-907
-
HandleHttpRequest 2.6.0.4.12.0.0-907
-
HandleHttpResponse 2.6.0.4.12.0.0-907
-
IdentifyMimeType 2.6.0.4.12.0.0-907
-
InvokeGRPC 2.6.0.4.12.0.0-907
-
InvokeHTTP 2.6.0.4.12.0.0-907
-
InvokeScriptedProcessor 2.6.0.4.12.0.0-907
-
ISPEnrichIP 2.6.0.4.12.0.0-907
-
JoinEnrichment 2.6.0.4.12.0.0-907
-
JoltTransformJSON 2.6.0.4.12.0.0-907
-
JoltTransformRecord 2.6.0.4.12.0.0-907
-
JSLTTransformJSON 2.6.0.4.12.0.0-907
-
JsonQueryElasticsearch 2.6.0.4.12.0.0-907
-
ListAzureBlobStorage_v12 2.6.0.4.12.0.0-907
-
ListAzureDataLakeStorage 2.6.0.4.12.0.0-907
-
ListBoxFile 2.6.0.4.12.0.0-907
-
ListBoxFileInfo 2.6.0.4.12.0.0-907
-
ListBoxFileMetadataInstances 2.6.0.4.12.0.0-907
-
ListBoxFileMetadataTemplates 2.6.0.4.12.0.0-907
-
ListCDPObjectStore 2.6.0.4.12.0.0-907
-
ListDatabaseTables 2.6.0.4.12.0.0-907
-
ListDropbox 2.6.0.4.12.0.0-907
-
ListenBeats 2.6.0.4.12.0.0-907
-
ListenFTP 2.6.0.4.12.0.0-907
-
ListenGRPC 2.6.0.4.12.0.0-907
-
ListenHTTP 2.6.0.4.12.0.0-907
-
ListenNetFlow 2.6.0.4.12.0.0-907
-
ListenOTLP 2.6.0.4.12.0.0-907
-
ListenSlack 2.6.0.4.12.0.0-907
-
ListenSyslog 2.6.0.4.12.0.0-907
-
ListenTCP 2.6.0.4.12.0.0-907
-
ListenTrapSNMP 2.6.0.4.12.0.0-907
-
ListenUDP 2.6.0.4.12.0.0-907
-
ListenUDPRecord 2.6.0.4.12.0.0-907
-
ListenWebSocket 2.6.0.4.12.0.0-907
-
ListFile 2.6.0.4.12.0.0-907
-
ListFTP 2.6.0.4.12.0.0-907
-
ListGCSBucket 2.6.0.4.12.0.0-907
-
ListGoogleDrive 2.6.0.4.12.0.0-907
-
ListHBaseRegions 2.6.0.4.12.0.0-907
-
ListHDFS 2.6.0.4.12.0.0-907
-
ListS3 2.6.0.4.12.0.0-907
-
ListSFTP 2.6.0.4.12.0.0-907
-
ListSmb 2.6.0.4.12.0.0-907
-
LogAttribute 2.6.0.4.12.0.0-907
-
LogMessage 2.6.0.4.12.0.0-907
-
LookupAttribute 2.6.0.4.12.0.0-907
-
LookupRecord 2.6.0.4.12.0.0-907
-
MergeContent 2.6.0.4.12.0.0-907
-
MergeRecord 2.6.0.4.12.0.0-907
-
ModifyBytes 2.6.0.4.12.0.0-907
-
ModifyCompression 2.6.0.4.12.0.0-907
-
MonitorActivity 2.6.0.4.12.0.0-907
-
MoveAzureDataLakeStorage 2.6.0.4.12.0.0-907
-
MoveHDFS 2.6.0.4.12.0.0-907
-
Notify 2.6.0.4.12.0.0-907
-
PackageFlowFile 2.6.0.4.12.0.0-907
-
PaginatedJsonQueryElasticsearch 2.6.0.4.12.0.0-907
-
ParseEvtx 2.6.0.4.12.0.0-907
-
ParseNetflowv5 2.6.0.4.12.0.0-907
-
ParseSyslog 2.6.0.4.12.0.0-907
-
ParseSyslog5424 2.6.0.4.12.0.0-907
-
PartitionRecord 2.6.0.4.12.0.0-907
-
PublishAMQP 2.6.0.4.12.0.0-907
-
PublishGCPubSub 2.6.0.4.12.0.0-907
-
PublishJMS 2.6.0.4.12.0.0-907
-
PublishKafka 2.6.0.4.12.0.0-907
-
PublishKafka_2_6 2.6.0.4.12.0.0-907
-
PublishKafka2CDP 2.6.0.4.12.0.0-907
-
PublishKafka2RecordCDP 2.6.0.4.12.0.0-907
-
PublishKafkaRecord_2_6 2.6.0.4.12.0.0-907
-
PublishMQTT 2.6.0.4.12.0.0-907
-
PublishSlack 2.6.0.4.12.0.0-907
-
PutAccumuloRecord 2.6.0.4.12.0.0-907
-
PutAzureBlobStorage_v12 2.6.0.4.12.0.0-907
-
PutAzureCosmosDBRecord 2.6.0.4.12.0.0-907
-
PutAzureDataExplorer 2.6.0.4.12.0.0-907
-
PutAzureDataLakeStorage 2.6.0.4.12.0.0-907
-
PutAzureEventHub 2.6.0.4.12.0.0-907
-
PutAzureQueueStorage_v12 2.6.0.4.12.0.0-907
-
PutBigQuery 2.6.0.4.12.0.0-907
-
PutBoxFile 2.6.0.4.12.0.0-907
-
PutCassandraQL 2.6.0.4.12.0.0-907
-
PutCassandraRecord 2.6.0.4.12.0.0-907
-
PutCDPObjectStore 2.6.0.4.12.0.0-907
-
PutClouderaHiveQL 2.6.0.4.12.0.0-907
-
PutClouderaHiveStreaming 2.6.0.4.12.0.0-907
-
PutClouderaORC 2.6.0.4.12.0.0-907
-
PutCloudWatchMetric 2.6.0.4.12.0.0-907
-
PutCouchbase 2.6.0.4.12.0.0-907
-
PutDatabaseRecord 2.6.0.4.12.0.0-907
-
PutDistributedMapCache 2.6.0.4.12.0.0-907
-
PutDropbox 2.6.0.4.12.0.0-907
-
PutDynamoDB 2.6.0.4.12.0.0-907
-
PutDynamoDBRecord 2.6.0.4.12.0.0-907
-
PutElasticsearchJson 2.6.0.4.12.0.0-907
-
PutElasticsearchRecord 2.6.0.4.12.0.0-907
-
PutEmail 2.6.0.4.12.0.0-907
-
PutFile 2.6.0.4.12.0.0-907
-
PutFTP 2.6.0.4.12.0.0-907
-
PutGCSObject 2.6.0.4.12.0.0-907
-
PutGoogleDrive 2.6.0.4.12.0.0-907
-
PutGridFS 2.6.0.4.12.0.0-907
-
PutHBaseCell 2.6.0.4.12.0.0-907
-
PutHBaseJSON 2.6.0.4.12.0.0-907
-
PutHBaseRecord 2.6.0.4.12.0.0-907
-
PutHDFS 2.6.0.4.12.0.0-907
-
PutIceberg 2.6.0.4.12.0.0-907
-
PutIcebergCDC 2.6.0.4.12.0.0-907
-
PutIoTDBRecord 2.6.0.4.12.0.0-907
-
PutJiraIssue 2.6.0.4.12.0.0-907
-
PutKinesisFirehose 2.6.0.4.12.0.0-907
-
PutKinesisStream 2.6.0.4.12.0.0-907
-
PutKudu 2.6.0.4.12.0.0-907
-
PutLambda 2.6.0.4.12.0.0-907
-
PutMongo 2.6.0.4.12.0.0-907
-
PutMongoBulkOperations 2.6.0.4.12.0.0-907
-
PutMongoRecord 2.6.0.4.12.0.0-907
-
PutParquet 2.6.0.4.12.0.0-907
-
PutPLC 2.6.0.4.12.0.0-907
-
PutRecord 2.6.0.4.12.0.0-907
-
PutRedisHashRecord 2.6.0.4.12.0.0-907
-
PutS3Object 2.6.0.4.12.0.0-907
-
PutSalesforceObject 2.6.0.4.12.0.0-907
-
PutSFTP 2.6.0.4.12.0.0-907
-
PutSmbFile 2.6.0.4.12.0.0-907
-
PutSnowflakeInternalStage 2.6.0.4.12.0.0-907
-
PutSNS 2.6.0.4.12.0.0-907
-
PutSolrContentStream 2.6.0.4.12.0.0-907
-
PutSolrRecord 2.6.0.4.12.0.0-907
-
PutSplunk 2.6.0.4.12.0.0-907
-
PutSplunkHTTP 2.6.0.4.12.0.0-907
-
PutSQL 2.6.0.4.12.0.0-907
-
PutSQS 2.6.0.4.12.0.0-907
-
PutSyslog 2.6.0.4.12.0.0-907
-
PutTCP 2.6.0.4.12.0.0-907
-
PutUDP 2.6.0.4.12.0.0-907
-
PutWebSocket 2.6.0.4.12.0.0-907
-
PutZendeskTicket 2.6.0.4.12.0.0-907
-
QueryAirtableTable 2.6.0.4.12.0.0-907
-
QueryAzureDataExplorer 2.6.0.4.12.0.0-907
-
QueryCassandra 2.6.0.4.12.0.0-907
-
QueryDatabaseTable 2.6.0.4.12.0.0-907
-
QueryDatabaseTableRecord 2.6.0.4.12.0.0-907
-
QueryIoTDBRecord 2.6.0.4.12.0.0-907
-
QueryRecord 2.6.0.4.12.0.0-907
-
QuerySalesforceObject 2.6.0.4.12.0.0-907
-
QuerySolr 2.6.0.4.12.0.0-907
-
QuerySplunkIndexingStatus 2.6.0.4.12.0.0-907
-
RemoveRecordField 2.6.0.4.12.0.0-907
-
RenameRecordField 2.6.0.4.12.0.0-907
-
ReplaceText 2.6.0.4.12.0.0-907
-
ReplaceTextWithMapping 2.6.0.4.12.0.0-907
-
ResizeImage 2.6.0.4.12.0.0-907
-
RetryFlowFile 2.6.0.4.12.0.0-907
-
RouteHL7 2.6.0.4.12.0.0-907
-
RouteOnAttribute 2.6.0.4.12.0.0-907
-
RouteOnContent 2.6.0.4.12.0.0-907
-
RouteText 2.6.0.4.12.0.0-907
-
RunMongoAggregation 2.6.0.4.12.0.0-907
-
SampleRecord 2.6.0.4.12.0.0-907
-
SawmillTransformJSON 2.6.0.4.12.0.0-907
-
SawmillTransformRecord 2.6.0.4.12.0.0-907
-
ScanAccumulo 2.6.0.4.12.0.0-907
-
ScanAttribute 2.6.0.4.12.0.0-907
-
ScanContent 2.6.0.4.12.0.0-907
-
ScanHBase 2.6.0.4.12.0.0-907
-
ScriptedFilterRecord 2.6.0.4.12.0.0-907
-
ScriptedPartitionRecord 2.6.0.4.12.0.0-907
-
ScriptedTransformRecord 2.6.0.4.12.0.0-907
-
ScriptedValidateRecord 2.6.0.4.12.0.0-907
-
SearchElasticsearch 2.6.0.4.12.0.0-907
-
SegmentContent 2.6.0.4.12.0.0-907
-
SelectClouderaHiveQL 2.6.0.4.12.0.0-907
-
SendTrapSNMP 2.6.0.4.12.0.0-907
-
SetSNMP 2.6.0.4.12.0.0-907
-
SignContentPGP 2.6.0.4.12.0.0-907
-
SplitAvro 2.6.0.4.12.0.0-907
-
SplitContent 2.6.0.4.12.0.0-907
-
SplitExcel 2.6.0.4.12.0.0-907
-
SplitJson 2.6.0.4.12.0.0-907
-
SplitPCAP 2.6.0.4.12.0.0-907
-
SplitRecord 2.6.0.4.12.0.0-907
-
SplitText 2.6.0.4.12.0.0-907
-
SplitXml 2.6.0.4.12.0.0-907
-
StartAwsPollyJob 2.6.0.4.12.0.0-907
-
StartAwsTextractJob 2.6.0.4.12.0.0-907
-
StartAwsTranscribeJob 2.6.0.4.12.0.0-907
-
StartAwsTranslateJob 2.6.0.4.12.0.0-907
-
StartGcpVisionAnnotateFilesOperation 2.6.0.4.12.0.0-907
-
StartGcpVisionAnnotateImagesOperation 2.6.0.4.12.0.0-907
-
StartSnowflakeIngest 2.6.0.4.12.0.0-907
-
TagS3Object 2.6.0.4.12.0.0-907
-
TailFile 2.6.0.4.12.0.0-907
-
TransformXml 2.6.0.4.12.0.0-907
-
TriggerClouderaHiveMetaStoreEvent 2.6.0.4.12.0.0-907
-
UnpackContent 2.6.0.4.12.0.0-907
-
UpdateAttribute 2.6.0.4.12.0.0-907
-
UpdateBoxFileMetadataInstance 2.6.0.4.12.0.0-907
-
UpdateByQueryElasticsearch 2.6.0.4.12.0.0-907
-
UpdateClouderaHiveTable 2.6.0.4.12.0.0-907
-
UpdateCounter 2.6.0.4.12.0.0-907
-
UpdateDatabaseTable 2.6.0.4.12.0.0-907
-
UpdateDeltaLakeTable 2.6.0.4.12.0.0-907
-
UpdateJiraIssue 2.6.0.4.12.0.0-907
-
UpdateRecord 2.6.0.4.12.0.0-907
-
ValidateCsv 2.6.0.4.12.0.0-907
-
ValidateJson 2.6.0.4.12.0.0-907
-
ValidateRecord 2.6.0.4.12.0.0-907
-
ValidateXml 2.6.0.4.12.0.0-907
-
VerifyContentMAC 2.6.0.4.12.0.0-907
-
VerifyContentPGP 2.6.0.4.12.0.0-907
-
Wait 2.6.0.4.12.0.0-907
-
-
Controller Services
-
AccumuloService 2.6.0.4.12.0.0-907
-
ActiveMQJMSConnectionFactoryProvider 2.6.0.4.12.0.0-907
-
ADLSCredentialsControllerService 2.6.0.4.12.0.0-907
-
ADLSCredentialsControllerServiceLookup 2.6.0.4.12.0.0-907
-
ADLSIDBrokerCloudCredentialsProviderControllerService 2.6.0.4.12.0.0-907
-
AmazonGlueEncodedSchemaReferenceReader 2.6.0.4.12.0.0-907
-
AmazonGlueSchemaRegistry 2.6.0.4.12.0.0-907
-
AmazonMSKConnectionService 2.6.0.4.12.0.0-907
-
ApicurioSchemaRegistry 2.6.0.4.12.0.0-907
-
AvroReader 2.6.0.4.12.0.0-907
-
AvroRecordSetWriter 2.6.0.4.12.0.0-907
-
AvroSchemaRegistry 2.6.0.4.12.0.0-907
-
AWSCredentialsProviderControllerService 2.6.0.4.12.0.0-907
-
AWSIDBrokerCloudCredentialsProviderControllerService 2.6.0.4.12.0.0-907
-
AzureBlobIDBrokerCloudCredentialsProviderControllerService 2.6.0.4.12.0.0-907
-
AzureBlobStorageFileResourceService 2.6.0.4.12.0.0-907
-
AzureCosmosDBClientService 2.6.0.4.12.0.0-907
-
AzureDataLakeStorageFileResourceService 2.6.0.4.12.0.0-907
-
AzureEventHubRecordSink 2.6.0.4.12.0.0-907
-
AzureServiceBusJMSConnectionFactoryProvider 2.6.0.4.12.0.0-907
-
AzureStorageCredentialsControllerService_v12 2.6.0.4.12.0.0-907
-
AzureStorageCredentialsControllerServiceLookup_v12 2.6.0.4.12.0.0-907
-
CassandraDistributedMapCache 2.6.0.4.12.0.0-907
-
CassandraSessionProvider 2.6.0.4.12.0.0-907
-
CdpCredentialsProviderControllerService 2.6.0.4.12.0.0-907
-
CdpOauth2AccessTokenProviderControllerService 2.6.0.4.12.0.0-907
-
CEFReader 2.6.0.4.12.0.0-907
-
CiscoEmblemSyslogMessageReader 2.6.0.4.12.0.0-907
-
ClouderaAttributeSchemaReferenceReader 2.6.0.4.12.0.0-907
-
ClouderaAttributeSchemaReferenceWriter 2.6.0.4.12.0.0-907
-
ClouderaEncodedSchemaReferenceReader 2.6.0.4.12.0.0-907
-
ClouderaEncodedSchemaReferenceWriter 2.6.0.4.12.0.0-907
-
ClouderaHiveConnectionPool 2.6.0.4.12.0.0-907
-
ClouderaHiveConnectionPoolLookup 2.6.0.4.12.0.0-907
-
ClouderaSchemaRegistry 2.6.0.4.12.0.0-907
-
CMLLookupService 2.6.0.4.12.0.0-907
-
ConfluentEncodedSchemaReferenceReader 2.6.0.4.12.0.0-907
-
ConfluentEncodedSchemaReferenceWriter 2.6.0.4.12.0.0-907
-
ConfluentProtobufMessageNameResolver 2.6.0.4.12.0.0-907
-
ConfluentSchemaRegistry 2.6.0.4.12.0.0-907
-
CouchbaseKeyValueLookupService 2.6.0.4.12.0.0-907
-
CouchbaseMapCacheClient 2.6.0.4.12.0.0-907
-
CouchbaseRecordLookupService 2.6.0.4.12.0.0-907
-
CSVReader 2.6.0.4.12.0.0-907
-
CSVRecordLookupService 2.6.0.4.12.0.0-907
-
CSVRecordSetWriter 2.6.0.4.12.0.0-907
-
DatabaseRecordLookupService 2.6.0.4.12.0.0-907
-
DatabaseRecordSink 2.6.0.4.12.0.0-907
-
DatabaseTableSchemaRegistry 2.6.0.4.12.0.0-907
-
DBCPConnectionPool 2.6.0.4.12.0.0-907
-
DBCPConnectionPoolLookup 2.6.0.4.12.0.0-907
-
DeveloperBoxClientService 2.6.0.4.12.0.0-907
-
DistributedMapCacheLookupService 2.6.0.4.12.0.0-907
-
EBCDICRecordReader 2.6.0.4.12.0.0-907
-
ElasticSearchClientServiceImpl 2.6.0.4.12.0.0-907
-
ElasticSearchLookupService 2.6.0.4.12.0.0-907
-
ElasticSearchStringLookupService 2.6.0.4.12.0.0-907
-
EmailRecordSink 2.6.0.4.12.0.0-907
-
EmbeddedHazelcastCacheManager 2.6.0.4.12.0.0-907
-
ExcelReader 2.6.0.4.12.0.0-907
-
ExternalHazelcastCacheManager 2.6.0.4.12.0.0-907
-
FreeFormTextRecordSetWriter 2.6.0.4.12.0.0-907
-
GCPCredentialsControllerService 2.6.0.4.12.0.0-907
-
GCSFileResourceService 2.6.0.4.12.0.0-907
-
GenericPLC4XConnectionPool 2.6.0.4.12.0.0-907
-
GrokReader 2.6.0.4.12.0.0-907
-
HadoopCatalogService 2.6.0.4.12.0.0-907
-
HadoopDBCPConnectionPool 2.6.0.4.12.0.0-907
-
HazelcastMapCacheClient 2.6.0.4.12.0.0-907
-
HBase_2_ClientMapCacheService 2.6.0.4.12.0.0-907
-
HBase_2_ClientService 2.6.0.4.12.0.0-907
-
HBase_2_RecordLookupService 2.6.0.4.12.0.0-907
-
HikariCPConnectionPool 2.6.0.4.12.0.0-907
-
HiveCatalogService 2.6.0.4.12.0.0-907
-
HttpRecordSink 2.6.0.4.12.0.0-907
-
ImpalaConnectionPool 2.6.0.4.12.0.0-907
-
IPFIXReader 2.6.0.4.12.0.0-907
-
IPLookupService 2.6.0.4.12.0.0-907
-
JASN1Reader 2.6.0.4.12.0.0-907
-
JdbcCatalogService 2.6.0.4.12.0.0-907
-
JettyWebSocketClient 2.6.0.4.12.0.0-907
-
JettyWebSocketServer 2.6.0.4.12.0.0-907
-
JiraRecordSink 2.6.0.4.12.0.0-907
-
JMSConnectionFactoryProvider 2.6.0.4.12.0.0-907
-
JndiJmsConnectionFactoryProvider 2.6.0.4.12.0.0-907
-
JsonConfigBasedBoxClientService 2.6.0.4.12.0.0-907
-
JsonPathReader 2.6.0.4.12.0.0-907
-
JsonRecordSetWriter 2.6.0.4.12.0.0-907
-
JsonTreeReader 2.6.0.4.12.0.0-907
-
JWTBearerOAuth2AccessTokenProvider 2.6.0.4.12.0.0-907
-
Kafka3ConnectionService 2.6.0.4.12.0.0-907
-
KafkaRecordSink_2_6 2.6.0.4.12.0.0-907
-
KafkaRecordSinkCDP 2.6.0.4.12.0.0-907
-
KerberosKeytabUserService 2.6.0.4.12.0.0-907
-
KerberosPasswordUserService 2.6.0.4.12.0.0-907
-
KerberosTicketCacheUserService 2.6.0.4.12.0.0-907
-
KuduLookupService 2.6.0.4.12.0.0-907
-
LivySessionController 2.6.0.4.12.0.0-907
-
LoggingRecordSink 2.6.0.4.12.0.0-907
-
MapCacheClientService 2.6.0.4.12.0.0-907
-
MapCacheServer 2.6.0.4.12.0.0-907
-
MongoDBControllerService 2.6.0.4.12.0.0-907
-
MongoDBLookupService 2.6.0.4.12.0.0-907
-
MQTTIIoTReader 2.6.0.4.12.0.0-907
-
Neo4JCypherClientService 2.6.0.4.12.0.0-907
-
ParquetReader 2.6.0.4.12.0.0-907
-
ParquetRecordSetWriter 2.6.0.4.12.0.0-907
-
PEMEncodedSSLContextProvider 2.6.0.4.12.0.0-907
-
PhoenixThickConnectionPool 2.6.0.4.12.0.0-907
-
PhoenixThinConnectionPool 2.6.0.4.12.0.0-907
-
PostgreSQLConnectionPool 2.6.0.4.12.0.0-907
-
PropertiesFileLookupService 2.6.0.4.12.0.0-907
-
ProtobufReader 2.6.0.4.12.0.0-907
-
ProxyPLC4XConnectionPool 2.6.0.4.12.0.0-907
-
RabbitMQJMSConnectionFactoryProvider 2.6.0.4.12.0.0-907
-
ReaderLookup 2.6.0.4.12.0.0-907
-
RecordSetWriterLookup 2.6.0.4.12.0.0-907
-
RecordSinkServiceLookup 2.6.0.4.12.0.0-907
-
RedisConnectionPoolService 2.6.0.4.12.0.0-907
-
RedisDistributedMapCacheClientService 2.6.0.4.12.0.0-907
-
RedshiftConnectionPool 2.6.0.4.12.0.0-907
-
RESTCatalogService 2.6.0.4.12.0.0-907
-
RestLookupService 2.6.0.4.12.0.0-907
-
S3FileResourceService 2.6.0.4.12.0.0-907
-
ScriptedLookupService 2.6.0.4.12.0.0-907
-
ScriptedReader 2.6.0.4.12.0.0-907
-
ScriptedRecordSetWriter 2.6.0.4.12.0.0-907
-
ScriptedRecordSink 2.6.0.4.12.0.0-907
-
SetCacheClientService 2.6.0.4.12.0.0-907
-
SetCacheServer 2.6.0.4.12.0.0-907
-
SimpleCsvFileLookupService 2.6.0.4.12.0.0-907
-
SimpleDatabaseLookupService 2.6.0.4.12.0.0-907
-
SimpleKeyValueLookupService 2.6.0.4.12.0.0-907
-
SimpleRedisDistributedMapCacheClientService 2.6.0.4.12.0.0-907
-
SimpleScriptedLookupService 2.6.0.4.12.0.0-907
-
SiteToSiteReportingRecordSink 2.6.0.4.12.0.0-907
-
SlackRecordSink 2.6.0.4.12.0.0-907
-
SmbjClientProviderService 2.6.0.4.12.0.0-907
-
SnowflakeComputingConnectionPool 2.6.0.4.12.0.0-907
-
StandardAsanaClientProviderService 2.6.0.4.12.0.0-907
-
StandardAzureCredentialsControllerService 2.6.0.4.12.0.0-907
-
StandardCouchbaseConnectionService 2.6.0.4.12.0.0-907
-
StandardDatabaseDialectService 2.6.0.4.12.0.0-907
-
StandardDropboxCredentialService 2.6.0.4.12.0.0-907
-
StandardFileResourceService 2.6.0.4.12.0.0-907
-
StandardHashiCorpVaultClientService 2.6.0.4.12.0.0-907
-
StandardHttpContextMap 2.6.0.4.12.0.0-907
-
StandardJiraCredentialService 2.6.0.4.12.0.0-907
-
StandardJsonSchemaRegistry 2.6.0.4.12.0.0-907
-
StandardKustoIngestService 2.6.0.4.12.0.0-907
-
StandardKustoQueryService 2.6.0.4.12.0.0-907
-
StandardOauth2AccessTokenProvider 2.6.0.4.12.0.0-907
-
StandardPGPPrivateKeyService 2.6.0.4.12.0.0-907
-
StandardPGPPublicKeyService 2.6.0.4.12.0.0-907
-
StandardPLC4XConnectionPool 2.6.0.4.12.0.0-907
-
StandardPrivateKeyService 2.6.0.4.12.0.0-907
-
StandardProtobufReader 2.6.0.4.12.0.0-907
-
StandardProxyConfigurationService 2.6.0.4.12.0.0-907
-
StandardRestrictedSSLContextService 2.6.0.4.12.0.0-907
-
StandardS3EncryptionService 2.6.0.4.12.0.0-907
-
StandardSnowflakeIngestManagerProviderService 2.6.0.4.12.0.0-907
-
StandardSSLContextService 2.6.0.4.12.0.0-907
-
StandardWebClientServiceProvider 2.6.0.4.12.0.0-907
-
Syslog5424Reader 2.6.0.4.12.0.0-907
-
SyslogReader 2.6.0.4.12.0.0-907
-
TinkerpopClientService 2.6.0.4.12.0.0-907
-
UDPEventRecordSink 2.6.0.4.12.0.0-907
-
VolatileSchemaCache 2.6.0.4.12.0.0-907
-
WindowsEventLogReader 2.6.0.4.12.0.0-907
-
XMLFileLookupService 2.6.0.4.12.0.0-907
-
XMLReader 2.6.0.4.12.0.0-907
-
XMLRecordSetWriter 2.6.0.4.12.0.0-907
-
YamlTreeReader 2.6.0.4.12.0.0-907
-
ZendeskRecordSink 2.6.0.4.12.0.0-907
-
-
Reporting Tasks
-
AzureLogAnalyticsProvenanceReportingTask 2.6.0.4.12.0.0-907
-
AzureLogAnalyticsReportingTask 2.6.0.4.12.0.0-907
-
ControllerStatusReportingTask 2.6.0.4.12.0.0-907
-
MonitorDiskUsage 2.6.0.4.12.0.0-907
-
MonitorMemory 2.6.0.4.12.0.0-907
-
QueryNiFiReportingTask 2.6.0.4.12.0.0-907
-
ReportLineageToAtlas 2.6.0.4.12.0.0-907
-
ScriptedReportingTask 2.6.0.4.12.0.0-907
-
SiteToSiteBulletinReportingTask 2.6.0.4.12.0.0-907
-
SiteToSiteMetricsReportingTask 2.6.0.4.12.0.0-907
-
SiteToSiteProvenanceReportingTask 2.6.0.4.12.0.0-907
-
SiteToSiteStatusReportingTask 2.6.0.4.12.0.0-907
-
-
Parameter Providers
-
AwsSecretsManagerParameterProvider 2.6.0.4.12.0.0-907
-
AzureKeyVaultSecretsParameterProvider 2.6.0.4.12.0.0-907
-
CyberArkConjurParameterProvider 2.6.0.4.12.0.0-907
-
DatabaseParameterProvider 2.6.0.4.12.0.0-907
-
EnvironmentVariableParameterProvider 2.6.0.4.12.0.0-907
-
GcpSecretManagerParameterProvider 2.6.0.4.12.0.0-907
-
HashiCorpVaultParameterProvider 2.6.0.4.12.0.0-907
-
KubernetesSecretParameterProvider 2.6.0.4.12.0.0-907
-
OnePasswordParameterProvider 2.6.0.4.12.0.0-907
-
PropertiesFileParameterProvider 2.6.0.4.12.0.0-907
-
-
Flow Analysis Rules
-
DisallowComponentType 2.6.0.4.12.0.0-907
-
DisallowConsecutiveConnectionsWithRoundRobinLB 2.6.0.4.12.0.0-907
-
DisallowDeadEnd 2.6.0.4.12.0.0-907
-
DisallowDeprecatedProcessor 2.6.0.4.12.0.0-907
-
DisallowExtractTextForFullContent 2.6.0.4.12.0.0-907
-
RecommendRecordProcessor 2.6.0.4.12.0.0-907
-
RequireHandleHttpResponseAfterHandleHttpRequest 2.6.0.4.12.0.0-907
-
RequireMergeBeforePutIceberg 2.6.0.4.12.0.0-907
-
RequireServerSSLContextService 2.6.0.4.12.0.0-907
-
RestrictBackpressureSettings 2.6.0.4.12.0.0-907
-
RestrictComponentNaming 2.6.0.4.12.0.0-907
-
RestrictConcurrentTasksVsThreadPoolSizeInProcessors 2.6.0.4.12.0.0-907
-
RestrictFlowFileExpiration 2.6.0.4.12.0.0-907
-
RestrictProcessorConcurrency 2.6.0.4.12.0.0-907
-
RestrictSchedulingForListProcessors 2.6.0.4.12.0.0-907
-
RestrictThreadPoolSize 2.6.0.4.12.0.0-907
-
RestrictYieldDurationForConsumeKafkaProcessors 2.6.0.4.12.0.0-907
-
KafkaRecordSinkCDP 2.6.0.4.12.0.0-907
- Bundle
- com.cloudera | nifi-cdf-kafka-2-nar
- Description
- Provides a service to write records to a Kafka 2.6+ topic using the Kafka 3.9.1.7.3.2.0-952 Producer API.
- Tags
- kafka, record, sink
- Input Requirement
- Supports Sensitive Dynamic Properties
- false
-
Acknowledgment Wait Time
After sending a message to Kafka, this indicates the amount of time that we are willing to wait for a response from Kafka. If Kafka does not acknowledge the message within this time period, the FlowFile will be routed to 'failure'.
- Display Name
- Acknowledgment Wait Time
- Description
- After sending a message to Kafka, this indicates the amount of time that we are willing to wait for a response from Kafka. If Kafka does not acknowledge the message within this time period, the FlowFile will be routed to 'failure'.
- API Name
- ack.wait.time
- Default Value
- 5 secs
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- true
-
Delivery Guarantee
Specifies the requirement for guaranteeing that a message is sent to Kafka. Corresponds to Kafka's 'acks' property.
- Display Name
- Delivery Guarantee
- Description
- Specifies the requirement for guaranteeing that a message is sent to Kafka. Corresponds to Kafka's 'acks' property.
- API Name
- acks
- Default Value
- 0
- Allowable Values
-
- Best Effort
- Guarantee Single Node Delivery
- Guarantee Replicated Delivery
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- true
-
AWS Assume Role ARN
The AWS Role ARN for cross-account access when using AWS MSK IAM. Used with Assume Role Session Name.
- Display Name
- AWS Assume Role ARN
- Description
- The AWS Role ARN for cross-account access when using AWS MSK IAM. Used with Assume Role Session Name.
- API Name
- AWS Assume Role ARN
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- true
- Dependencies
-
- AWS Role Source is set to any of [SPECIFIED_ROLE]
-
AWS Assume Role Session Name
The AWS Role Session Name for cross-account access. Used in conjunction with Assume Role ARN.
- Display Name
- AWS Assume Role Session Name
- Description
- The AWS Role Session Name for cross-account access. Used in conjunction with Assume Role ARN.
- API Name
- AWS Assume Role Session Name
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- true
- Dependencies
-
- AWS Role Source is set to any of [SPECIFIED_ROLE]
-
AWS Role Source
Select how AWS credentials are sourced for AWS MSK IAM: Default Profile searches standard locations, Specified Profile selects a named profile, or Specified Role configures a Role ARN and Session Name.
- Display Name
- AWS Role Source
- Description
- Select how AWS credentials are sourced for AWS MSK IAM: Default Profile searches standard locations, Specified Profile selects a named profile, or Specified Role configures a Role ARN and Session Name.
- API Name
- AWS Role Source
- Default Value
- DEFAULT_PROFILE
- Allowable Values
-
- Default Profile
- Specified Profile
- Specified Role
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- true
- Dependencies
-
- SASL Mechanism is set to any of [AWS_MSK_IAM]
-
AWS Profile Name
The Amazon Web Services Profile to select when multiple profiles are available.
- Display Name
- AWS Profile Name
- Description
- The Amazon Web Services Profile to select when multiple profiles are available.
- API Name
- aws.profile.name
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- true
- Dependencies
-
- AWS Role Source is set to any of [SPECIFIED_PROFILE]
-
Bootstrap Servers
Comma-separated list of Kafka Bootstrap Servers in the format host:port. Corresponds to Kafka bootstrap.servers property
- Display Name
- Bootstrap Servers
- Description
- Comma-separated list of Kafka Bootstrap Servers in the format host:port. Corresponds to Kafka bootstrap.servers property
- API Name
- bootstrap.servers
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- true
-
Compression Type
This parameter allows you to specify the compression codec for all data generated by this producer.
- Display Name
- Compression Type
- Description
- This parameter allows you to specify the compression codec for all data generated by this producer.
- API Name
- compression.type
- Default Value
- none
- Allowable Values
-
- none
- gzip
- snappy
- lz4
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- true
-
interceptor.classes
Specifies the value for 'interceptor.classes' Kafka Configuration property.
- Display Name
- interceptor.classes
- Description
- Specifies the value for 'interceptor.classes' Kafka Configuration property.
- API Name
- interceptor.classes
- Default Value
- com.hortonworks.smm.kafka.monitoring.interceptors.MonitoringProducerInterceptor
- Expression Language Scope
- Environment variables defined at JVM level and system properties
- Sensitive
- false
- Required
- false
-
Kerberos User Service
Service supporting user authentication with Kerberos
- Display Name
- Kerberos User Service
- Description
- Service supporting user authentication with Kerberos
- API Name
- kerberos-user-service
- Service Interface
- org.apache.nifi.kerberos.SelfContainedKerberosUserService
- Service Implementations
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- true
- Dependencies
-
- SASL Mechanism is set to any of [GSSAPI]
-
Max Metadata Wait Time
The amount of time publisher will wait to obtain metadata or wait for the buffer to flush during the 'send' call before failing the entire 'send' call. Corresponds to Kafka's 'max.block.ms' property
- Display Name
- Max Metadata Wait Time
- Description
- The amount of time publisher will wait to obtain metadata or wait for the buffer to flush during the 'send' call before failing the entire 'send' call. Corresponds to Kafka's 'max.block.ms' property
- API Name
- max.block.ms
- Default Value
- 5 sec
- Expression Language Scope
- Environment variables defined at JVM level and system properties
- Sensitive
- false
- Required
- true
-
Max Request Size
The maximum size of a request in bytes. Corresponds to Kafka's 'max.request.size' property and defaults to 1 MB (1048576).
- Display Name
- Max Request Size
- Description
- The maximum size of a request in bytes. Corresponds to Kafka's 'max.request.size' property and defaults to 1 MB (1048576).
- API Name
- max.request.size
- Default Value
- 1 MB
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- true
-
Message Header Encoding
For any attribute that is added as a message header, as configured via the <Attributes to Send as Headers> property, this property indicates the Character Encoding to use for serializing the headers.
- Display Name
- Message Header Encoding
- Description
- For any attribute that is added as a message header, as configured via the <Attributes to Send as Headers> property, this property indicates the Character Encoding to use for serializing the headers.
- API Name
- message-header-encoding
- Default Value
- UTF-8
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- false
-
OAuth2 Access Token Provider Service
Service providing OAuth2 Access Tokens for authentication
- Display Name
- OAuth2 Access Token Provider Service
- Description
- Service providing OAuth2 Access Tokens for authentication
- API Name
- oauth2-access-token-provider-service
- Service Interface
- org.apache.nifi.oauth2.OAuth2AccessTokenProvider
- Service Implementations
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- true
- Dependencies
-
- SASL Mechanism is set to any of [OAUTHBEARER]
-
Record Writer
Specifies the Controller Service to use for writing out the records.
- Display Name
- Record Writer
- Description
- Specifies the Controller Service to use for writing out the records.
- API Name
- record-sink-record-writer
- Service Interface
- org.apache.nifi.serialization.RecordSetWriterFactory
- Service Implementations
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- true
-
Kerberos Service Name
The service name that matches the primary name of the Kafka server configured in the broker JAAS configuration
- Display Name
- Kerberos Service Name
- Description
- The service name that matches the primary name of the Kafka server configured in the broker JAAS configuration
- API Name
- sasl.kerberos.service.name
- Expression Language Scope
- Environment variables defined at JVM level and system properties
- Sensitive
- false
- Required
- true
- Dependencies
-
- SASL Mechanism is set to any of [GSSAPI]
-
SASL Mechanism
SASL mechanism used for authentication. Corresponds to Kafka Client sasl.mechanism property
- Display Name
- SASL Mechanism
- Description
- SASL mechanism used for authentication. Corresponds to Kafka Client sasl.mechanism property
- API Name
- sasl.mechanism
- Default Value
- GSSAPI
- Allowable Values
-
- GSSAPI
- PLAIN
- SCRAM-SHA-256
- SCRAM-SHA-512
- AWS_MSK_IAM
- OAUTHBEARER
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- true
- Dependencies
-
- Security Protocol is set to any of [SASL_PLAINTEXT, SASL_SSL]
-
SASL Password
Password provided with configured username when using PLAIN or SCRAM SASL Mechanisms
- Display Name
- SASL Password
- Description
- Password provided with configured username when using PLAIN or SCRAM SASL Mechanisms
- API Name
- sasl.password
- Expression Language Scope
- Environment variables defined at JVM level and system properties
- Sensitive
- true
- Required
- true
- Dependencies
-
- SASL Mechanism is set to any of [PLAIN, SCRAM-SHA-256, SCRAM-SHA-512]
-
Token Authentication
Enables or disables Token authentication when using SCRAM SASL Mechanisms
- Display Name
- Token Authentication
- Description
- Enables or disables Token authentication when using SCRAM SASL Mechanisms
- API Name
- sasl.token.auth
- Default Value
- false
- Allowable Values
-
- true
- false
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- false
- Dependencies
-
- SASL Mechanism is set to any of [SCRAM-SHA-256, SCRAM-SHA-512]
-
SASL Username
Username provided with configured password when using PLAIN or SCRAM SASL Mechanisms
- Display Name
- SASL Username
- Description
- Username provided with configured password when using PLAIN or SCRAM SASL Mechanisms
- API Name
- sasl.username
- Expression Language Scope
- Environment variables defined at JVM level and system properties
- Sensitive
- false
- Required
- true
- Dependencies
-
- SASL Mechanism is set to any of [PLAIN, SCRAM-SHA-256, SCRAM-SHA-512]
-
Security Protocol
Security protocol used to communicate with brokers. Corresponds to Kafka Client security.protocol property
- Display Name
- Security Protocol
- Description
- Security protocol used to communicate with brokers. Corresponds to Kafka Client security.protocol property
- API Name
- security.protocol
- Default Value
- PLAINTEXT
- Allowable Values
-
- PLAINTEXT
- SSL
- SASL_PLAINTEXT
- SASL_SSL
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- true
-
SSL Context Service
Service supporting SSL communication with Kafka brokers
- Display Name
- SSL Context Service
- Description
- Service supporting SSL communication with Kafka brokers
- API Name
- SSL Context Service
- Service Interface
- org.apache.nifi.ssl.SSLContextService
- Service Implementations
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- false
- Dependencies
-
- Security Protocol is set to any of [SASL_SSL, SSL]
-
Topic Name
The name of the Kafka Topic to publish to.
- Display Name
- Topic Name
- Description
- The name of the Kafka Topic to publish to.
- API Name
- topic
- Expression Language Scope
- Environment variables defined at JVM level and system properties
- Sensitive
- false
- Required
- true
-
The name of a Kafka configuration property or a SASL extension property.
Kafka configuration properties will be added on the Kafka configuration after loading any provided configuration properties. In the event a dynamic property represents a property that was already set, its value will be ignored and WARN message logged. For the list of available Kafka properties please refer to: http://kafka.apache.org/documentation.html#configuration. SASL extension properties can be specified in sasl_extension_propertyName format (e.g. sasl_extension_logicalCluster).
- Name
- The name of a Kafka configuration property or a SASL extension property.
- Description
- Kafka configuration properties will be added on the Kafka configuration after loading any provided configuration properties. In the event a dynamic property represents a property that was already set, its value will be ignored and WARN message logged. For the list of available Kafka properties please refer to: http://kafka.apache.org/documentation.html#configuration. SASL extension properties can be specified in sasl_extension_propertyName format (e.g. sasl_extension_logicalCluster).
- Value
- The value of the given property.
- Expression Language Scope
- ENVIRONMENT