Skip to content

ragi256/fluent-bit-pubsub

 
 

Repository files navigation

fluent-bit output plugin for google pubsub

example workflow

This plugin is used to publish data to queue in google pubsub.

You could easily use it.

Build

A bin directory already has been made binaries for mac, linux.

If you should directly make binaries for mac, linux

# local machine binary
$ bash make.sh build

# Your machine is mac, and if you should do to retry cross compiling for linux.
# A command in below is required a docker.
$ bash make.sh build_linux

Usage

configuration options for fluent-bit.conf

Key Description Default
Project google cloud project id NONE(required)
Topic google pubsub topic name NONE(required)
Jwt jwt string for accessible google cloud project (expected to be stored from ENV) NONE(Jwt or JwtPath required)
JwtPath jwt file path for accessible google cloud project NONE(Jwt or JwtPath required)
Debug print debug log false(optional)
Timeout the maximum time that the client will attempt to publish a bundle of messages. (millsecond) 60000 (optional)
DelayThreshold publish a non-empty batch after this delay has passed. (millsecond) 1
ByteThreshold publish a batch when its size in bytes reaches this value. 1000000
CountThreshold publish a batch when it has been reached count of messages. 100
SchemaType topic schema type Avro or Protocol Buffer. (Only support Avro yet) NONE(optional)
SchemaFilePath schema definition file path. NONE(optional)

Example fluent-bit.conf

[Output]
    Name pubsub
    Match *
    Project your-project(custom)
    Topic your-topic-name(custom)
    Jwtpath your-jwtpath(custom)

Example exec

$ fluent-bit -c [your config file] -e pubsub.so

About

FluentBit output plugin for google pubsub.

Resources

License

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published

Languages

  • Go 78.6%
  • C 14.4%
  • Shell 6.5%
  • Dockerfile 0.5%