confluent

Documentation

Index

• func ConfigAdd(path string)
• func New(ctx context.Context, producer *kafka.Producer) (publisher.Driver, error)
• func NewWithConfigPath(ctx context.Context, producer *kafka.Producer, path string) (publisher.Driver, error)
• func NewWithOptions(ctx context.Context, producer *kafka.Producer, options *Options) publisher.Driver
• type Options
  • func NewOptions() (*Options, error)
  • func NewOptionsWithPath(path string) (opts *Options, err error)

Functions

func ConfigAdd

func ConfigAdd(path string)

func New

func New(ctx context.Context, producer *kafka.Producer) (publisher.Driver, error)

New returns connection with default options.

func NewWithConfigPath

func NewWithConfigPath(ctx context.Context, producer *kafka.Producer, path string) (publisher.Driver, error)

NewWithConfigPath returns connection with options from config path.

func NewWithOptions

func NewWithOptions(ctx context.Context, producer *kafka.Producer, options *Options) publisher.Driver

NewWithOptions returns connection with options.

Types

type Options

type Options struct {
	Log struct {
		Level string
	}
}

Options kafka connection options.

func NewOptions

func NewOptions() (*Options, error)

NewOptions returns options from config file or environment vars.

func NewOptionsWithPath

func NewOptionsWithPath(path string) (opts *Options, err error)

NewOptionsWithPath unmarshals a given key path into options and returns it.