Changed Message.Opaque to non-pointer interface{} (issue confluentinc#4)

Author: edenhill

kafka/handle.go

@@ -169,7 +169,7 @@ type cgoif interface{}
 // delivery report cgoif container
 type cgo_dr struct {
 	delivery_chan chan Event
-	opaque        *interface{}
+	opaque        interface{}
 }
 
 // cgo_put adds object cg to the handle's cgo map and returns a

kafka/message.go

@@ -92,7 +92,7 @@ type Message struct {
 	Key            []byte
 	Timestamp      time.Time
 	TimestampType  TimestampType
-	Opaque         *interface{}
+	Opaque         interface{}
 }
 
 // String returns a human readable representation of a Message.

kafka/producer.go

@@ -61,7 +61,7 @@ func (p *Producer) get_handle() *handle {
 // transmit queue, thus returning immediately.
 // The delivery report will be sent on the provided delivery_chan if specified,
 // or on the Producer object's Events channel if not.
-func (p *Producer) produce(msg *Message, msg_flags int, delivery_chan chan Event, opaque *interface{}) error {
+func (p *Producer) produce(msg *Message, msg_flags int, delivery_chan chan Event, opaque interface{}) error {
 	c_rkt := p.handle.get_rkt(*msg.TopicPartition.Topic)
 
 	var valp *byte = nil
@@ -115,7 +115,7 @@ func (p *Producer) produce(msg *Message, msg_flags int, delivery_chan chan Event
 	return nil
 }
 
-func (p *Producer) Produce(msg *Message, delivery_chan chan Event, opaque *interface{}) error {
+func (p *Producer) Produce(msg *Message, delivery_chan chan Event, opaque interface{}) error {
 	return p.produce(msg, 0, delivery_chan, opaque)
 }