kafka

Documentation

Index

• type KafkaProducer
  • func NewKafkaProducer(brokers []string, sConfig *sarama.Config) (*KafkaProducer, error)
  • func (m *KafkaProducer) Close(ctx context.Context) error
  • func (m *KafkaProducer) Write(ctx context.Context, topic string, e cloudevents.Event) error

Types

type KafkaProducer

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

func NewKafkaProducer

func NewKafkaProducer(brokers []string, sConfig *sarama.Config) (*KafkaProducer, error)

func (*KafkaProducer) Close

func (m *KafkaProducer) Close(ctx context.Context) error

func (*KafkaProducer) Write

func (m *KafkaProducer) Write(ctx context.Context, topic string, e cloudevents.Event) error