go fmt

consumer.go

@@ -2,7 +2,7 @@ package kafka
 
 type Consumer struct {
 	client *Client
-	topic string
+	topic  string
 }
 
 func NewConsumer(client *Client, topic string) *Consumer {

produce_request.go

@@ -2,16 +2,16 @@ package kafka
 
 type produceRequestPartitionBlock struct {
 	partition int32
-	msgSet *messageSet
+	msgSet    *messageSet
 }
 
 type produceRequestTopicBlock struct {
-	topic *string
+	topic      *string
 	partitions []produceRequestPartitionBlock
 }
 
 type produceRequest struct {
 	requiredAcks int16
-	timeout int32
-	topics []produceRequestTopicBlock
+	timeout      int32
+	topics       []produceRequestTopicBlock
 }

producer.go

@@ -2,7 +2,7 @@ package kafka
 
 type Producer struct {
 	client *Client
-	topic string
+	topic  string
 }
 
 func NewProducer(client *Client, topic string) *Producer {