producer

type Client interface {
	Topic() string
	Publish(ctx context.Context, value []byte, key []byte) error
	PublishWithoutKey(ctx context.Context, value []byte) error
	PublishWithEvent(ctx context.Context, value []byte, key []byte, event chan kafka.Event) error
	PublishRaw(ctx context.Context, msg *kafka.Message, event chan kafka.Event) error
	Close()
}

type Config struct {
	Topic            string                       `json:"topic"`
	BootstrapServers string                       `json:"bootstrap.servers"`
	SecurityProtocol string                       `json:"security.protocol"`
	SslCaLocation    string                       `json:"ssl.ca.location"`
	SaslMechanism    string                       `json:"sasl.mechanism"`
	SaslUsername     string                       `json:"sasl.username"`
	SaslPassword     string                       `json:"sasl.password"`
	ConfigMap        map[string]kafka.ConfigValue `json:"config.map"`
}

type EventHandlerFunc func(event kafka.Event)

type Option func(opts *Options)

type Options struct {
	Topic        string
	EventHandler EventHandlerFunc
	IsDebug      bool
}