franz

Documentation

Index

• Constants
• type Config
  • func (c *Config) Validate() error
• type Source
  • func (k *Source) Category() api.Category
  • func (k *Source) Commit(events []api.Event)
  • func (k *Source) Config() interface{}
  • func (k *Source) Init(context api.Context) error
  • func (k *Source) ProductLoop(productFunc api.ProductFunc)
  • func (k *Source) Start() error
  • func (k *Source) Stop()
  • func (k *Source) String() string
  • func (k *Source) Type() api.Type

Constants

const (
	Type = "franzKafka"
)

Types

type Config

type Config struct {
	Brokers  []string `yaml:"brokers,omitempty" validate:"required"`
	Topic    string   `yaml:"topic,omitempty"`
	Topics   []string `yaml:"topics,omitempty"`
	GroupId  string   `yaml:"groupId,omitempty" default:"loggie"`
	ClientId string   `yaml:"clientId,omitempty"`
	Worker   int      `yaml:"worker,omitempty" default:"1"`

	FetchMaxWait           time.Duration `yaml:"fetchMaxWait,omitempty"`
	FetchMaxBytes          int32         `yaml:"fetchMaxBytes,omitempty"`
	FetchMinBytes          int32         `yaml:"fetchMinBytes,omitempty"`
	FetchMaxPartitionBytes int32         `yaml:"fetchMaxPartitionBytes,omitempty"`

	EnableAutoCommit   bool          `yaml:"enableAutoCommit,omitempty"`
	AutoCommitInterval time.Duration `yaml:"autoCommitInterval,omitempty" default:"1s"`
	AutoOffsetReset    string        `yaml:"autoOffsetReset,omitempty" default:"latest"`

	SASL franz.SASL `yaml:"sasl,omitempty"`

	AddonMeta *bool `yaml:"addonMeta,omitempty" default:"true"`
}

func (*Config) Validate

func (c *Config) Validate() error

type Source

type Source struct {
	// contains filtered or unexported fields
}

func (*Source) Category

func (k *Source) Category() api.Category

func (*Source) Commit

func (k *Source) Commit(events []api.Event)

func (*Source) Config

func (k *Source) Config() interface{}

func (*Source) Init

func (k *Source) Init(context api.Context) error

func (*Source) ProductLoop

func (k *Source) ProductLoop(productFunc api.ProductFunc)

func (*Source) Start

func (k *Source) Start() error

func (*Source) Stop

func (k *Source) Stop()

func (*Source) String

func (k *Source) String() string

func (*Source) Type

func (k *Source) Type() api.Type