Documentation
¶
Index ¶
- func New(setters ...Setter) producer.Producer
- type Producer
- type Setter
- func SetAddr(addr ...string) Setter
- func SetAllowAutoTopicCreation(allowAutoTopicCreation bool) Setter
- func SetBalancer(balancer kafka.Balancer) Setter
- func SetBatchBytes(batchBytes int64) Setter
- func SetBatchSize(batchSize int) Setter
- func SetBatchTimeout(batchTimeout time.Duration) Setter
- func SetCompletion(completion func(messages []kafka.Message, err error)) Setter
- func SetCompression(compression kafka.Compression) Setter
- func SetLogger(logger logger.LogWriter) Setter
- func SetMaxAttempts(maxAttempts int) Setter
- func SetMsgType(msgType message.MsgType) Setter
- func SetReadTimeout(readTimeout time.Duration) Setter
- func SetRequiredAcks(requiredAcks kafka.RequiredAcks) Setter
- func SetTopicList(topic ...string) Setter
- func SetTransport(transport kafka.RoundTripper) Setter
- func SetWriteBackoffMax(writeBackoffMax time.Duration) Setter
- func SetWriteBackoffMin(writeBackoffMin time.Duration) Setter
- func SetWriteTimeout(writeTimeout time.Duration) Setter
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Producer ¶
type Producer struct {
// contains filtered or unexported fields
}
func (*Producer) AsyncSendMsg ¶
type Setter ¶
type Setter func(p *Producer)
func SetBalancer ¶
func SetBalancer(balancer kafka.Balancer) Setter
func SetBatchBytes ¶
func SetBatchSize ¶
func SetBatchTimeout ¶
func SetCompletion ¶
func SetCompression ¶
func SetCompression(compression kafka.Compression) Setter
func SetMaxAttempts ¶
func SetMsgType ¶
func SetReadTimeout ¶
func SetRequiredAcks ¶
func SetRequiredAcks(requiredAcks kafka.RequiredAcks) Setter
func SetTopicList ¶
func SetTransport ¶
func SetTransport(transport kafka.RoundTripper) Setter
func SetWriteBackoffMax ¶
func SetWriteBackoffMin ¶
func SetWriteTimeout ¶
Source Files
Click to show internal directories.
Click to hide internal directories.