kafka

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

type AssignedPartitions map[string]AssignedPartitionsList

type AssignedPartitionsList []int

type Config struct {
	Servers string `toml:"servers"` // Список kafka серверов

	User     string `toml:"user"`     // Пользователь
	Password string `toml:"password"` // Пароль

	Timeout config.Duration `toml:"timeout"` // Таймаут

	RetryTimeout config.Duration `toml:"retry-timeout"` // Таймаут повторной отправки

	MaxRequestSize int `toml:"max-request-size"` // Максимальный размер сообщения

	Group                    string                          `toml:"group"`                       // Группа для консьюмера
	AutoCommit               bool                            `toml:"auto-commit"`                 // Использовать auto commit для консьюмера?
	ConsumeInSeparateThreads bool                            `toml:"consume-in-separate-threads"` // Обрабатывать каждый топик в отдельном потоке
	ProducerTopics           map[string]*ProducerTopicConfig `toml:"producer-topics"`             // Список топиков продюсера с их параметрами map[virtualName]*config
	ConsumerTopics           map[string]*ConsumerTopicConfig `toml:"consumer-topics"`             // Список топиков консьюмера с их параметрами map[virtualName]*config

	Consumer *Consumer `toml:"-"`
	Producer *Producer `toml:"-"`
}

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

type ConsumerTopicConfig struct {
	Active   bool   `toml:"active"`   // Активный?
	Type     string `toml:"type"`     // Тип топика. Произвольное необязательное значение на усмотрение разработчика
	Encoding string `toml:"encoding"` // Формат данных

	Extra any `toml:"extra"` // Произвольные дополнительные данные
}

type Error kafka.Error

type Message kafka.Message

type Messages []Message

type Metadata kafka.Metadata

type Offset kafka.Offset

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

type ProducerTopicConfig struct {
	Active bool   `toml:"active"` // Активный?
	Type   string `toml:"type"`   // Тип топика. Произвольное необязательное значение на усмотрение разработчика

	NumPartitions     int             `toml:"num-partitions"`     // Количество партиций при создании
	ReplicationFactor int             `toml:"replication-factor"` // Фактор репликации при создании
	RetentionTime     config.Duration `toml:"retention-time"`     // Время жизни данных
	RetentionSize     int64           `toml:"retention-size"`     // Максимальный размер для очистки по размеру

	Extra any `toml:"extra"` // Произвольные дополнительные данные
}