kafka

type Consumer interface {
	Fetch(context.Context) (Message, error)
	Commit(context.Context, Message) error
	GroupMode() bool
	Close() error
}

type Manager interface {
	CreateTopic(topic string, partitions, replication int) error
	Close() error
}

type Message struct {
	Topic     string
	Partition int
	Offset    int64

	Key     []byte
	Value   []byte
	Headers []sarama.RecordHeader
}

type Producer interface {
	Write(Message) error
	Close() error
}

type XDGSCRAMClient struct {
	*scram.Client
	*scram.ClientConversation
	scram.HashGeneratorFcn
}