Skip to content

Commit

Permalink
consume,topic: log sarama output to stderr.
Browse files Browse the repository at this point in the history
  • Loading branch information
fgeller committed Jun 8, 2016
1 parent 4ac93a6 commit fbf140c
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
2 changes: 1 addition & 1 deletion consume.go
Original file line number Diff line number Diff line change
Expand Up @@ -323,7 +323,7 @@ func consumeCommand() command {
parseArgs: consumeParseArgs,
run: func(closer chan struct{}) {
if config.consume.verbose {
sarama.Logger = log.New(os.Stdout, "", log.LstdFlags)
sarama.Logger = log.New(os.Stderr, "", log.LstdFlags)
}
consumer, err := sarama.NewConsumer(config.consume.brokers, nil)
if err != nil {
Expand Down
2 changes: 1 addition & 1 deletion topic.go
Original file line number Diff line number Diff line change
Expand Up @@ -106,7 +106,7 @@ func topicParseArgs() {
func topicRun(closer chan struct{}) {
var err error
if config.topic.verbose {
sarama.Logger = log.New(os.Stdout, "", log.LstdFlags)
sarama.Logger = log.New(os.Stderr, "", log.LstdFlags)
}

client, err := sarama.NewClient(config.topic.brokers, nil)
Expand Down

0 comments on commit fbf140c

Please sign in to comment.