Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct { Brokers []string Topic string BalanceStrategy string MaxAttempts int WriteBackoffMin time.Duration WriteBackoffMax time.Duration BatchSize int BatchBytes int BatchTimeout time.Duration ReadTimeout time.Duration WriteTimeout time.Duration RequiredAcks int16 Async bool Compression string Logger *log.Logger ErrorLogger *log.Logger AllowAutoTopicCreation bool }
Click to show internal directories.
Click to hide internal directories.