kafka_input

package
v0.7.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 28, 2021 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Config

type Config struct {
	Name              string        `mapstructure:"name,omitempty"`
	Address           string        `mapstructure:"address,omitempty"`
	Topics            string        `mapstructure:"topics,omitempty"`
	GroupID           string        `mapstructure:"group-id,omitempty"`
	SessionTimeout    time.Duration `mapstructure:"session-timeout,omitempty"`
	HeartbeatInterval time.Duration `mapstructure:"heartbeat-interval,omitempty"`
	RecoveryWaitTime  time.Duration `mapstructure:"recovery-wait-time,omitempty"`
	Version           string        `mapstructure:"version,omitempty"`
	Format            string        `mapstructure:"format,omitempty"`
	Debug             bool          `mapstructure:"debug,omitempty"`
	NumWorkers        int           `mapstructure:"num-workers,omitempty"`
	Outputs           []string      `mapstructure:"outputs,omitempty"`
	// contains filtered or unexported fields
}

Config //

type KafkaInput

type KafkaInput struct {
	Cfg *Config
	// contains filtered or unexported fields
}

KafkaInput //

func (*KafkaInput) Close

func (k *KafkaInput) Close() error

func (*KafkaInput) SetLogger

func (k *KafkaInput) SetLogger(logger *log.Logger)

func (*KafkaInput) SetName

func (k *KafkaInput) SetName(name string)

func (*KafkaInput) SetOutputs

func (k *KafkaInput) SetOutputs(outs map[string]outputs.Output)

func (*KafkaInput) Start

func (k *KafkaInput) Start(ctx context.Context, name string, cfg map[string]interface{}, opts ...inputs.Option) error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL