Skip to content

Commit

Permalink
chore: remove println statements
Browse files Browse the repository at this point in the history
  • Loading branch information
alexec committed Oct 5, 2021
1 parent 5bbe50a commit 6da41fd
Show file tree
Hide file tree
Showing 4 changed files with 4 additions and 5 deletions.
3 changes: 2 additions & 1 deletion examples/main.go
Original file line number Diff line number Diff line change
Expand Up @@ -2,6 +2,7 @@ package main

import (
"fmt"
"log"
"os"
"path/filepath"
"strings"
Expand All @@ -22,7 +23,7 @@ func main() {
case "docs":
_, _ = fmt.Printf("### Examples\n\n")
for _, file := range files {
println(file.Name())
log.Println(file.Name())
for i, un := range file.Items {
if i == 0 {
annotations := un.GetAnnotations()
Expand Down
4 changes: 2 additions & 2 deletions runner/main.go
Original file line number Diff line number Diff line change
Expand Up @@ -100,10 +100,10 @@ func main() {
}
}()
if errors.Is(err, context.Canceled) {
println(fmt.Errorf("ignoring context cancelled error, expected"))
logger.Info("ignoring context cancelled error, expected")
} else if err != nil {
if err := ioutil.WriteFile("/dev/termination-log", []byte(err.Error()), 0o600); err != nil {
println(fmt.Sprintf("failed to write termination-log: %v", err))
logger.Info(fmt.Sprintf("failed to write termination-log: %v", err))
}
panic(err)
}
Expand Down
1 change: 0 additions & 1 deletion runner/sidecar/source/kafka/kafka.go
Original file line number Diff line number Diff line change
Expand Up @@ -223,7 +223,6 @@ func (s *kafkaSource) consumePartition(ctx context.Context, partition int32) {
}
offset := int64(msg.TopicPartition.Offset)
logger := logger.WithValues("offset", offset)
println("offset=", offset)
if err := s.processMessage(ctx, msg); err != nil {
if errors.Is(err, context.Canceled) {
logger.Info("failed to process message", "err", err.Error())
Expand Down
1 change: 0 additions & 1 deletion testapi/kafka.go
Original file line number Diff line number Diff line change
Expand Up @@ -69,7 +69,6 @@ func init() {
case *kafka.Stats:
// https://github.com/edenhill/librdkafka/wiki/Consumer-lag-monitoring
// https://github.com/confluentinc/confluent-kafka-go/blob/master/examples/stats_example/stats_example.go
println(ev.String())
stats := &KafkaStats{}
if err := json.Unmarshal([]byte(e.String()), stats); err != nil {
w.WriteHeader(500)
Expand Down

0 comments on commit 6da41fd

Please sign in to comment.