 Documentation
      ¶
      Documentation
      ¶
    
    
  
    
  
    Index ¶
Constants ¶
      View Source
      
  
const (
	AppName = "kafka"
)
    Variables ¶
This section is empty.
Functions ¶
Types ¶
type Kafka ¶
type Kafka struct {
	Brokers        []string       `toml:"brokers" json:"brokers" yaml:"brokers"  env:"BROKERS"`
	ScramAlgorithm ScramAlgorithm `toml:"scram_algorithm" json:"scram_algorithm" yaml:"scram_algorithm"  env:"SCRAM_ALGORITHM"`
	UserName       string         `toml:"username" json:"username" yaml:"username"  env:"USERNAME"`
	Password       string         `toml:"password" json:"password" yaml:"password"  env:"PASSWORD"`
	Debug          bool           `toml:"debug" json:"debug" yaml:"debug"  env:"DEBUG"`
	ioc.ObjectImpl
	// contains filtered or unexported fields
}
    func (*Kafka) ConsumerGroup ¶
type ScramAlgorithm ¶
type ScramAlgorithm string
const ( SHA256 ScramAlgorithm = "SHA256" SHA512 ScramAlgorithm = "SHA512" )
 Click to show internal directories. 
   Click to hide internal directories.