kafkaclient

Documentation

Index

• Constants
• func New() interface{ ... }
• type Configuration
  • func (c *Configuration) Default()
  • func (c *Configuration) FromEnv(envs map[string]string)
  • func (c *Configuration) Validate() error

Constants

const DefaultTopic string = "changes"

const EnvNameChangesTopic string = "BLUDGEON_CHANGES_TOPIC"

Functions

func New

func New() interface {
	client.Handler
	internal.Initializer
	internal.Parameterizer
	internal.Configurer
}

Types

type Configuration

type Configuration struct {
	Topic string
}

func (*Configuration) Default

func (c *Configuration) Default()

func (*Configuration) FromEnv

func (c *Configuration) FromEnv(envs map[string]string)

func (*Configuration) Validate

func (c *Configuration) Validate() error