kafeman

Documentation

Index

• Variables
• func Newkafeman(config config.Config) *kafeman
• type AddConfigRecordCommand
• type ConsumeCommand
• type CreateTopicCommand
• type Decoder
• type Encoder
• type GroupInfo
• type ProduceCommand
• type ReplicateCMD
• type SetConfigValueTopicCommand
• type UpdateTopicCommand

Variables

var ErrNoTopic = errors.New("No topic in cluster")

var ErrNoTopicProvided = errors.New("No topic provided")

Functions

func Newkafeman

func Newkafeman(
	config config.Config,
) *kafeman

Types

type AddConfigRecordCommand

type AddConfigRecordCommand struct {
	Topic, Key, Value string
}

type ConsumeCommand

type ConsumeCommand struct {
	Topic          string
	ConsumerGroup  string
	Partitions     []int32
	CommitMessages bool
	Offset         int64
	Follow         bool
	WithMeta       bool
	MessagesCount  int32
	FromTime       time.Time
	Decoder        Decoder
}

type CreateTopicCommand

type CreateTopicCommand struct {
	TopicName         string
	PartitionsCount   int32
	ReplicationFactor int16
	CleanupPolicy     string
}

type Decoder

type Decoder interface {
	Decode([]byte) ([]byte, error)
}

Encoder declare how to encode message

type Encoder

type Encoder interface {
	Encode([]byte) ([]byte, error)
}

Encoder declare how to encode message

type GroupInfo

type GroupInfo struct {
	Name      string
	State     string
	Consumers int
}

type ProduceCommand

type ProduceCommand struct {
	Topic       string
	Partition   int32
	Partitioner string
	BufferSize  int
	Input       io.Reader
	Output      io.Writer
	Encoder     Encoder
}

type ReplicateCMD

type ReplicateCMD struct {
	SourceTopic  string
	SourceBroker string
	DestTopic    string
	DestBroker   string

	Partition   int32
	Partitioner string

	Partitions     []int32
	CommitMessages bool
	Offset         int64
	Follow         bool
	WithMeta       bool
	MessagesCount  int32
	FromTime       time.Time
	ConsumerGroup  string
}

type SetConfigValueTopicCommand

type SetConfigValueTopicCommand struct {
	Topic  string
	Values map[string]string
}

type UpdateTopicCommand

type UpdateTopicCommand struct {
	Topic           string
	PartitionsCount int32
	// partiton -> offset
	Assignments [][]int32
}