From 7cb310c59c0735a181a3f4d2cfaf97f4633059cd Mon Sep 17 00:00:00 2001 From: Jack Wilsdon Date: Wed, 24 Apr 2024 17:42:20 +0100 Subject: [PATCH] Remove trailing newlines from log messages --- consumergroup.go | 4 ++-- reader.go | 6 +++--- 2 files changed, 5 insertions(+), 5 deletions(-) diff --git a/consumergroup.go b/consumergroup.go index b9d0a7e2e..88aee8921 100644 --- a/consumergroup.go +++ b/consumergroup.go @@ -467,7 +467,7 @@ func (g *Generation) heartbeatLoop(interval time.Duration) { l.Printf("started heartbeat for group, %v [%v]", g.GroupID, interval) }) defer g.log(func(l Logger) { - l.Printf("stopped heartbeat for group %s\n", g.GroupID) + l.Printf("stopped heartbeat for group %s", g.GroupID) }) ticker := time.NewTicker(interval) @@ -1009,7 +1009,7 @@ func (cg *ConsumerGroup) makeJoinGroupRequestV1(memberID string) (joinGroupReque // their various partitions. func (cg *ConsumerGroup) assignTopicPartitions(conn coordinator, group joinGroupResponseV1) (GroupMemberAssignments, error) { cg.withLogger(func(l Logger) { - l.Printf("selected as leader for group, %s\n", cg.config.ID) + l.Printf("selected as leader for group, %s", cg.config.ID) }) balancer, ok := findGroupBalancer(group.GroupProtocol, cg.config.GroupBalancers) diff --git a/reader.go b/reader.go index 04d90f355..b0c4df4cc 100644 --- a/reader.go +++ b/reader.go @@ -271,10 +271,10 @@ func (r *Reader) commitLoopInterval(ctx context.Context, gen *Generation) { // commitLoop processes commits off the commit chan. func (r *Reader) commitLoop(ctx context.Context, gen *Generation) { r.withLogger(func(l Logger) { - l.Printf("started commit for group %s\n", r.config.GroupID) + l.Printf("started commit for group %s", r.config.GroupID) }) defer r.withLogger(func(l Logger) { - l.Printf("stopped commit for group %s\n", r.config.GroupID) + l.Printf("stopped commit for group %s", r.config.GroupID) }) if r.useSyncCommits() { @@ -293,7 +293,7 @@ func (r *Reader) run(cg *ConsumerGroup) { defer cg.Close() r.withLogger(func(l Logger) { - l.Printf("entering loop for consumer group, %v\n", r.config.GroupID) + l.Printf("entering loop for consumer group, %v", r.config.GroupID) }) for {