heka configuration

gistfile1.txt

[hekad]
maxprocs=10

[LogstreamerInput]
log_directory = "/var/log"
file_match = 'local7\.log'
# decoder = "OABCloudDecoder"

[OABCloudDecoder]
type = "PayloadRegexDecoder"
match_regex = '^(?P<Timestamp>.*) (?P<Host>[a-zA-z]*) (?P<App>[a-zA-z]*) - (?P<Severity>[A-Z]*) - (?P<Message>.*)'
timestamp_layout = "Dec 18 15:46:29"

[OABCloudDecoder.severity_map]
DEBUG = 7
INFO = 6
NOTICE = 5
WARNING = 4
ERROR = 3
CRITICAL = 2
ALERT = 1
EMERGENCY = 0

[OABCloudDecoder.message_fields]
Type = "oabcloud_log"
Timestamp = "%Timestamp%"
App = "%App%"
Message = "%Message%"

[PayloadEncoder]
append_newlines = false

[LogOutput]
message_matcher = "TRUE"
encoder = "PayloadEncoder"

[ESJsonEncoder]
index = "%{Type}-%{2006.01.02}"
es_index_from_timestamp = true
type_name = "%{Type}"

[DashboardOutput]
ticker_interval = 30
working_directory = "/tmp/heka/"

[ElasticSearchOutput]
message_matcher = "TRUE"
server = "http://10.1.2.3:9200"
flush_interval = 5000
flush_count = 10
encoder = "ESJsonEncoder"