Skip to content

Instantly share code, notes, and snippets.

@fhussonnois
Last active January 22, 2020 13:41
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save fhussonnois/5fabbdd5a1912e9b21a2c09f278e72ab to your computer and use it in GitHub Desktop.
Save fhussonnois/5fabbdd5a1912e9b21a2c09f278e72ab to your computer and use it in GitHub Desktop.
example-file-pulse-conditional.properties
# The type of the filter
filters.TagSecurityException.type=io.streamthoughts.kafka.connect.filepulse.filter.AppendFilter
# The name of the field to add
filters.TagSecurityException.field=tags
# the value of the field
filters.TagSecurityException.values=SecurityAlert
# The filter condition expression (using Simple Connect Expression Language)
filters.TagSecurityException.if="{{ contains($value.logmessage, BadCredentialsException) }}"
# Invert the boolean value return from the if expression
filters.TagSecurityException.invert=false
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment