kafka

package

Go to main page

Versions in this module

v0

v0.1.0

Feb 19, 2024

Changes in this version

type Config

+ SASL SASL

+ type SASL struct

+ AuthIdentity string

+ Enable bool

+ Handshake bool

+ Mechanism sarama.SASLMechanism

+ Password string

+ SCRAMAuthzID string

+ User string

+ Version int16

v0.0.8

Feb 14, 2024

v0.0.7

Feb 14, 2024

v0.0.6

Apr 13, 2022

v0.0.5

Jan 20, 2022

v0.0.4

Jan 19, 2022

v0.0.3

Jan 19, 2022

Changes in this version

type Config

+ IsolationLevel string

v0.0.2

Dec 23, 2021

Changes in this version

type Message

+ HighWaterMarkOffset int64

v0.0.1

Dec 21, 2021

Changes in this version

+ var NoOpHandler = &noOpHandler

+ func NewProducer(ctx context.Context, conf Config, logger *log.Logger) (*kafkaProducer, error)

+ type AvroEncoder struct

+ Content []byte

+ SchemaID int

+ func (a *AvroEncoder) Encode() ([]byte, error)

+ func (a *AvroEncoder) Length() int

+ type CachedSchemaRegistryClient struct

+ SchemaRegistryClient *SchemaRegistryClient

+ func NewCachedSchemaRegistryClient(connect []string) *CachedSchemaRegistryClient

+ func NewCachedSchemaRegistryClientWithRetries(connect []string, retries int) *CachedSchemaRegistryClient

+ func (client *CachedSchemaRegistryClient) CreateSubject(subject string, codec *goavro.Codec) (int, error)

+ func (client *CachedSchemaRegistryClient) DeleteSubject(subject string) error

+ func (client *CachedSchemaRegistryClient) DeleteVersion(subject string, version int) error

+ func (client *CachedSchemaRegistryClient) GetLatestSchema(subject string) (*goavro.Codec, error)

+ func (client *CachedSchemaRegistryClient) GetSchema(id int) (*goavro.Codec, error)

+ func (client *CachedSchemaRegistryClient) GetSchemaByVersion(subject string, version int) (*goavro.Codec, error)

+ func (client *CachedSchemaRegistryClient) GetSubjects() ([]string, error)

+ func (client *CachedSchemaRegistryClient) GetVersions(subject string) ([]int, error)

+ func (client *CachedSchemaRegistryClient) IsSchemaRegistered(subject string, codec *goavro.Codec) (int, error)

+ type Config struct

+ Brokers string

+ CACerts string

+ ClientID string

+ CommitInterval time.Duration

+ FlushInterval time.Duration

+ Group string

+ InitOffsets string

+ RebalanceStrategy string

+ RebalanceTimeout time.Duration

+ SchemaRegistryServers string

+ TLSCert string

+ TLSEnabled bool

+ TLSKey string

+ Topics string

+ Verbose bool

+ Version string

+ func FromEnv() (Config, error)

+ func NewKafkaConfig() Config

+ type Consumer interface

+ Background func() (func(), chan error)

+ func NewConsumer(ctx context.Context, conf Config, handler Handler, logger *log.Logger) (Consumer, error)

+ type ConsumerMessage sarama.ConsumerMessage

+ type Error struct

+ ErrorCode int

+ Message string

+ func (e *Error) Error() string

+ type Handler interface

+ Handle func(*Message) error

+ type Message struct

+ Key string

+ Offset int64

+ Partition int32

+ SchemaId int

+ Topic string

+ Value string

+ type Producer interface

+ Background func() (func(), chan error)

+ Send func(ProducerMessage) error

+ type ProducerMessage struct

+ Key []byte

+ Topic string

+ Value []byte

+ type SchemaRegistryClient struct

+ SchemaRegistryConnect []string

+ func NewSchemaRegistryClient(connect []string) *SchemaRegistryClient

+ func NewSchemaRegistryClientWithRetries(connect []string, retries int) *SchemaRegistryClient

+ func (client *SchemaRegistryClient) CreateSubject(subject string, codec *goavro.Codec) (int, error)

+ func (client *SchemaRegistryClient) DeleteSubject(subject string) error

+ func (client *SchemaRegistryClient) DeleteVersion(subject string, version int) error

+ func (client *SchemaRegistryClient) GetLatestSchema(subject string) (*goavro.Codec, error)

+ func (client *SchemaRegistryClient) GetSchema(id int) (*goavro.Codec, error)

+ func (client *SchemaRegistryClient) GetSchemaByVersion(subject string, version int) (*goavro.Codec, error)

+ func (client *SchemaRegistryClient) GetSubjects() ([]string, error)

+ func (client *SchemaRegistryClient) GetVersions(subject string) ([]int, error)

+ func (client *SchemaRegistryClient) IsSchemaRegistered(subject string, codec *goavro.Codec) (int, error)

+ type SchemaRegistryClientInterface interface

+ CreateSubject func(string, *goavro.Codec) (int, error)

+ DeleteSubject func(string) error

+ DeleteVersion func(string, int) error

+ GetLatestSchema func(string) (*goavro.Codec, error)

+ GetSchema func(int) (*goavro.Codec, error)

+ GetSchemaByVersion func(string, int) (*goavro.Codec, error)

+ GetSubjects func() ([]string, error)

+ GetVersions func(string) ([]int, error)

+ IsSchemaRegistered func(string, *goavro.Codec) (int, error)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL