kafka

package

v1.2.0-arch32 Latest Latest Go to latest Published: Mar 4, 2025 License: AGPL-3.0 Imports: 8 Imported by: 0

Details

This section is empty.

View Source

var SHA256 scram.HashGeneratorFcn = sha256.New

View Source

var SHA512 scram.HashGeneratorFcn = sha512.New

func DiffPartitions(a []int32, b []int32) []int32

returns elements that are in a but not in b

func GetPartitions(client sarama.Client, topics []string) ([]int32, error)

type KafkaNet struct {
	// contains filtered or unexported fields
}

func ConfigNet(FlagSet *flag.FlagSet) *KafkaNet

func (k *KafkaNet) Configure(config *sarama.Config)

type XDGSCRAMClient struct {
	*scram.Client
	*scram.ClientConversation
	scram.HashGeneratorFcn
}

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)