kafkaconsumergroup

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

type KafkaConsumerGroupInputConfig struct {
	Splitter string

	// Client Config
	MetadataRetries            int    `toml:"metadata_retries"`
	WaitForElection            uint32 `toml:"wait_for_election"`
	BackgroundRefreshFrequency uint32 `toml:"background_refresh_frequency"`

	// Broker Config
	MaxOpenRequests int    `toml:"max_open_reqests"`
	DialTimeout     uint32 `toml:"dial_timeout"`
	ReadTimeout     uint32 `toml:"read_timeout"`
	WriteTimeout    uint32 `toml:"write_timeout"`

	// Consumer Config
	Partition                 int32
	Group                     string
	DefaultFetchSize          int32    `toml:"default_fetch_size"`
	MinFetchSize              int32    `toml:"min_fetch_size"`
	MaxMessageSize            int32    `toml:"max_message_size"`
	MaxWaitTime               uint32   `toml:"max_wait_time"`
	ConsumerGroup             string   `toml:"consumer_group"`
	Topics                    []string `toml:"topics"`
	ZookeeperConnectionString string   `toml:"zookeeper_connection_string"`
	OffsetMethod              string   `toml:"offset_method"` // Newest, Oldest
	EventBufferSize           int      `toml:"event_buffer_size"`
	LogSarama                 bool     `toml:"log_sarama"`
}