Issue #1148 Add KafkaOutput
Allow restart attempts on failure.
Issue #1148 Add KafkaInput
Issue #1131 added immediate_start for ProcessInput.
1) return big message from tokenizers. 2) Logstreamer: drop this message or keep only truncated first part of it (depends on new config option)
Merge pull request #1152 from arrrrgh/issue_1131

Issue #1131 added immediate_start for ProcessInput.
Log brokerProducer errors in KafkaOutput
Fix the encoder check to not Queue a nil message
Add a stat to track discarded messages, encode() with no output or error
keeping the errChan empty more important than new packs

if heka is busy, inchan wins over errChan and QueueMessage will block
forever
Merge pull request #1169 from imgix/kafka_output

keeping the errChan empty more important than new packs
Improve producer errChan handling and prevent QueueMessage deadlocks
Fix leaky file descriptor bug on http_output.go
Merge pull request #1173 from didip/close-response-body-08x

Fix leaky file descriptor bug on http_output.go
Merge pull request #1137 from validname/validname_fix_tokenizer

Add ability to drop big message entirely or to decode first part of it
Add a goroutine to offload the Kafka errChan processing and prevent deadlocks
Stamp packs only when a message matcher succeeds.
Add RWMutex to protect packet tracking metadata from multiple
goroutine access, and fix the refcounting that I broke w/ the first
commit.
Merge pull request #1176 from mozilla-services/pack_diag_match_fix

Pack diag match fix
Issue #1165 Added max_msg_size to StatsdInput for message size.