htgc/fluent-plugin-kafka — pull request #3 by spsusbilla (2014-05-08 12:18:26+00:00)
Title: Created timesliced version of the plugin

I've created a time-sliced version of the kafka plugin. This is to optionally add the tag and timestamp to the record, as the two are dropped in kafka. Usage is similar to kafka_buffered, but the following conf settings has been added: tag_key, time_key and time_format.

Example conf:
```

type kafka_buffered
brokers :,:,..
default_topic
flush_interval 60>
buffer_type (file|memory)
output_data_type (json|ltsv|attr:)
tag_key tag
time_key timestamp
time_format %Y-%m-%d %H:%M:%S

```