kafka

Documentation

Index

• type ServerConfig
• type ServerControl
  • func Run(config *ServerConfig, impl service.KfkServer) (*ServerControl, error)
  • func (s *ServerControl) DisConnect(addr net.Addr) error

Types

type ServerConfig

type ServerConfig struct {
	// 网络配置
	ListenAddr string
	MultiCore  bool
	NeedSasl   bool
	MaxConn    int32

	// Kafka协议配置
	ClusterId     string
	AdvertiseHost string
	AdvertisePort int
}

type ServerControl

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

func Run

func Run(config *ServerConfig, impl service.KfkServer) (*ServerControl, error)

func (*ServerControl) DisConnect

func (s *ServerControl) DisConnect(addr net.Addr) error