Uploaded image for project: 'Flume'
  1. Flume
  2. FLUME-2800

Multiline log events for Taildir Source

    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Resolved
    • Minor
    • Resolution: Duplicate
    • 1.6.0, 1.7.0
    • None
    • Sinks+Sources
    • None

    Description

      This a proposal of implementation to handle multiline log messages for new tailing source FLUME-2498.
      Based on an idea FLUME-2779 MultiLine Deserializer for Spooling DIrectory Source.

      Config.

      • multiLineRegex: Regular expression to handle multiline log messages (grok expressions permitted)
      • grokDictionaryDir: Custom Grok dictionaries directory
      • maxNumberLines: Max number of lines per event in multiline log messages. Default 100. Remaining lines is never transferred to sink.

      For Regex expressions use Java regex engine.

      Include a functionality for extracting grok expressions into a pure named regex (inspired by the logstash inteceptor)
      By default load the included built-in grok dictionaries with pre-defined patterns.
      https://github.com/aicer/grok

      Attached patch includes a config documentation and unit tests.
      Also attached a completed port/patch for Flume 1.6 a Java 1.6

      Attachments

        1. FLUME-2800.patch
          89 kB
          David Burgos. Isban (Banco Santander)
        2. FLUME-2800-2.patch
          88 kB
          David Burgos. Isban (Banco Santander)
        3. FLUME-2800-2-Flume1.6.patch
          149 kB
          David Burgos. Isban (Banco Santander)
        4. FLUME-2800-Flume1.6.patch
          149 kB
          David Burgos. Isban (Banco Santander)

        Issue Links

          Activity

            People

              Unassigned Unassigned
              dburgosm David Burgos. Isban (Banco Santander)
              Votes:
              0 Vote for this issue
              Watchers:
              6 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: