Sources / Sinks:

SerDe / Convertalizers / FileFormats:

Enrichment

Irrelevant in Kafka or belongs in Streams: 

SMT

  1. AttributesToJSON <- assumes headers
  2. Base64EncodeContent
  3. CompressContent
  4. ConvertCharacterSet
  5. DuplicateFlowFile
  6. EncryptContent
  7. EvaluateJsonPath
  8. EvaluateXPath
  9. EvaluateXQuery
  10. ExtractAvroMetadata
  11. ExtractEmailAttachments
  12. ExtractEmailHeaders
  13. ExtractHL7Attributes
  14. ExtractImageMetadata
  15. ExtractMediaMetadata
  16. ExtractText
  17. ExtractTNEFAttachments
  18. GeoEnrichIP
  19. HashAttribute <- assumes headers
  20. HashContent
  21. IdentifyMimeType
  22. InferAvroSchema
  23. InvokeScriptedProcessor <- arguable, maybe it doesn't belong at all
  24. JoltTransformJSON
  25. ModifyBytes
  26. ModifyHTMLElement
  27. ParseCEF
  28. ParseEvtx
  29. ParseSyslog
  30. ReplaceText
  31. ReplaceTextWithMapping
  32. ResizeImage
  33. RouteHL7
  34. RouteOnAttribute <- assumes headers
  35. RouteOnContent
  36. RouteText
  37. ScanAttribute
  38. ScanContent
  39. SegmentContent
  40. SplitAvro
  41. SplitContent
  42. SplitJson
  43. SplitText
  44. SplitXml
  45. TransformXml
  46. UnpackContent
  47. UpdateAttribute <- assumes headers
  48. ValidateCsv
  49. ValidateXml