Documentation
¶
Index ¶
- Constants
- Variables
- func CloseConnection()
- func Connect()
- func ConnectTopic(TopicName, GroupID string) *kafka.Reader
- func Connect_err() error
- func CreateClient() error
- func FillSettings()
- func GetAddr() net.Addr
- func GetOffsetFromGroupID(TopicName, GroupID string) (int64, error)
- func GetWaitGroup_Connect() *sync.WaitGroup
- func LogInfo_Connected(err error)
- func SetWaitGroup_Connect(wg *sync.WaitGroup)
- func StartKafka()
- func Start_ctx(ctx *context.Context, WaitGroup *sync.WaitGroup) error
- func WaitStop()
- type SettingsINI
Constants ¶
const PackageName = "kafka_connect"
PackageName - имя текущего пакета, для логирования
Variables ¶
var Client *kafka.Client
Client - клиент для Kafka
var Conn *kafka.Conn
Conn - соединение к серверу nats
Functions ¶
func CloseConnection ¶
func CloseConnection()
CloseConnection - закрывает соединение с сервером Kafka
func ConnectTopic ¶
ConnectTopic - подключает кафку к нужному топику
func Connect_err ¶
func Connect_err() error
Connect_err - подключается к серверу Kafka и возвращает ошибку
func CreateClient ¶ added in v1.0.70
func CreateClient() error
CreateClient - создаёт клиент для Kafka
func FillSettings ¶
func FillSettings()
FillSettings загружает переменные окружения в структуру из файла или из переменных окружения
func GetOffsetFromGroupID ¶ added in v1.0.70
GetOffsetFromGroupID - получает оффсет группы для конкретного топика, партиция 0
func GetWaitGroup_Connect ¶ added in v1.0.235
GetWaitGroup_Connect - возвращает группу ожидания завершения всех частей программы
func LogInfo_Connected ¶ added in v1.0.58
func LogInfo_Connected(err error)
LogInfo_Connected - выводит сообщение в Лог, или паника при ошибке
func SetWaitGroup_Connect ¶ added in v1.0.235
SetWaitGroup_Connect - присваивает внешний WaitGroup
func StartKafka ¶
func StartKafka()
StartKafka - необходимые процедуры для подключения к серверу Kafka
Types ¶
type SettingsINI ¶
type SettingsINI struct {
KAFKA_HOST string
KAFKA_PORT string
KAFKA_LOGIN string
KAFKA_PASSWORD string
}
SettingsINI - структура для хранения всех нужных переменных окружения
var Settings SettingsINI
Settings хранит все нужные переменные окружения
Source Files