Issue #1148 Add KafkaOutput
Allow restart attempts on failure.
Added optional HTTP authentication against the ElasticSearch HTTP
server. This is needed if you have put a proxy before your ElasticSearch
server that uses HTTPS and Basic Auth to protect access to the
ElasticSearch server.
Issue #1148 Add KafkaInput
1) return big message from tokenizers. 2) Logstreamer: drop this message or keep only truncated first part of it (depends on new config option)
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.
Merge pull request #1177 from arrrrgh/stable_issue_1165

Added max_msg_size to StatsdInput for message size. Closes #1165.