Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( SHA256 scram.HashGeneratorFcn = func() hash.Hash { return sha256.New() } SHA512 scram.HashGeneratorFcn = func() hash.Hash { return sha512.New() } )
Functions ¶
This section is empty.
Types ¶
type KafkaProducer ¶
type KafkaProducer struct {
// contains filtered or unexported fields
}
func InitKafka ¶ added in v0.0.2
func InitKafka(servers []string) KafkaProducer
func InitKafkaWithAuth ¶ added in v0.0.15
func InitKafkaWithAuth( servers []string, saslUser string, saslPassword string, saslMechanism string, ) KafkaProducer
📁 d:\idea project\udpgo\kafka\kafkaClient.go
func (*KafkaProducer) SendMesssage ¶
func (t *KafkaProducer) SendMesssage(content []byte, topic string, keyType string) (int32, int64, error)
send message and return partition,offset
type XDGSCRAMClient ¶ added in v0.0.15
type XDGSCRAMClient struct {
*scram.Client
*scram.ClientConversation
scram.HashGeneratorFcn
}
func (*XDGSCRAMClient) Begin ¶ added in v0.0.15
func (x *XDGSCRAMClient) Begin(userName, password, authzID string) (err error)
func (*XDGSCRAMClient) Done ¶ added in v0.0.15
func (x *XDGSCRAMClient) Done() bool
Source Files
Click to show internal directories.
Click to hide internal directories.