-
Processors
-
AttributeRollingWindow 2.4.0.4.3.3.0-40
-
AttributesToCSV 2.4.0.4.3.3.0-40
-
AttributesToJSON 2.4.0.4.3.3.0-40
-
CalculateParquetOffsets 2.4.0.4.3.3.0-40
-
CalculateParquetRowGroupOffsets 2.4.0.4.3.3.0-40
-
CalculateRecordStats 2.4.0.4.3.3.0-40
-
CaptureChangeDebeziumDB2 2.4.0.4.3.3.0-40
-
CaptureChangeDebeziumMongoDB 2.4.0.4.3.3.0-40
-
CaptureChangeDebeziumMySQL 2.4.0.4.3.3.0-40
-
CaptureChangeDebeziumOracle 2.4.0.4.3.3.0-40
-
CaptureChangeDebeziumPostgreSQL 2.4.0.4.3.3.0-40
-
CaptureChangeDebeziumSQLServer 2.4.0.4.3.3.0-40
-
CaptureChangeMySQL 2.4.0.4.3.3.0-40
-
CompressContent 2.4.0.4.3.3.0-40
-
ConnectWebSocket 2.4.0.4.3.3.0-40
-
ConsumeAMQP 2.4.0.4.3.3.0-40
-
ConsumeAzureEventHub 2.4.0.4.3.3.0-40
-
ConsumeBoxEnterpriseEvents 2.4.0.4.3.3.0-40
-
ConsumeBoxEvents 2.4.0.4.3.3.0-40
-
ConsumeElasticsearch 2.4.0.4.3.3.0-40
-
ConsumeGCPubSub 2.4.0.4.3.3.0-40
-
ConsumeIMAP 2.4.0.4.3.3.0-40
-
ConsumeJMS 2.4.0.4.3.3.0-40
-
ConsumeKafka 2.4.0.4.3.3.0-40
-
ConsumeKafka_2_6 2.4.0.4.3.3.0-40
-
ConsumeKafka2CDP 2.4.0.4.3.3.0-40
-
ConsumeKafka2RecordCDP 2.4.0.4.3.3.0-40
-
ConsumeKafkaRecord_2_6 2.4.0.4.3.3.0-40
-
ConsumeKinesisStream 2.4.0.4.3.3.0-40
-
ConsumeMQTT 2.4.0.4.3.3.0-40
-
ConsumePLC 2.4.0.4.3.3.0-40
-
ConsumePOP3 2.4.0.4.3.3.0-40
-
ConsumeSlack 2.4.0.4.3.3.0-40
-
ConsumeTwitter 2.4.0.4.3.3.0-40
-
ConsumeWindowsEventLog 2.4.0.4.3.3.0-40
-
ControlRate 2.4.0.4.3.3.0-40
-
ConvertAvroToParquet 2.4.0.4.3.3.0-40
-
ConvertCharacterSet 2.4.0.4.3.3.0-40
-
ConvertProtobuf 2.4.0.4.3.3.0-40
-
ConvertRecord 2.4.0.4.3.3.0-40
-
CopyAzureBlobStorage_v12 2.4.0.4.3.3.0-40
-
CopyS3Object 2.4.0.4.3.3.0-40
-
CountText 2.4.0.4.3.3.0-40
-
CreateBoxFileMetadataInstance 2.4.0.4.3.3.0-40
-
CreateBoxMetadataTemplate 2.4.0.4.3.3.0-40
-
CreateHadoopSequenceFile 2.4.0.4.3.3.0-40
-
CryptographicHashContent 2.4.0.4.3.3.0-40
-
DebugFlow 2.4.0.4.3.3.0-40
-
DecryptContentAge 2.4.0.4.3.3.0-40
-
DecryptContentPGP 2.4.0.4.3.3.0-40
-
DeduplicateRecord 2.4.0.4.3.3.0-40
-
DeleteAzureBlobStorage_v12 2.4.0.4.3.3.0-40
-
DeleteAzureDataLakeStorage 2.4.0.4.3.3.0-40
-
DeleteBoxFileMetadataInstance 2.4.0.4.3.3.0-40
-
DeleteByQueryElasticsearch 2.4.0.4.3.3.0-40
-
DeleteCDPObjectStore 2.4.0.4.3.3.0-40
-
DeleteDynamoDB 2.4.0.4.3.3.0-40
-
DeleteFile 2.4.0.4.3.3.0-40
-
DeleteGCSObject 2.4.0.4.3.3.0-40
-
DeleteGridFS 2.4.0.4.3.3.0-40
-
DeleteHBaseCells 2.4.0.4.3.3.0-40
-
DeleteHBaseRow 2.4.0.4.3.3.0-40
-
DeleteHDFS 2.4.0.4.3.3.0-40
-
DeleteMongo 2.4.0.4.3.3.0-40
-
DeleteS3Object 2.4.0.4.3.3.0-40
-
DeleteSFTP 2.4.0.4.3.3.0-40
-
DeleteSQS 2.4.0.4.3.3.0-40
-
DetectDuplicate 2.4.0.4.3.3.0-40
-
DistributeLoad 2.4.0.4.3.3.0-40
-
DuplicateFlowFile 2.4.0.4.3.3.0-40
-
EncodeContent 2.4.0.4.3.3.0-40
-
EncryptContentAge 2.4.0.4.3.3.0-40
-
EncryptContentPGP 2.4.0.4.3.3.0-40
-
EnforceOrder 2.4.0.4.3.3.0-40
-
EvaluateJsonPath 2.4.0.4.3.3.0-40
-
EvaluateXPath 2.4.0.4.3.3.0-40
-
EvaluateXQuery 2.4.0.4.3.3.0-40
-
ExecuteGraphQuery 2.4.0.4.3.3.0-40
-
ExecuteGraphQueryRecord 2.4.0.4.3.3.0-40
-
ExecuteGroovyScript 2.4.0.4.3.3.0-40
-
ExecuteProcess 2.4.0.4.3.3.0-40
-
ExecuteScript 2.4.0.4.3.3.0-40
-
ExecuteSparkInteractive 2.4.0.4.3.3.0-40
-
ExecuteSQL 2.4.0.4.3.3.0-40
-
ExecuteSQLRecord 2.4.0.4.3.3.0-40
-
ExecuteStreamCommand 2.4.0.4.3.3.0-40
-
ExtractAvroMetadata 2.4.0.4.3.3.0-40
-
ExtractDocumentText 2.4.0.4.3.3.0-40
-
ExtractEmailAttachments 2.4.0.4.3.3.0-40
-
ExtractEmailHeaders 2.4.0.4.3.3.0-40
-
ExtractGrok 2.4.0.4.3.3.0-40
-
ExtractHL7Attributes 2.4.0.4.3.3.0-40
-
ExtractImageMetadata 2.4.0.4.3.3.0-40
-
ExtractMediaMetadata 2.4.0.4.3.3.0-40
-
ExtractRecordSchema 2.4.0.4.3.3.0-40
-
ExtractStructuredBoxFileMetadata 2.4.0.4.3.3.0-40
-
ExtractText 2.4.0.4.3.3.0-40
-
FetchAzureBlobStorage_v12 2.4.0.4.3.3.0-40
-
FetchAzureDataLakeStorage 2.4.0.4.3.3.0-40
-
FetchBoxFile 2.4.0.4.3.3.0-40
-
FetchBoxFileInfo 2.4.0.4.3.3.0-40
-
FetchBoxFileMetadataInstance 2.4.0.4.3.3.0-40
-
FetchBoxFileRepresentation 2.4.0.4.3.3.0-40
-
FetchCDPObjectStore 2.4.0.4.3.3.0-40
-
FetchDistributedMapCache 2.4.0.4.3.3.0-40
-
FetchDropbox 2.4.0.4.3.3.0-40
-
FetchFile 2.4.0.4.3.3.0-40
-
FetchFTP 2.4.0.4.3.3.0-40
-
FetchGCSObject 2.4.0.4.3.3.0-40
-
FetchGoogleDrive 2.4.0.4.3.3.0-40
-
FetchGridFS 2.4.0.4.3.3.0-40
-
FetchHBaseRow 2.4.0.4.3.3.0-40
-
FetchHDFS 2.4.0.4.3.3.0-40
-
FetchParquet 2.4.0.4.3.3.0-40
-
FetchPLC 2.4.0.4.3.3.0-40
-
FetchS3Object 2.4.0.4.3.3.0-40
-
FetchSFTP 2.4.0.4.3.3.0-40
-
FetchSmb 2.4.0.4.3.3.0-40
-
FilterAttribute 2.4.0.4.3.3.0-40
-
FlattenJson 2.4.0.4.3.3.0-40
-
ForkEnrichment 2.4.0.4.3.3.0-40
-
ForkRecord 2.4.0.4.3.3.0-40
-
GenerateFlowFile 2.4.0.4.3.3.0-40
-
GenerateRecord 2.4.0.4.3.3.0-40
-
GenerateTableFetch 2.4.0.4.3.3.0-40
-
GeoEnrichIP 2.4.0.4.3.3.0-40
-
GeoEnrichIPRecord 2.4.0.4.3.3.0-40
-
GeohashRecord 2.4.0.4.3.3.0-40
-
GetAsanaObject 2.4.0.4.3.3.0-40
-
GetAwsPollyJobStatus 2.4.0.4.3.3.0-40
-
GetAwsTextractJobStatus 2.4.0.4.3.3.0-40
-
GetAwsTranscribeJobStatus 2.4.0.4.3.3.0-40
-
GetAwsTranslateJobStatus 2.4.0.4.3.3.0-40
-
GetAzureEventHub 2.4.0.4.3.3.0-40
-
GetAzureQueueStorage_v12 2.4.0.4.3.3.0-40
-
GetBoxFileCollaborators 2.4.0.4.3.3.0-40
-
GetBoxGroupMembers 2.4.0.4.3.3.0-40
-
GetCouchbaseKey 2.4.0.4.3.3.0-40
-
GetDynamoDB 2.4.0.4.3.3.0-40
-
GetElasticsearch 2.4.0.4.3.3.0-40
-
GetFile 2.4.0.4.3.3.0-40
-
GetFileResource 2.4.0.4.3.3.0-40
-
GetFTP 2.4.0.4.3.3.0-40
-
GetGcpVisionAnnotateFilesOperationStatus 2.4.0.4.3.3.0-40
-
GetGcpVisionAnnotateImagesOperationStatus 2.4.0.4.3.3.0-40
-
GetHBase 2.4.0.4.3.3.0-40
-
GetHDFS 2.4.0.4.3.3.0-40
-
GetHDFSEvents 2.4.0.4.3.3.0-40
-
GetHDFSFileInfo 2.4.0.4.3.3.0-40
-
GetHDFSSequenceFile 2.4.0.4.3.3.0-40
-
GetHubSpot 2.4.0.4.3.3.0-40
-
GetJiraIssue 2.4.0.4.3.3.0-40
-
GetMongo 2.4.0.4.3.3.0-40
-
GetMongoRecord 2.4.0.4.3.3.0-40
-
GetS3ObjectMetadata 2.4.0.4.3.3.0-40
-
GetS3ObjectTags 2.4.0.4.3.3.0-40
-
GetSFTP 2.4.0.4.3.3.0-40
-
GetShopify 2.4.0.4.3.3.0-40
-
GetSlackReaction 2.4.0.4.3.3.0-40
-
GetSmbFile 2.4.0.4.3.3.0-40
-
GetSNMP 2.4.0.4.3.3.0-40
-
GetSnowflakeIngestStatus 2.4.0.4.3.3.0-40
-
GetSolr 2.4.0.4.3.3.0-40
-
GetSplunk 2.4.0.4.3.3.0-40
-
GetSQS 2.4.0.4.3.3.0-40
-
GetTCP 2.4.0.4.3.3.0-40
-
GetWorkdayReport 2.4.0.4.3.3.0-40
-
GetZendesk 2.4.0.4.3.3.0-40
-
HandleHttpRequest 2.4.0.4.3.3.0-40
-
HandleHttpResponse 2.4.0.4.3.3.0-40
-
IdentifyMimeType 2.4.0.4.3.3.0-40
-
InvokeGRPC 2.4.0.4.3.3.0-40
-
InvokeHTTP 2.4.0.4.3.3.0-40
-
InvokeScriptedProcessor 2.4.0.4.3.3.0-40
-
ISPEnrichIP 2.4.0.4.3.3.0-40
-
JoinEnrichment 2.4.0.4.3.3.0-40
-
JoltTransformJSON 2.4.0.4.3.3.0-40
-
JoltTransformRecord 2.4.0.4.3.3.0-40
-
JSLTTransformJSON 2.4.0.4.3.3.0-40
-
JsonQueryElasticsearch 2.4.0.4.3.3.0-40
-
ListAzureBlobStorage_v12 2.4.0.4.3.3.0-40
-
ListAzureDataLakeStorage 2.4.0.4.3.3.0-40
-
ListBoxFile 2.4.0.4.3.3.0-40
-
ListBoxFileInfo 2.4.0.4.3.3.0-40
-
ListBoxFileMetadataInstances 2.4.0.4.3.3.0-40
-
ListBoxFileMetadataTemplates 2.4.0.4.3.3.0-40
-
ListCDPObjectStore 2.4.0.4.3.3.0-40
-
ListDatabaseTables 2.4.0.4.3.3.0-40
-
ListDropbox 2.4.0.4.3.3.0-40
-
ListenBeats 2.4.0.4.3.3.0-40
-
ListenFTP 2.4.0.4.3.3.0-40
-
ListenGRPC 2.4.0.4.3.3.0-40
-
ListenHTTP 2.4.0.4.3.3.0-40
-
ListenNetFlow 2.4.0.4.3.3.0-40
-
ListenOTLP 2.4.0.4.3.3.0-40
-
ListenSlack 2.4.0.4.3.3.0-40
-
ListenSyslog 2.4.0.4.3.3.0-40
-
ListenTCP 2.4.0.4.3.3.0-40
-
ListenTrapSNMP 2.4.0.4.3.3.0-40
-
ListenUDP 2.4.0.4.3.3.0-40
-
ListenUDPRecord 2.4.0.4.3.3.0-40
-
ListenWebSocket 2.4.0.4.3.3.0-40
-
ListFile 2.4.0.4.3.3.0-40
-
ListFTP 2.4.0.4.3.3.0-40
-
ListGCSBucket 2.4.0.4.3.3.0-40
-
ListGoogleDrive 2.4.0.4.3.3.0-40
-
ListHBaseRegions 2.4.0.4.3.3.0-40
-
ListHDFS 2.4.0.4.3.3.0-40
-
ListS3 2.4.0.4.3.3.0-40
-
ListSFTP 2.4.0.4.3.3.0-40
-
ListSmb 2.4.0.4.3.3.0-40
-
LogAttribute 2.4.0.4.3.3.0-40
-
LogMessage 2.4.0.4.3.3.0-40
-
LookupAttribute 2.4.0.4.3.3.0-40
-
LookupRecord 2.4.0.4.3.3.0-40
-
MergeContent 2.4.0.4.3.3.0-40
-
MergeRecord 2.4.0.4.3.3.0-40
-
ModifyBytes 2.4.0.4.3.3.0-40
-
ModifyCompression 2.4.0.4.3.3.0-40
-
MonitorActivity 2.4.0.4.3.3.0-40
-
MoveAzureDataLakeStorage 2.4.0.4.3.3.0-40
-
MoveHDFS 2.4.0.4.3.3.0-40
-
Notify 2.4.0.4.3.3.0-40
-
PackageFlowFile 2.4.0.4.3.3.0-40
-
PaginatedJsonQueryElasticsearch 2.4.0.4.3.3.0-40
-
ParseEvtx 2.4.0.4.3.3.0-40
-
ParseNetflowv5 2.4.0.4.3.3.0-40
-
ParseSyslog 2.4.0.4.3.3.0-40
-
ParseSyslog5424 2.4.0.4.3.3.0-40
-
PartitionRecord 2.4.0.4.3.3.0-40
-
PublishAMQP 2.4.0.4.3.3.0-40
-
PublishGCPubSub 2.4.0.4.3.3.0-40
-
PublishJMS 2.4.0.4.3.3.0-40
-
PublishKafka 2.4.0.4.3.3.0-40
-
PublishKafka_2_6 2.4.0.4.3.3.0-40
-
PublishKafka2CDP 2.4.0.4.3.3.0-40
-
PublishKafka2RecordCDP 2.4.0.4.3.3.0-40
-
PublishKafkaRecord_2_6 2.4.0.4.3.3.0-40
-
PublishMQTT 2.4.0.4.3.3.0-40
-
PublishSlack 2.4.0.4.3.3.0-40
-
PutAccumuloRecord 2.4.0.4.3.3.0-40
-
PutAzureBlobStorage_v12 2.4.0.4.3.3.0-40
-
PutAzureCosmosDBRecord 2.4.0.4.3.3.0-40
-
PutAzureDataExplorer 2.4.0.4.3.3.0-40
-
PutAzureDataLakeStorage 2.4.0.4.3.3.0-40
-
PutAzureEventHub 2.4.0.4.3.3.0-40
-
PutAzureQueueStorage_v12 2.4.0.4.3.3.0-40
-
PutBigQuery 2.4.0.4.3.3.0-40
-
PutBoxFile 2.4.0.4.3.3.0-40
-
PutCassandraQL 2.4.0.4.3.3.0-40
-
PutCassandraRecord 2.4.0.4.3.3.0-40
-
PutCDPObjectStore 2.4.0.4.3.3.0-40
-
PutClouderaHiveQL 2.4.0.4.3.3.0-40
-
PutClouderaHiveStreaming 2.4.0.4.3.3.0-40
-
PutClouderaORC 2.4.0.4.3.3.0-40
-
PutCloudWatchMetric 2.4.0.4.3.3.0-40
-
PutCouchbaseKey 2.4.0.4.3.3.0-40
-
PutDatabaseRecord 2.4.0.4.3.3.0-40
-
PutDistributedMapCache 2.4.0.4.3.3.0-40
-
PutDropbox 2.4.0.4.3.3.0-40
-
PutDynamoDB 2.4.0.4.3.3.0-40
-
PutDynamoDBRecord 2.4.0.4.3.3.0-40
-
PutElasticsearchJson 2.4.0.4.3.3.0-40
-
PutElasticsearchRecord 2.4.0.4.3.3.0-40
-
PutEmail 2.4.0.4.3.3.0-40
-
PutFile 2.4.0.4.3.3.0-40
-
PutFTP 2.4.0.4.3.3.0-40
-
PutGCSObject 2.4.0.4.3.3.0-40
-
PutGoogleDrive 2.4.0.4.3.3.0-40
-
PutGridFS 2.4.0.4.3.3.0-40
-
PutHBaseCell 2.4.0.4.3.3.0-40
-
PutHBaseJSON 2.4.0.4.3.3.0-40
-
PutHBaseRecord 2.4.0.4.3.3.0-40
-
PutHDFS 2.4.0.4.3.3.0-40
-
PutIceberg 2.4.0.4.3.3.0-40
-
PutIcebergCDC 2.4.0.4.3.3.0-40
-
PutIoTDBRecord 2.4.0.4.3.3.0-40
-
PutJiraIssue 2.4.0.4.3.3.0-40
-
PutKinesisFirehose 2.4.0.4.3.3.0-40
-
PutKinesisStream 2.4.0.4.3.3.0-40
-
PutKudu 2.4.0.4.3.3.0-40
-
PutLambda 2.4.0.4.3.3.0-40
-
PutMongo 2.4.0.4.3.3.0-40
-
PutMongoBulkOperations 2.4.0.4.3.3.0-40
-
PutMongoRecord 2.4.0.4.3.3.0-40
-
PutParquet 2.4.0.4.3.3.0-40
-
PutPLC 2.4.0.4.3.3.0-40
-
PutRecord 2.4.0.4.3.3.0-40
-
PutRedisHashRecord 2.4.0.4.3.3.0-40
-
PutS3Object 2.4.0.4.3.3.0-40
-
PutSalesforceObject 2.4.0.4.3.3.0-40
-
PutSFTP 2.4.0.4.3.3.0-40
-
PutSmbFile 2.4.0.4.3.3.0-40
-
PutSnowflakeInternalStage 2.4.0.4.3.3.0-40
-
PutSNS 2.4.0.4.3.3.0-40
-
PutSolrContentStream 2.4.0.4.3.3.0-40
-
PutSolrRecord 2.4.0.4.3.3.0-40
-
PutSplunk 2.4.0.4.3.3.0-40
-
PutSplunkHTTP 2.4.0.4.3.3.0-40
-
PutSQL 2.4.0.4.3.3.0-40
-
PutSQS 2.4.0.4.3.3.0-40
-
PutSyslog 2.4.0.4.3.3.0-40
-
PutTCP 2.4.0.4.3.3.0-40
-
PutUDP 2.4.0.4.3.3.0-40
-
PutWebSocket 2.4.0.4.3.3.0-40
-
PutZendeskTicket 2.4.0.4.3.3.0-40
-
QueryAirtableTable 2.4.0.4.3.3.0-40
-
QueryAzureDataExplorer 2.4.0.4.3.3.0-40
-
QueryCassandra 2.4.0.4.3.3.0-40
-
QueryDatabaseTable 2.4.0.4.3.3.0-40
-
QueryDatabaseTableRecord 2.4.0.4.3.3.0-40
-
QueryIoTDBRecord 2.4.0.4.3.3.0-40
-
QueryRecord 2.4.0.4.3.3.0-40
-
QuerySalesforceObject 2.4.0.4.3.3.0-40
-
QuerySolr 2.4.0.4.3.3.0-40
-
QuerySplunkIndexingStatus 2.4.0.4.3.3.0-40
-
RemoveRecordField 2.4.0.4.3.3.0-40
-
RenameRecordField 2.4.0.4.3.3.0-40
-
ReplaceText 2.4.0.4.3.3.0-40
-
ReplaceTextWithMapping 2.4.0.4.3.3.0-40
-
ResizeImage 2.4.0.4.3.3.0-40
-
RetryFlowFile 2.4.0.4.3.3.0-40
-
RouteHL7 2.4.0.4.3.3.0-40
-
RouteOnAttribute 2.4.0.4.3.3.0-40
-
RouteOnContent 2.4.0.4.3.3.0-40
-
RouteText 2.4.0.4.3.3.0-40
-
RunMongoAggregation 2.4.0.4.3.3.0-40
-
SampleRecord 2.4.0.4.3.3.0-40
-
SawmillTransformJSON 2.4.0.4.3.3.0-40
-
SawmillTransformRecord 2.4.0.4.3.3.0-40
-
ScanAccumulo 2.4.0.4.3.3.0-40
-
ScanAttribute 2.4.0.4.3.3.0-40
-
ScanContent 2.4.0.4.3.3.0-40
-
ScanHBase 2.4.0.4.3.3.0-40
-
ScriptedFilterRecord 2.4.0.4.3.3.0-40
-
ScriptedPartitionRecord 2.4.0.4.3.3.0-40
-
ScriptedTransformRecord 2.4.0.4.3.3.0-40
-
ScriptedValidateRecord 2.4.0.4.3.3.0-40
-
SearchElasticsearch 2.4.0.4.3.3.0-40
-
SegmentContent 2.4.0.4.3.3.0-40
-
SelectClouderaHiveQL 2.4.0.4.3.3.0-40
-
SendTrapSNMP 2.4.0.4.3.3.0-40
-
SetSNMP 2.4.0.4.3.3.0-40
-
SignContentPGP 2.4.0.4.3.3.0-40
-
SplitAvro 2.4.0.4.3.3.0-40
-
SplitContent 2.4.0.4.3.3.0-40
-
SplitExcel 2.4.0.4.3.3.0-40
-
SplitJson 2.4.0.4.3.3.0-40
-
SplitPCAP 2.4.0.4.3.3.0-40
-
SplitRecord 2.4.0.4.3.3.0-40
-
SplitText 2.4.0.4.3.3.0-40
-
SplitXml 2.4.0.4.3.3.0-40
-
StartAwsPollyJob 2.4.0.4.3.3.0-40
-
StartAwsTextractJob 2.4.0.4.3.3.0-40
-
StartAwsTranscribeJob 2.4.0.4.3.3.0-40
-
StartAwsTranslateJob 2.4.0.4.3.3.0-40
-
StartGcpVisionAnnotateFilesOperation 2.4.0.4.3.3.0-40
-
StartGcpVisionAnnotateImagesOperation 2.4.0.4.3.3.0-40
-
StartSnowflakeIngest 2.4.0.4.3.3.0-40
-
TagS3Object 2.4.0.4.3.3.0-40
-
TailFile 2.4.0.4.3.3.0-40
-
TransformXml 2.4.0.4.3.3.0-40
-
TriggerClouderaHiveMetaStoreEvent 2.4.0.4.3.3.0-40
-
UnpackContent 2.4.0.4.3.3.0-40
-
UpdateAttribute 2.4.0.4.3.3.0-40
-
UpdateBoxFileMetadataInstance 2.4.0.4.3.3.0-40
-
UpdateByQueryElasticsearch 2.4.0.4.3.3.0-40
-
UpdateClouderaHiveTable 2.4.0.4.3.3.0-40
-
UpdateCounter 2.4.0.4.3.3.0-40
-
UpdateDatabaseTable 2.4.0.4.3.3.0-40
-
UpdateDeltaLakeTable 2.4.0.4.3.3.0-40
-
UpdateJiraIssue 2.4.0.4.3.3.0-40
-
UpdateRecord 2.4.0.4.3.3.0-40
-
ValidateCsv 2.4.0.4.3.3.0-40
-
ValidateJson 2.4.0.4.3.3.0-40
-
ValidateRecord 2.4.0.4.3.3.0-40
-
ValidateXml 2.4.0.4.3.3.0-40
-
VerifyContentMAC 2.4.0.4.3.3.0-40
-
VerifyContentPGP 2.4.0.4.3.3.0-40
-
Wait 2.4.0.4.3.3.0-40
-
-
Controller Services
-
AccumuloService 2.4.0.4.3.3.0-40
-
ActiveMQJMSConnectionFactoryProvider 2.4.0.4.3.3.0-40
-
ADLSCredentialsControllerService 2.4.0.4.3.3.0-40
-
ADLSCredentialsControllerServiceLookup 2.4.0.4.3.3.0-40
-
ADLSIDBrokerCloudCredentialsProviderControllerService 2.4.0.4.3.3.0-40
-
AmazonGlueSchemaRegistry 2.4.0.4.3.3.0-40
-
AmazonMSKConnectionService 2.4.0.4.3.3.0-40
-
ApicurioSchemaRegistry 2.4.0.4.3.3.0-40
-
AvroReader 2.4.0.4.3.3.0-40
-
AvroRecordSetWriter 2.4.0.4.3.3.0-40
-
AvroSchemaRegistry 2.4.0.4.3.3.0-40
-
AWSCredentialsProviderControllerService 2.4.0.4.3.3.0-40
-
AWSIDBrokerCloudCredentialsProviderControllerService 2.4.0.4.3.3.0-40
-
AzureBlobIDBrokerCloudCredentialsProviderControllerService 2.4.0.4.3.3.0-40
-
AzureBlobStorageFileResourceService 2.4.0.4.3.3.0-40
-
AzureCosmosDBClientService 2.4.0.4.3.3.0-40
-
AzureDataLakeStorageFileResourceService 2.4.0.4.3.3.0-40
-
AzureEventHubRecordSink 2.4.0.4.3.3.0-40
-
AzureServiceBusJMSConnectionFactoryProvider 2.4.0.4.3.3.0-40
-
AzureStorageCredentialsControllerService_v12 2.4.0.4.3.3.0-40
-
AzureStorageCredentialsControllerServiceLookup_v12 2.4.0.4.3.3.0-40
-
CassandraDistributedMapCache 2.4.0.4.3.3.0-40
-
CassandraSessionProvider 2.4.0.4.3.3.0-40
-
CdpCredentialsProviderControllerService 2.4.0.4.3.3.0-40
-
CdpOauth2AccessTokenProviderControllerService 2.4.0.4.3.3.0-40
-
CEFReader 2.4.0.4.3.3.0-40
-
CiscoEmblemSyslogMessageReader 2.4.0.4.3.3.0-40
-
ClouderaAttributeSchemaReferenceReader 2.4.0.4.3.3.0-40
-
ClouderaAttributeSchemaReferenceWriter 2.4.0.4.3.3.0-40
-
ClouderaEncodedSchemaReferenceReader 2.4.0.4.3.3.0-40
-
ClouderaEncodedSchemaReferenceWriter 2.4.0.4.3.3.0-40
-
ClouderaHiveConnectionPool 2.4.0.4.3.3.0-40
-
ClouderaHiveConnectionPoolLookup 2.4.0.4.3.3.0-40
-
ClouderaSchemaRegistry 2.4.0.4.3.3.0-40
-
CMLLookupService 2.4.0.4.3.3.0-40
-
ConfluentEncodedSchemaReferenceReader 2.4.0.4.3.3.0-40
-
ConfluentEncodedSchemaReferenceWriter 2.4.0.4.3.3.0-40
-
ConfluentSchemaRegistry 2.4.0.4.3.3.0-40
-
CouchbaseClusterService 2.4.0.4.3.3.0-40
-
CouchbaseKeyValueLookupService 2.4.0.4.3.3.0-40
-
CouchbaseMapCacheClient 2.4.0.4.3.3.0-40
-
CouchbaseRecordLookupService 2.4.0.4.3.3.0-40
-
CSVReader 2.4.0.4.3.3.0-40
-
CSVRecordLookupService 2.4.0.4.3.3.0-40
-
CSVRecordSetWriter 2.4.0.4.3.3.0-40
-
DatabaseRecordLookupService 2.4.0.4.3.3.0-40
-
DatabaseRecordSink 2.4.0.4.3.3.0-40
-
DatabaseTableSchemaRegistry 2.4.0.4.3.3.0-40
-
DBCPConnectionPool 2.4.0.4.3.3.0-40
-
DBCPConnectionPoolLookup 2.4.0.4.3.3.0-40
-
DeveloperBoxClientService 2.4.0.4.3.3.0-40
-
DistributedMapCacheLookupService 2.4.0.4.3.3.0-40
-
EBCDICRecordReader 2.4.0.4.3.3.0-40
-
ElasticSearchClientServiceImpl 2.4.0.4.3.3.0-40
-
ElasticSearchLookupService 2.4.0.4.3.3.0-40
-
ElasticSearchStringLookupService 2.4.0.4.3.3.0-40
-
EmailRecordSink 2.4.0.4.3.3.0-40
-
EmbeddedHazelcastCacheManager 2.4.0.4.3.3.0-40
-
ExcelReader 2.4.0.4.3.3.0-40
-
ExternalHazelcastCacheManager 2.4.0.4.3.3.0-40
-
FreeFormTextRecordSetWriter 2.4.0.4.3.3.0-40
-
GCPCredentialsControllerService 2.4.0.4.3.3.0-40
-
GCSFileResourceService 2.4.0.4.3.3.0-40
-
GenericPLC4XConnectionPool 2.4.0.4.3.3.0-40
-
GrokReader 2.4.0.4.3.3.0-40
-
HadoopCatalogService 2.4.0.4.3.3.0-40
-
HadoopDBCPConnectionPool 2.4.0.4.3.3.0-40
-
HazelcastMapCacheClient 2.4.0.4.3.3.0-40
-
HBase_2_ClientMapCacheService 2.4.0.4.3.3.0-40
-
HBase_2_ClientService 2.4.0.4.3.3.0-40
-
HBase_2_RecordLookupService 2.4.0.4.3.3.0-40
-
HikariCPConnectionPool 2.4.0.4.3.3.0-40
-
HiveCatalogService 2.4.0.4.3.3.0-40
-
HttpRecordSink 2.4.0.4.3.3.0-40
-
ImpalaConnectionPool 2.4.0.4.3.3.0-40
-
IPFIXReader 2.4.0.4.3.3.0-40
-
IPLookupService 2.4.0.4.3.3.0-40
-
JASN1Reader 2.4.0.4.3.3.0-40
-
JdbcCatalogService 2.4.0.4.3.3.0-40
-
JettyWebSocketClient 2.4.0.4.3.3.0-40
-
JettyWebSocketServer 2.4.0.4.3.3.0-40
-
JiraRecordSink 2.4.0.4.3.3.0-40
-
JMSConnectionFactoryProvider 2.4.0.4.3.3.0-40
-
JndiJmsConnectionFactoryProvider 2.4.0.4.3.3.0-40
-
JsonConfigBasedBoxClientService 2.4.0.4.3.3.0-40
-
JsonPathReader 2.4.0.4.3.3.0-40
-
JsonRecordSetWriter 2.4.0.4.3.3.0-40
-
JsonTreeReader 2.4.0.4.3.3.0-40
-
JWTBearerOAuth2AccessTokenProvider 2.4.0.4.3.3.0-40
-
Kafka3ConnectionService 2.4.0.4.3.3.0-40
-
KafkaRecordSink_2_6 2.4.0.4.3.3.0-40
-
KerberosKeytabUserService 2.4.0.4.3.3.0-40
-
KerberosPasswordUserService 2.4.0.4.3.3.0-40
-
KerberosTicketCacheUserService 2.4.0.4.3.3.0-40
-
KuduLookupService 2.4.0.4.3.3.0-40
-
LivySessionController 2.4.0.4.3.3.0-40
-
LoggingRecordSink 2.4.0.4.3.3.0-40
-
MapCacheClientService 2.4.0.4.3.3.0-40
-
MapCacheServer 2.4.0.4.3.3.0-40
-
MongoDBControllerService 2.4.0.4.3.3.0-40
-
MongoDBLookupService 2.4.0.4.3.3.0-40
-
Neo4JCypherClientService 2.4.0.4.3.3.0-40
-
ParquetReader 2.4.0.4.3.3.0-40
-
ParquetRecordSetWriter 2.4.0.4.3.3.0-40
-
PEMEncodedSSLContextProvider 2.4.0.4.3.3.0-40
-
PhoenixThickConnectionPool 2.4.0.4.3.3.0-40
-
PhoenixThinConnectionPool 2.4.0.4.3.3.0-40
-
PostgreSQLConnectionPool 2.4.0.4.3.3.0-40
-
PropertiesFileLookupService 2.4.0.4.3.3.0-40
-
ProtobufReader 2.4.0.4.3.3.0-40
-
ProxyPLC4XConnectionPool 2.4.0.4.3.3.0-40
-
RabbitMQJMSConnectionFactoryProvider 2.4.0.4.3.3.0-40
-
ReaderLookup 2.4.0.4.3.3.0-40
-
RecordSetWriterLookup 2.4.0.4.3.3.0-40
-
RecordSinkServiceLookup 2.4.0.4.3.3.0-40
-
RedisConnectionPoolService 2.4.0.4.3.3.0-40
-
RedisDistributedMapCacheClientService 2.4.0.4.3.3.0-40
-
RedshiftConnectionPool 2.4.0.4.3.3.0-40
-
RESTCatalogService 2.4.0.4.3.3.0-40
-
RestLookupService 2.4.0.4.3.3.0-40
-
S3FileResourceService 2.4.0.4.3.3.0-40
-
ScriptedLookupService 2.4.0.4.3.3.0-40
-
ScriptedReader 2.4.0.4.3.3.0-40
-
ScriptedRecordSetWriter 2.4.0.4.3.3.0-40
-
ScriptedRecordSink 2.4.0.4.3.3.0-40
-
SetCacheClientService 2.4.0.4.3.3.0-40
-
SetCacheServer 2.4.0.4.3.3.0-40
-
SimpleCsvFileLookupService 2.4.0.4.3.3.0-40
-
SimpleDatabaseLookupService 2.4.0.4.3.3.0-40
-
SimpleKeyValueLookupService 2.4.0.4.3.3.0-40
-
SimpleRedisDistributedMapCacheClientService 2.4.0.4.3.3.0-40
-
SimpleScriptedLookupService 2.4.0.4.3.3.0-40
-
SiteToSiteReportingRecordSink 2.4.0.4.3.3.0-40
-
SlackRecordSink 2.4.0.4.3.3.0-40
-
SmbjClientProviderService 2.4.0.4.3.3.0-40
-
SnowflakeComputingConnectionPool 2.4.0.4.3.3.0-40
-
StandardAsanaClientProviderService 2.4.0.4.3.3.0-40
-
StandardAzureCredentialsControllerService 2.4.0.4.3.3.0-40
-
StandardDatabaseDialectService 2.4.0.4.3.3.0-40
-
StandardDropboxCredentialService 2.4.0.4.3.3.0-40
-
StandardFileResourceService 2.4.0.4.3.3.0-40
-
StandardHashiCorpVaultClientService 2.4.0.4.3.3.0-40
-
StandardHttpContextMap 2.4.0.4.3.3.0-40
-
StandardJiraCredentialService 2.4.0.4.3.3.0-40
-
StandardJsonSchemaRegistry 2.4.0.4.3.3.0-40
-
StandardKustoIngestService 2.4.0.4.3.3.0-40
-
StandardKustoQueryService 2.4.0.4.3.3.0-40
-
StandardOauth2AccessTokenProvider 2.4.0.4.3.3.0-40
-
StandardPGPPrivateKeyService 2.4.0.4.3.3.0-40
-
StandardPGPPublicKeyService 2.4.0.4.3.3.0-40
-
StandardPLC4XConnectionPool 2.4.0.4.3.3.0-40
-
StandardPrivateKeyService 2.4.0.4.3.3.0-40
-
StandardProxyConfigurationService 2.4.0.4.3.3.0-40
-
StandardRestrictedSSLContextService 2.4.0.4.3.3.0-40
-
StandardS3EncryptionService 2.4.0.4.3.3.0-40
-
StandardSnowflakeIngestManagerProviderService 2.4.0.4.3.3.0-40
-
StandardSSLContextService 2.4.0.4.3.3.0-40
-
StandardWebClientServiceProvider 2.4.0.4.3.3.0-40
-
Syslog5424Reader 2.4.0.4.3.3.0-40
-
SyslogReader 2.4.0.4.3.3.0-40
-
TinkerpopClientService 2.4.0.4.3.3.0-40
-
UDPEventRecordSink 2.4.0.4.3.3.0-40
-
VolatileSchemaCache 2.4.0.4.3.3.0-40
-
WindowsEventLogReader 2.4.0.4.3.3.0-40
-
XMLFileLookupService 2.4.0.4.3.3.0-40
-
XMLReader 2.4.0.4.3.3.0-40
-
XMLRecordSetWriter 2.4.0.4.3.3.0-40
-
YamlTreeReader 2.4.0.4.3.3.0-40
-
ZendeskRecordSink 2.4.0.4.3.3.0-40
-
-
Reporting Tasks
-
AzureLogAnalyticsProvenanceReportingTask 2.4.0.4.3.3.0-40
-
AzureLogAnalyticsReportingTask 2.4.0.4.3.3.0-40
-
ControllerStatusReportingTask 2.4.0.4.3.3.0-40
-
MonitorDiskUsage 2.4.0.4.3.3.0-40
-
MonitorMemory 2.4.0.4.3.3.0-40
-
QueryNiFiReportingTask 2.4.0.4.3.3.0-40
-
ReportLineageToAtlas 2.4.0.4.3.3.0-40
-
ScriptedReportingTask 2.4.0.4.3.3.0-40
-
SiteToSiteBulletinReportingTask 2.4.0.4.3.3.0-40
-
SiteToSiteMetricsReportingTask 2.4.0.4.3.3.0-40
-
SiteToSiteProvenanceReportingTask 2.4.0.4.3.3.0-40
-
SiteToSiteStatusReportingTask 2.4.0.4.3.3.0-40
-
-
Parameter Providers
-
AwsSecretsManagerParameterProvider 2.4.0.4.3.3.0-40
-
AzureKeyVaultSecretsParameterProvider 2.4.0.4.3.3.0-40
-
CyberArkConjurParameterProvider 2.4.0.4.3.3.0-40
-
DatabaseParameterProvider 2.4.0.4.3.3.0-40
-
EnvironmentVariableParameterProvider 2.4.0.4.3.3.0-40
-
GcpSecretManagerParameterProvider 2.4.0.4.3.3.0-40
-
HashiCorpVaultParameterProvider 2.4.0.4.3.3.0-40
-
KubernetesSecretParameterProvider 2.4.0.4.3.3.0-40
-
OnePasswordParameterProvider 2.4.0.4.3.3.0-40
-
PropertiesFileParameterProvider 2.4.0.4.3.3.0-40
-
-
Flow Analysis Rules
-
DisallowComponentType 2.4.0.4.3.3.0-40
-
DisallowConsecutiveConnectionsWithRoundRobinLB 2.4.0.4.3.3.0-40
-
DisallowDeadEnd 2.4.0.4.3.3.0-40
-
DisallowDeprecatedProcessor 2.4.0.4.3.3.0-40
-
DisallowExtractTextForFullContent 2.4.0.4.3.3.0-40
-
RecommendRecordProcessor 2.4.0.4.3.3.0-40
-
RequireHandleHttpResponseAfterHandleHttpRequest 2.4.0.4.3.3.0-40
-
RequireMergeBeforePutIceberg 2.4.0.4.3.3.0-40
-
RequireServerSSLContextService 2.4.0.4.3.3.0-40
-
RestrictBackpressureSettings 2.4.0.4.3.3.0-40
-
RestrictComponentNaming 2.4.0.4.3.3.0-40
-
RestrictConcurrentTasksVsThreadPoolSizeInProcessors 2.4.0.4.3.3.0-40
-
RestrictFlowFileExpiration 2.4.0.4.3.3.0-40
-
RestrictProcessorConcurrency 2.4.0.4.3.3.0-40
-
RestrictSchedulingForListProcessors 2.4.0.4.3.3.0-40
-
RestrictThreadPoolSize 2.4.0.4.3.3.0-40
-
RestrictYieldDurationForConsumeKafkaProcessors 2.4.0.4.3.3.0-40
-
KafkaRecordSink_2_6 2.4.0.4.3.3.0-40
- Bundle
- org.apache.nifi | nifi-kafka-2-6-nar
- Description
- Provides a service to write records to a Kafka 2.6+ topic.
- 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 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
- Environment variables and FlowFile Attributes
- Sensitive
- false
- Required
- false
- Dependencies
-
- SASL Mechanism is set to any of [AWS_MSK_IAM]
-
Kafka Brokers
Comma-separated list of Kafka Brokers in the format host:port
- Display Name
- Kafka Brokers
- Description
- Comma-separated list of Kafka Brokers in the format host:port
- API Name
- bootstrap.servers
- Default Value
- localhost:9092
- Expression Language Scope
- Environment variables defined at JVM level and system properties
- 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
-
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
- false
-
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
-
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
- false
-
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
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- true
-
Password
Password provided with configured username when using PLAIN or SCRAM SASL Mechanisms
- Display Name
- 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
- false
- Dependencies
-
- SASL Mechanism is set to any of [PLAIN, SCRAM-SHA-512, SCRAM-SHA-256]
-
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-512, SCRAM-SHA-256]
-
Username
Username provided with configured password when using PLAIN or SCRAM SASL Mechanisms
- Display Name
- 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
- false
- Dependencies
-
- SASL Mechanism is set to any of [PLAIN, SCRAM-SHA-512, SCRAM-SHA-256]
-
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
-
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.
These 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.
- Name
- The name of a Kafka configuration property.
- Description
- These 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.
- Value
- The value of a given Kafka configuration property.
- Expression Language Scope
- ENVIRONMENT