kafka

type KafkaLibrary struct{}

type KafkaLibraryInterface interface {
	GetStateFull() *StateFullFormat
	InitConsumer() (sarama.Consumer, error)
}

type StateFullFormat struct {
	Payload  *entity.LoggerRequest `json:"payload"`
	Function string                `json:"__function"`
}