Versions in this module Expand all Collapse all v0 v0.1.8 May 10, 2024 v0.1.7 May 6, 2024 v0.1.6 Jan 9, 2024 v0.1.5 Sep 21, 2023 Changes in this version + var SHA256 scram.HashGeneratorFcn = sha256.New + var SHA512 scram.HashGeneratorFcn = sha512.New + type Acl struct + type AdminClient struct + func InitKafka(addrs []string, offsetOldest, isSync, randomPart bool, retryMax int) (*AdminClient, error) + func InitKafkaPlain(addrs []string, username, password string, ...) (*AdminClient, error) + func InitKafkaScram(addrs []string, username, password string, ...) (*AdminClient, error) + func (c *AdminClient) ACLCreate(resource Resource, acls []Acl) error + func (c *AdminClient) ACLDelete(acl string) ([]MatchingAcl, error) + func (c *AdminClient) ACLList() (map[string]TopicDetail, error) + func (c *AdminClient) GroupDelete(group string) error + func (c *AdminClient) GroupDescribe(groups []string) ([]*GroupDescription, error) + func (c *AdminClient) GroupList() (map[string]string, error) + func (c *AdminClient) GroupOffsetDelete(group string, topic string, partition int32) error + func (c *AdminClient) GroupOffsetsList(group string, topicPartitions map[string][]int32) (*OffsetFetchResponse, error) + func (c *AdminClient) GroupRemoveMember(groupId string, groupInstanceIds []string) (*LeaveGroupResponse, error) + func (c *AdminClient) PartitionCreate(topic string, count int32, assignment [][]int32) error + func (c *AdminClient) PartitionReassignAlter(topic string, assignment [][]int32) error + func (c *AdminClient) PartitionReassignList(topics string, partitions []int32) (map[string]map[int32]*PartitionReplicaReassignmentsStatus, error) + func (c *AdminClient) TopicCreate(topic string, partitions int32, replicationFactor int16) error + func (c *AdminClient) TopicDelete(topic string) error + func (c *AdminClient) TopicList() (map[string]TopicDetail, error) + type ByteEncoder sarama.ByteEncoder + func (b ByteEncoder) Encode() ([]byte, error) + func (b ByteEncoder) Length() int + type ConsumerClient struct + Offset int64 + func InitConsumer(addrs []string, offsetOldest, isSync, randomPart bool, retryMax int) (*ConsumerClient, error) + func InitConsumerPlain(addrs []string, username, password string, ...) (*ConsumerClient, error) + func InitConsumerScram(addrs []string, username, password string, ...) (*ConsumerClient, error) + func (c *ConsumerClient) ConsumerMessage(topic string, partition int32) (value []byte, err error) + func (c *ConsumerClient) ConsumerMessages(topic string, fn func(message []byte) error) (err error) + type ConsumerGroup struct + Messages [][]byte + Size int + func (c *ConsumerGroup) Cleanup(session sarama.ConsumerGroupSession) error + func (c *ConsumerGroup) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error + func (c *ConsumerGroup) Setup(session sarama.ConsumerGroupSession) error + type ConsumerGroupClient struct + func InitConsumerGroup(addrs []string, groupID string, isSync, offsetOldest, randomPart bool, ...) (*ConsumerGroupClient, error) + func InitConsumerGroupPlain(addrs []string, groupID, username, password string, ...) (*ConsumerGroupClient, error) + func InitConsumerGroupScram(addrs []string, groupID, username, password string, ...) (*ConsumerGroupClient, error) + func (c *ConsumerGroupClient) ConsumerCustom(topics []string, handler ConsumerGroup) (err error) + func (c *ConsumerGroupClient) ConsumerMessage(topics []string) (value []byte, err error) + func (c *ConsumerGroupClient) ConsumerMessages(topics []string, msgSize int) (value [][]byte, err error) + type GroupDescription struct + type LeaveGroupResponse struct + type MatchingAcl struct + type Message struct + type OffsetFetchResponse struct + type PartitionReplicaReassignmentsStatus struct + type ProducerClient struct + func InitProducer(addrs []string, isSync, randomPart bool, retryMax int) (*ProducerClient, error) + func InitProducerPlain(addrs []string, username, password string, isSync, randomPart bool, ...) (*ProducerClient, error) + func InitProducerScram(addrs []string, username, password string, isSync, randomPart bool, ...) (*ProducerClient, error) + func (c *ProducerClient) ProducerCustom(msg Message) (partition int32, offset int64, err error) + func (c *ProducerClient) ProducerCustoms(msgs []Message) (err error) + func (c *ProducerClient) ProducerMessage(topic string, msg interface{}) (partition int32, offset int64, err error) + func (c *ProducerClient) ProducerMessages(topic string, msgs []interface{}) (err error) + type Resource struct + type StringEncoder sarama.StringEncoder + func (s StringEncoder) Encode() ([]byte, error) + func (s StringEncoder) Length() int + type TopicDetail struct + type XDGSCRAMClient struct + func (x *XDGSCRAMClient) Begin(userName, password, authzID string) (err error) + func (x *XDGSCRAMClient) Done() bool + func (x *XDGSCRAMClient) Step(challenge string) (response string, err error)