client

May 9, 2023

Changes in this version

+ type Compression = kafka.Compression

+ const CompressionGzip

+ const CompressionLz4

+ const CompressionNone

+ const CompressionSnappy

+ const CompressionZstd

type ProducerConfig

+ BatchSize int

+ BatchTimeout time.Duration

+ Compression Compression

Mar 20, 2023

Changes in this version

type Config

+ SSHConfig *SSHConfig

+ type SSHConfig struct

+ AcceptAnyHostKey bool

+ Host string

+ PrivateKey string

+ User string

Jan 24, 2023

Changes in this version

+ type KafkaLogger struct

+ IsErrorLogger bool

+ Logger logger

+ func (l *KafkaLogger) Printf(format string, args ...interface{})

Oct 20, 2022 GO-2023-1863

  GO-2023-1863: rudder-server is vulnerable to SQL injection in github.com/rudderlabs/rudder-server

Oct 19, 2022 GO-2023-1863

  GO-2023-1863: rudder-server is vulnerable to SQL injection in github.com/rudderlabs/rudder-server

Oct 19, 2022 GO-2023-1863

  GO-2023-1863: rudder-server is vulnerable to SQL injection in github.com/rudderlabs/rudder-server

Oct 19, 2022 GO-2023-1863

  GO-2023-1863: rudder-server is vulnerable to SQL injection in github.com/rudderlabs/rudder-server

Oct 14, 2022 GO-2023-1863

  GO-2023-1863: rudder-server is vulnerable to SQL injection in github.com/rudderlabs/rudder-server

Oct 12, 2022 GO-2023-1863

  GO-2023-1863: rudder-server is vulnerable to SQL injection in github.com/rudderlabs/rudder-server

Sep 23, 2022 GO-2023-1863

  GO-2023-1863: rudder-server is vulnerable to SQL injection in github.com/rudderlabs/rudder-server

Sep 15, 2022 GO-2023-1863

  GO-2023-1863: rudder-server is vulnerable to SQL injection in github.com/rudderlabs/rudder-server

Sep 12, 2022 GO-2023-1863

  GO-2023-1863: rudder-server is vulnerable to SQL injection in github.com/rudderlabs/rudder-server

Sep 8, 2022 GO-2023-1863

  GO-2023-1863: rudder-server is vulnerable to SQL injection in github.com/rudderlabs/rudder-server

Aug 25, 2022 GO-2023-1863

  GO-2023-1863: rudder-server is vulnerable to SQL injection in github.com/rudderlabs/rudder-server

Aug 5, 2022 GO-2023-1863

  GO-2023-1863: rudder-server is vulnerable to SQL injection in github.com/rudderlabs/rudder-server

Jul 14, 2022 GO-2023-1863

  GO-2023-1863: rudder-server is vulnerable to SQL injection in github.com/rudderlabs/rudder-server

Jul 6, 2022 GO-2023-1863

  GO-2023-1863: rudder-server is vulnerable to SQL injection in github.com/rudderlabs/rudder-server

Jun 16, 2022 GO-2023-1863

  GO-2023-1863: rudder-server is vulnerable to SQL injection in github.com/rudderlabs/rudder-server

Jun 14, 2022 GO-2023-1863

  GO-2023-1863: rudder-server is vulnerable to SQL injection in github.com/rudderlabs/rudder-server

Changes in this version

+ func IsProducerErrTemporary(err error) bool

+ type Client struct

+ func New(network string, addresses []string, conf Config) (*Client, error)

+ func NewAzureEventHubs(address, connectionString string, conf Config) (*Client, error)

+ func NewConfluentCloud(address, key, secret string, conf Config) (*Client, error)

+ func (c *Client) NewConsumer(topic string, conf ConsumerConfig) *Consumer

+ func (c *Client) NewProducer(topic string, producerConf ProducerConfig) (p *Producer, err error)

+ func (c *Client) Ping(ctx context.Context) error

+ type Config struct

+ ClientID string

+ DialTimeout time.Duration

+ SASL *SASL

+ TLS *TLS

+ type Consumer struct

+ func (c *Consumer) Close(ctx context.Context) error

+ func (c *Consumer) Receive(ctx context.Context) (Message, error)

+ type ConsumerConfig struct

+ CommitInterval time.Duration

+ ErrorLogger Logger

+ FetchBatchesMaxWait time.Duration

+ GroupID string

+ Logger Logger

+ Partition int

+ StartOffset ConsumerStartOffset

+ type ConsumerStartOffset int64

+ const FirstOffset

+ const LastOffset

+ type Logger interface

+ Printf func(format string, args ...interface{})

+ type Message struct

+ Headers []MessageHeader

+ Key []byte

+ Offset int64

+ Partition int32

+ Timestamp time.Time

+ Topic string

+ Value []byte

+ type MessageHeader struct

+ Key string

+ Value []byte

+ type Producer struct

+ func (p *Producer) Close(ctx context.Context) error

+ func (p *Producer) Publish(ctx context.Context, msgs ...Message) error

+ type ProducerConfig struct

+ ClientID string

+ ErrorLogger Logger

+ Logger Logger

+ ReadTimeout time.Duration

+ WriteTimeout time.Duration

+ type SASL struct

+ Password string

+ ScramHashGen ScramHashGenerator

+ Username string

+ type ScramHashGenerator uint8

+ const ScramPlainText

+ const ScramSHA256

+ const ScramSHA512

+ func ScramHashGeneratorFromString(s string) (ScramHashGenerator, error)

+ func (s ScramHashGenerator) String() string

+ type TLS struct

+ CACertificate []byte

+ Cert []byte

+ InsecureSkipVerify bool

+ Key []byte

+ WithSystemCertPool bool

Jun 24, 2022 GO-2023-1863

  GO-2023-1863: rudder-server is vulnerable to SQL injection in github.com/rudderlabs/rudder-server