func (c *Conn) CreateTopics(req *protocol.CreateTopicRequests) (*protocol.CreateTopicsResponse, error) {
	var resp protocol.CreateTopicsResponse
	err := c.writeOperation(func(deadline time.Time, id int32) error {
		return c.writeRequest(req)
	}, func(deadline time.Time, size int) error {
		return c.readResponse(&resp, size, req.Version())
	})
	if err != nil {
		return nil, err
	}
	return &resp, nil
}
CreateTopics sends a create topics request and returns the response.
package jocko
import (
	"bufio"
	"net"
	"runtime"
	"sync"
	"time"
	"github.com/travisjeffery/jocko/protocol"
)
type Conn struct {
	conn          net.Conn
	rlock         sync.Mutex
	rbuf          bufio.Reader
	rdeadline     connDeadline
	wlock         sync.Mutex
	wbuf          bufio.Writer
	wdeadline     connDeadline
	clientID      string
	correlationID int32
}
func NewConn(conn net.Conn, clientID string) (*Conn, error) {
	return &Conn{
		conn:     conn,
		clientID: clientID,
		rbuf:     *bufio.NewReader(conn),
		wbuf:     *bufio.NewWriter(conn),
	}, nil
}
func (c *Conn) LocalAddr() net.Addr { return c.conn.LocalAddr() }
func (c *Conn) RemoteAddr() net.Addr { return c.conn.RemoteAddr() }
func (c *Conn) SetDeadline(t time.Time) error {
	c.rdeadline.setDeadline(t)
	c.wdeadline.setDeadline(t)
	return nil
}
func (c *Conn) SetReadDeadline(t time.Time) error {
	c.rdeadline.setDeadline(t)
	return nil
}
func (c *Conn) SetWriteDeadline(t time.Time) error {
	c.wdeadline.setDeadline(t)
	return nil
}
func (c *Conn) Read(b []byte) (int, error) {
	return 0, nil
}
func (c *Conn) Write(b []byte) (int, error) {
	return 0, nil
}
func (c *Conn) Close() error { return c.conn.Close() }
func (c *Conn) LeaderAndISR(req *protocol.LeaderAndISRRequest) (*protocol.LeaderAndISRResponse, error) {
	var resp protocol.LeaderAndISRResponse
	err := c.writeOperation(func(deadline time.Time, id int32) error {
		return c.writeRequest(req)
	}, func(deadline time.Time, size int) error {
		return c.readResponse(&resp, size, req.Version())
	})
	if err != nil {
		return nil, err
	}
	return &resp, nil
}