Function NewConn

protocol/conn.go:19–25

(conn net.Conn, clientID string)

}

func NewConn(conn net.Conn, clientID string) *Conn {
	return &Conn{
		buffer:   bufio.NewReader(conn),
		conn:     conn,
		clientID: clientID,
	}
}

func (c *Conn) String() string {
	return fmt.Sprintf("kafka://%s@%s->%s", c.clientID, c.LocalAddr(), c.RemoteAddr())