Skip to content

Instantly share code, notes, and snippets.

@fhussonnois
Created January 22, 2020 11: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/f8f21b2a7e3f79c61f1350e5b5050d7a to your computer and use it in GitHub Desktop.
Save fhussonnois/f8f21b2a7e3f79c61f1350e5b5050d7a to your computer and use it in GitHub Desktop.
example-file-pulse-log4j.properties
# List of aliases for the filter chain, specifying the order in which the filters will be applied.
filters=GroupMultilineException, ParseLog4jLog
# Configuration for the filter with alias 'GroupMultilineException'
filters.GroupMultilineException.negate=false
filters.GroupMultilineException.pattern="^[\\t]"
filters.GroupMultilineException.type=io.streamthoughts.kafka.connect.filepulse.filter.MultiRowFilter
# Configuration for the filter with alias 'ParseLog4jLog'
filters.ParseLog4jLog.match="%{TIMESTAMP_ISO8601:logdate} %{LOGLEVEL:loglevel} %{GREEDYDATA:message}"
filters.ParseLog4jLog.overwrite=message
filters.ParseLog4jLog.source=message
filters.ParseLog4jLog.type=io.streamthoughts.kafka.connect.filepulse.filter.GrokFilter
filters.ParseLog4jLog.ignoreFailure=true
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment