tkafka

Jun 25, 2024

Changes in this version

+ func Consume[T any](ctx context.Context, cfg ReadConfig, ...) error

type Generate

+ func (g *Generate) DeleteGroups(ctx context.Context, groups ...string) (kadm.DeleteGroupResponses, error)

+ func (g *Generate) DeleteTopics(ctx context.Context, topics ...string) (kadm.DeleteTopicResponses, error)

+ type OptionTestClient func(*optionTestClient)

+ func WithConfig(cfg wkafka.Config) OptionTestClient

+ func WithContext(ctx context.Context) OptionTestClient

+ func WithWafkaOptions(opts ...wkafka.Option) OptionTestClient

+ type ReadConfig struct

+ KafkaConfig wkafka.Config

+ KafkaConsumer wkafka.ConsumerConfig

+ Name string

Nov 7, 2023

Changes in this version

+ var DefaultBrokerAddress = []string

+ func BrokerAddress() []string

+ func Config() wkafka.Config

+ func TestClient() (*wkafka.Client, error)

+ type Generate struct

+ Topics []string

+ func NewGenerate(c *wkafka.Client) *Generate

+ func (g *Generate) Cleanup() (kadm.DeleteTopicResponses, error)

+ func (g *Generate) CreateTopics(ctx context.Context, topics ...Topic) ([]kadm.CreateTopicResponse, error)

+ type Topic struct

+ Name string

+ Partitions int32

+ ReplicationFactor int16