Sources / Sinks:
- ConnectWebSocket
- ConsumeAMQP
- ConsumeIMAP
- ConsumeJMS
- ConsumeKafka
- ConsumeKafka_0_10
- ConsumeMQTT
- ConsumePOP3
- ConsumeWindowsEventLog
- ExecuteFlumeSink
- ExecuteFlumeSource
- FetchDistributedMapCache
- FetchElasticsearch
- FetchElasticsearch5
- FetchElasticsearchHttp
- FetchFile
- FetchFTP
- FetchHDFS
- FetchS3Object
- FetchSFTP
- GenerateFlowFile
- GenerateTableFetch
- GetAzureEventHub
- GetCouchbaseKey
- GetDynamoDB
- GetFile
- GetFTP
- GetHBase
- GetHDFS
- GetHDFSEvents
- GetHDFSSequenceFile
- GetHTMLElement
- GetHTTP
- GetIgniteCache
- GetJMSQueue
- GetJMSTopic
- GetKafka
- GetMongo
- GetSFTP
- GetSNMP
- GetSolr
- GetSplunk
- GetSQS
- GetTwitter
- HandleHttpRequest
- HandleHttpResponse
- ListDatabaseTables
- ListenHTTP
- ListenLumberjack
- ListenRELP
- ListenSMTP
- ListenSyslog
- ListenTCP
- ListenUDP
- ListenWebSocket
- ListFile
- ListFTP
- ListHDFS
- ListS3
- ListSFTP
- PostHTTP
- PublishAMQP
- PublishJMS
- PublishKafka
- PublishKafka_0_10
- PublishMQTT
- PutAzureEventHub
- PutCassandraQL
- PutCloudWatchMetric
- PutCouchbaseKey
- PutDistributedMapCache
- PutDynamoDB
- PutElasticsearch
- PutElasticsearch5
- PutElasticsearchHttp
- PutEmail
- PutFile
- PutFTP
- PutHBaseCell
- PutHBaseJSON
- PutHDFS
- PutHiveQL
- PutHiveStreaming
- PutHTMLElement
- PutIgniteCache
- PutJMS
- PutKafka
- PutKinesisFirehose
- PutKinesisStream
- PutLambda
- PutMongo
- PutRiemann
- PutS3Object
- PutSFTP
- PutSlack
- PutSNS
- PutSolrContentStream
- PutSplunk
- PutSQL
- PutSQS
- PutSyslog
- PutTCP
- PutUDP
- PutWebSocket
- StoreInKiteDataset
- TailFile
SerDe / Convertalizers / FileFormats:
- ConvertAvroSchema
- ConvertAvroToJSON
- ConvertAvroToORC
- ConvertCSVToAvro
- ConvertJSONToAvro
- ConvertJSONToSQL
- CreateHadoopSequenceFile
Enrichment
- DeleteDynamoDB
- DeleteHDFS
- DeleteS3Object
- DeleteSQS
- ExecuteProcess
- ExecuteScript
- ExecuteSQL
- ExecuteStreamCommand
- InvokeHTTP
- QueryCassandra
- QueryDatabaseTable
- QueryDNS
- QueryElasticsearchHttp
- QueryWhois
- ScrollElasticsearchHttp
- SelectHiveQL
- SetSNMP
- SpringContextProcessor
- YandexTranslate
Irrelevant in Kafka or belongs in Streams:
SMT
- AttributesToJSON <- assumes headers
- Base64EncodeContent
- CompressContent
- ConvertCharacterSet
- DuplicateFlowFile
- EncryptContent
- EvaluateJsonPath
- EvaluateXPath
- EvaluateXQuery
- ExtractAvroMetadata
- ExtractEmailAttachments
- ExtractEmailHeaders
- ExtractHL7Attributes
- ExtractImageMetadata
- ExtractMediaMetadata
- ExtractText
- ExtractTNEFAttachments
- GeoEnrichIP
- HashAttribute <- assumes headers
- HashContent
- IdentifyMimeType
- InferAvroSchema
- InvokeScriptedProcessor <- arguable, maybe it doesn't belong at all
- JoltTransformJSON
- ModifyBytes
- ModifyHTMLElement
- ParseCEF
- ParseEvtx
- ParseSyslog
- ReplaceText
- ReplaceTextWithMapping
- ResizeImage
- RouteHL7
- RouteOnAttribute <- assumes headers
- RouteOnContent
- RouteText
- ScanAttribute
- ScanContent
- SegmentContent
- SplitAvro
- SplitContent
- SplitJson
- SplitText
- SplitXml
- TransformXml
- UnpackContent
- UpdateAttribute <- assumes headers
- ValidateCsv
- ValidateXml