Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

kafka

package

Go to main page

Versions in this module

v1

v1.3.0

Jul 14, 2023

v1.2.0

Mar 14, 2023

Changes in this version

+ var KErrorLogger = &errorLogger

+ var KLogger = &debugLogger

+ func GetKafkaDialer(options ...DialerOption) *kafka.Dialer

+ type DialerOption func(*kafka.Dialer)

+ func DialerWithCaCertTls(file string) DialerOption

+ func DialerWithUserAndPasswd(user, passwd string) DialerOption

type ReaderOption

+ func ReaderWithCommitInterval(commitInterval time.Duration) ReaderOption

+ func ReaderWithMaxBytes(maxBytes int) ReaderOption

+ func ReaderWithMinBytes(minBytes int) ReaderOption

type WriterOption

+ func WriterWithBatchBytes(batchBytes int) WriterOption

+ func WriterWithBatchSize(batchSize int) WriterOption

+ func WriterWithBatchTimeout(batchTimeout time.Duration) WriterOption

+ func WriterWithDialer(dialer *kafka.Dialer) WriterOption

+ func WriterWithLogger(debugLogger, errorLogger kafka.Logger) WriterOption

v1.1.0

Nov 29, 2022

Changes in this version

+ func NewGroupReader(brokers []string, topic, groupID string, options ...ReaderOption) (r *kafka.Reader, e error)

+ func NewPartitionReader(brokers []string, topic string, partition int, options ...ReaderOption) (r *kafka.Reader, e error)

+ func NewPartitionWriter(brokers []string, topic string, partition int, options ...WriterOption) (w *kafka.Writer, e error)

+ func NewWriter(brokers []string, topic string, options ...WriterOption) (w *kafka.Writer, e error)

+ func SetLog(l logger.Logger)

+ type PartitionBalancer struct

+ func (p *PartitionBalancer) Balance(_ kafka.Message, _ ...int) (partition int)

+ type ReaderOption func(*kafka.ReaderConfig)

+ func ReaderWithAsync() ReaderOption

+ func ReaderWithDialer(dialer *kafka.Dialer) ReaderOption

+ func ReaderWithOffset(offset int64) ReaderOption

+ type WriterOption func(*kafka.WriterConfig)

+ func WriterWithAsync() WriterOption

JackTT - Gopher 🇻🇳