session

type Session interface {
	Info() string
	Connect(ctx context.Context) (sarama.Client, error)
	Disconnect()
	GetClient() sarama.Client
	GetAdminClient() sarama.ClusterAdmin
	IsAuthenticated() bool
}