@@ -9,8 +9,8 @@ import (
// Broker represents a single Kafka broker connection. All operations on this object are entirely concurrency-safe.
type Broker struct {
- id int32
- addr string
+ id int32
+ addr string
correlationID int32
conn net.Conn
@@ -12,5 +12,5 @@ import (
)
var (
- Logger = log.New(ioutil.Discard, "[Sarama] ", log.LstdFlags)
+ Logger = log.New(ioutil.Discard, "[Sarama] ", log.LstdFlags) // Logger instance to write connection management events to.