A simple logstash pulsar output plugin. Will send logstash messages into an apache pulsar topic.
To build the plugin for use in logstash
> bundle install
> bundle exec rake vendor
Once dependencies are installed build the gem
> gem build logstash-output-pulsar.gemspec
Once the gem has been built you can install the gem with logstash. Copy the gem file to /usr/share/logstash directory and run
> logstash-plugin install /usr/share/logstash/logstash-output-pulsar-{{VERSION}}.gem
Use the following conf for your logstash config
output {
pulsar {
bootstrap_servers => "pulsar://pulsar-server:port"
batch_max_publish_delay => 300
batch_max_size => 300
topic_id => "persistent://pulsar-topic"
}
}