sarama.go 783 B

1234567891011121314151617
  1. /*
  2. Package sarama provides client libraries for the Kafka 0.8 protocol. The Client, Producer and Consumer objects are the core of the high-level API. The Broker and Request/Response objects permit more precise control.
  3. The Request/Response objects and properties are mostly undocumented, as they line up exactly with the
  4. protocol fields documented by Kafka at https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol
  5. */
  6. package sarama
  7. import (
  8. "io/ioutil"
  9. "log"
  10. )
  11. // Logger is the instance of golang's log.Logger that Sarama writes connection
  12. // management events to. By default it is set to discard all log messages via ioutil.Discard,
  13. // but you can set it to redirect wherever you want.
  14. var Logger = log.New(ioutil.Discard, "[Sarama] ", log.LstdFlags)