skafka

type Dependencies struct {
	ClientID string
	Logger   slogger.Logger
}

type SConsumer interface {
	Fetch(ctx context.Context, topic string, offset int)
	Close() error
}

type SKafka struct {
	// contains filtered or unexported fields
}

type SProducer interface {
	Publish(ctx context.Context, topic string, key, value []byte) error
	Close() error
}