args

Documentation

Index

• type Kafka
  • func (*Kafka) Descriptor() ([]byte, []int)
  • func (m *Kafka) GetCommitIntervalSeconds() int32
  • func (m *Kafka) GetConsumerGroupName() string
  • func (m *Kafka) GetMaxBytes() int32
  • func (m *Kafka) GetMaxWaitSeconds() int32
  • func (m *Kafka) GetMinBytes() int32
  • func (m *Kafka) GetReadOffset() int64
  • func (m *Kafka) GetRebalanceTimeoutSeconds() int32
  • func (m *Kafka) GetTopics() []string
  • func (m *Kafka) GetUseConsumerGroup() bool
  • func (*Kafka) ProtoMessage()
  • func (m *Kafka) Reset()
  • func (m *Kafka) String() string
  • func (m *Kafka) XXX_DiscardUnknown()
  • func (m *Kafka) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *Kafka) XXX_Merge(src proto.Message)
  • func (m *Kafka) XXX_Size() int
  • func (m *Kafka) XXX_Unmarshal(b []byte) error

Types

type Kafka

type Kafka struct {
	// Required
	Topics []string `protobuf:"bytes,1,rep,name=topics,proto3" json:"topics,omitempty"`
	// Optional; specify what offset the consumer should read from (only works if '--use-consumer-group' is false)
	ReadOffset int64 `protobuf:"varint,2,opt,name=read_offset,json=readOffset,proto3" json:"read_offset,omitempty"`
	// Optional: (default: true)
	UseConsumerGroup bool `protobuf:"varint,3,opt,name=use_consumer_group,json=useConsumerGroup,proto3" json:"use_consumer_group,omitempty"`
	// Optional; used only if "use_consumer_group" is true
	ConsumerGroupName string `protobuf:"bytes,4,opt,name=consumer_group_name,json=consumerGroupName,proto3" json:"consumer_group_name,omitempty"`
	// Optional; how long to wait for new data when reading batches of messages (default: 1s)
	MaxWaitSeconds int32 `protobuf:"varint,5,opt,name=max_wait_seconds,json=maxWaitSeconds,proto3" json:"max_wait_seconds,omitempty"`
	// Optional; minimum number of bytes to fetch in a single kafka request (throughput optimization)
	MinBytes int32 `protobuf:"varint,6,opt,name=min_bytes,json=minBytes,proto3" json:"min_bytes,omitempty"`
	// Optional; maximum number of bytes to fetch in a single kafka request (throughput optimization)
	MaxBytes int32 `protobuf:"varint,7,opt,name=max_bytes,json=maxBytes,proto3" json:"max_bytes,omitempty"`
	// Optional; how often to commit offsets to broker (default: 0 == synchronous)
	// NOTE: Used only-if "use_consumer_group" is true
	CommitIntervalSeconds int32 `` /* 127-byte string literal not displayed */
	// Optional; how long a coordinator will wait for member joins as part of a rebalance (default: 5s)
	RebalanceTimeoutSeconds int32    `` /* 133-byte string literal not displayed */
	XXX_NoUnkeyedLiteral    struct{} `json:"-"`
	XXX_unrecognized        []byte   `json:"-"`
	XXX_sizecache           int32    `json:"-"`
}

func (*Kafka) Descriptor

func (*Kafka) Descriptor() ([]byte, []int)

func (*Kafka) GetCommitIntervalSeconds

func (m *Kafka) GetCommitIntervalSeconds() int32

func (*Kafka) GetConsumerGroupName

func (m *Kafka) GetConsumerGroupName() string

func (*Kafka) GetMaxBytes

func (m *Kafka) GetMaxBytes() int32

func (*Kafka) GetMaxWaitSeconds

func (m *Kafka) GetMaxWaitSeconds() int32

func (*Kafka) GetMinBytes

func (m *Kafka) GetMinBytes() int32

func (*Kafka) GetReadOffset

func (m *Kafka) GetReadOffset() int64

func (*Kafka) GetRebalanceTimeoutSeconds

func (m *Kafka) GetRebalanceTimeoutSeconds() int32

func (*Kafka) GetTopics

func (m *Kafka) GetTopics() []string

func (*Kafka) GetUseConsumerGroup

func (m *Kafka) GetUseConsumerGroup() bool

func (*Kafka) ProtoMessage

func (*Kafka) ProtoMessage()

func (*Kafka) Reset

func (m *Kafka) Reset()

func (*Kafka) String

func (m *Kafka) String() string

func (*Kafka) XXX_DiscardUnknown

func (m *Kafka) XXX_DiscardUnknown()

func (*Kafka) XXX_Marshal

func (m *Kafka) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Kafka) XXX_Merge

func (m *Kafka) XXX_Merge(src proto.Message)

func (*Kafka) XXX_Size

func (m *Kafka) XXX_Size() int

func (*Kafka) XXX_Unmarshal

func (m *Kafka) XXX_Unmarshal(b []byte) error