kafkaWriter

Documentation

Index

• Constants
• func WriteMessages(w *kafka.Writer, ctx context.Context, msgs ...kafka.Message) error
• func WriteMessagesT(w *kafka.Writer, ctx context.Context, msgs ...kafka.Message) error
• type KafkaWriter
  • func (h *KafkaWriter) Hook()
  • func (h *KafkaWriter) UnHook()

Constants

const (
	TraceId = iota
	AgentId
	RoutineId
	NextKey
	OnlyKey
)

Functions

func WriteMessages

func WriteMessages(w *kafka.Writer, ctx context.Context, msgs ...kafka.Message) error

func WriteMessagesT

func WriteMessagesT(w *kafka.Writer, ctx context.Context, msgs ...kafka.Message) error

Types

type KafkaWriter

type KafkaWriter struct {
}

func (*KafkaWriter) Hook

func (h *KafkaWriter) Hook()

func (*KafkaWriter) UnHook

func (h *KafkaWriter) UnHook()