- push logs to kafka through zookeeper.
- use kafka-rb of https://github.com/ops-baidu/kafka-rb.git
- jiuze#baidu.com
<match kafka.*.*>
# plugin type (requried)
type kafka
# product & service (requried)
product aqueducts
service astream
# buffer config (only requried in development mode, defalut value is ok for production.)
host 192.168.1.20
port 2181
# interval (optional, but it may affect the latency.)
flush_interval 1s
</match>
TODO: Write a gem description TODO: Also, I need to write tests
Add this line to your application's Gemfile:
gem 'fluent-plugin-kafka'
And then execute:
$ bundle
Or install it yourself as:
$ gem install fluent-plugin-kafka
TODO: Write usage instructions here
- Fork it
- Create your feature branch (
git checkout -b my-new-feature
) - Commit your changes (
git commit -am 'Added some feature'
) - Push to the branch (
git push origin my-new-feature
) - Create new Pull Request