-
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
-
Kafka3ConnectionService 2.6.0.4.12.0.0-907
- Bundle
- org.apache.nifi | nifi-kafka-3-service-nar
- Description
- Provides and manages connections to Kafka Brokers for producer or consumer operations.
- Tags
- Apache, Consume, Kafka, Message, Publish
- Input Requirement
- Supports Sensitive Dynamic Properties
- false
-
Acknowledgment Wait Time
After sending a message to Kafka, this indicates the amount of time that the service will wait for a response from Kafka. If Kafka does not acknowledge the message within this time period, the service will throw an exception.
- Display Name
- Acknowledgment Wait Time
- Description
- After sending a message to Kafka, this indicates the amount of time that the service will wait for a response from Kafka. If Kafka does not acknowledge the message within this time period, the service will throw an exception.
- API Name
- ack.wait.time
- Default Value
- 5 sec
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- true
-
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
-
Client Timeout
Default timeout for Kafka client operations. Mapped to Kafka default.api.timeout.ms. The Kafka request.timeout.ms property is derived from half of the configured timeout
- Display Name
- Client Timeout
- Description
- Default timeout for Kafka client operations. Mapped to Kafka default.api.timeout.ms. The Kafka request.timeout.ms property is derived from half of the configured timeout
- API Name
- default.api.timeout.ms
- Default Value
- 60 sec
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- true
-
Transaction Isolation Level
Specifies how the service should handle transaction isolation levels when communicating with Kafka. The uncommited option means that messages will be received as soon as they are written to Kafka but will be pulled, even if the producer cancels the transactions. The committed option configures the service to not receive any messages for which the producer's transaction was canceled, but this can result in some latency since the consumer must wait for the producer to finish its entire transaction instead of pulling as the messages become available. Corresponds to Kafka isolation.level property.
- Display Name
- Transaction Isolation Level
- Description
- Specifies how the service should handle transaction isolation levels when communicating with Kafka. The uncommited option means that messages will be received as soon as they are written to Kafka but will be pulled, even if the producer cancels the transactions. The committed option configures the service to not receive any messages for which the producer's transaction was canceled, but this can result in some latency since the consumer must wait for the producer to finish its entire transaction instead of pulling as the messages become available. Corresponds to Kafka isolation.level property.
- API Name
- isolation.level
- Default Value
- read_committed
- Allowable Values
-
- Read Committed
- Read Uncommitted
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- true
-
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 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 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 Poll Records
Maximum number of records Kafka should return in a single poll.
- Display Name
- Max Poll Records
- Description
- Maximum number of records Kafka should return in a single poll.
- API Name
- max.poll.records
- Default Value
- 10000
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- true
-
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]
-
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
- 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]
-
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]
-
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