kafka

type KafkaLibrary struct{}

type KafkaLibraryInterface interface {
	GetStateFull() *StateFullFormat
	SendEvent(topic string, payload *StateFullFormat) (*StateFullFormat, int64, error)
	InitConsumer(group string) (sarama.ConsumerGroup, error)
	InitNewConsumer() (sarama.Consumer, error)
}

type StateFullFormat struct {
	UUID      string                 `json:"__uuid" bson:"__uuid"`
	Action    string                 `json:"__action" bson:"__action"`
	Data      map[string]interface{} `json:"data" bson:"data"`
	CreatedAt *time.Time             `json:"created_at" bson:"created_at"`
}