kafka

Documentation

Index

• type AuthenticationConfig
• type Config
• type ProduceMessageResult
• type Producer
  • func GetProducer(kafkaConfig Config) (*Producer, error)
  • func (p *Producer) Close()
  • func (p *Producer) ProduceSyncMessage(ctx context.Context, messageKey, messageValue string, ...) (ProduceMessageResult, error)

Types

type AuthenticationConfig

type AuthenticationConfig struct {
	Username string
	Password string
}

type Config

type Config struct {
	BrokerURLs      []string
	Topic           string
	Authentication  *AuthenticationConfig
	SSLVerification bool
}

type ProduceMessageResult

type ProduceMessageResult struct {
	Topic     string
	Partition string
	Offset    string
}

type Producer

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

func GetProducer

func GetProducer(kafkaConfig Config) (*Producer, error)

func (*Producer) Close

func (p *Producer) Close()

func (*Producer) ProduceSyncMessage

func (p *Producer) ProduceSyncMessage(ctx context.Context, messageKey, messageValue string, headers map[string]string) (ProduceMessageResult, error)