Documentation
¶
Index ¶
- func Errorf(msg string, args ...interface{})
- func Infof(msg string, args ...interface{})
- type Consumer
- type Message
- type OptionConsumer
- func OptionConsumerAddr(addrs []string) OptionConsumer
- func OptionConsumerCommitInterval(dur time.Duration) OptionConsumer
- func OptionConsumerGroupID(groupID string) OptionConsumer
- func OptionConsumerQueueCapacity(cap int) OptionConsumer
- func OptionConsumerSync() OptionConsumer
- func OptionConsumerTopic(topic string) OptionConsumer
- type OptionProducer
- func OptionProducerAddr(addrs []string) OptionProducer
- func OptionProducerAsync() OptionProducer
- func OptionProducerBalancer(balance kafka.Balancer) OptionProducer
- func OptionProducerBatchSize(size int) OptionProducer
- func OptionProducerReadTimeout(dur time.Duration) OptionProducer
- func OptionProducerRequiredAcks(level kafka.RequiredAcks) OptionProducer
- func OptionProducerTopic(topic string) OptionProducer
- func OptionProducerWithErrorLog(logger kafka.LoggerFunc) OptionProducer
- func OptionProducerWriteTimeout(dur time.Duration) OptionProducer
- type Producer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Consumer ¶
type Consumer struct {
*kafka.Reader
}
func DisconveryConsumer ¶
func DisconveryConsumer(topic, groupID string, _opts ...OptionConsumer) (*Consumer, error)
func DisconveryConsumerAppExclusive ¶
func DisconveryConsumerAppExclusive(app, topic, groupID string, _opts ...OptionConsumer) (*Consumer, error)
type OptionConsumer ¶
type OptionConsumer func(*kafka.ReaderConfig)
func OptionConsumerAddr ¶
func OptionConsumerAddr(addrs []string) OptionConsumer
func OptionConsumerCommitInterval ¶
func OptionConsumerCommitInterval(dur time.Duration) OptionConsumer
func OptionConsumerGroupID ¶
func OptionConsumerGroupID(groupID string) OptionConsumer
func OptionConsumerQueueCapacity ¶
func OptionConsumerQueueCapacity(cap int) OptionConsumer
func OptionConsumerSync ¶
func OptionConsumerSync() OptionConsumer
func OptionConsumerTopic ¶
func OptionConsumerTopic(topic string) OptionConsumer
type OptionProducer ¶
type OptionProducer func(*kafka.Writer)
func OptionProducerAddr ¶
func OptionProducerAddr(addrs []string) OptionProducer
func OptionProducerAsync ¶
func OptionProducerAsync() OptionProducer
func OptionProducerBalancer ¶
func OptionProducerBalancer(balance kafka.Balancer) OptionProducer
func OptionProducerBatchSize ¶
func OptionProducerBatchSize(size int) OptionProducer
func OptionProducerReadTimeout ¶
func OptionProducerReadTimeout(dur time.Duration) OptionProducer
func OptionProducerRequiredAcks ¶
func OptionProducerRequiredAcks(level kafka.RequiredAcks) OptionProducer
func OptionProducerTopic ¶
func OptionProducerTopic(topic string) OptionProducer
func OptionProducerWithErrorLog ¶
func OptionProducerWithErrorLog(logger kafka.LoggerFunc) OptionProducer
func OptionProducerWriteTimeout ¶
func OptionProducerWriteTimeout(dur time.Duration) OptionProducer
type Producer ¶
type Producer struct {
*kafka.Writer
}
func DisconveryProducer ¶
func DisconveryProducer(topic string, _opts ...OptionProducer) (*Producer, error)
func DisconveryProducerAppExclusive ¶
func DisconveryProducerAppExclusive(app, topic string, _opts ...OptionProducer) (*Producer, error)
Source Files
Click to show internal directories.
Click to hide internal directories.