Consumer group: change logger level to warn (#14)

* Consumer group: change logger level to warn

For errors that are retried we don't need to log them as errors but rather as warnings, since there is nothing actionable about these exceptions.

* Update codeowners to backend-council

Update gem version

Author: Dhruv Paranjape

.github/CODEOWNERS

@@ -1,4 +1,4 @@
 # https://docs.github.com/en/github/creating-cloning-and-archiving-repositories/about-code-owners
 
 # PATH                                 OWNERS
-*                                      @catawiki/fintech-backend
+*                                      @catawiki/backend-council

lib/kafka/consumer_group.rb

@@ -47,12 +47,12 @@ def join
       join_group
       synchronize
     rescue NotCoordinatorForGroup
-      @logger.error "Failed to find coordinator for group `#{@group_id}`; retrying..."
+      @logger.warn "Failed to find coordinator for group `#{@group_id}`; retrying..."
       sleep 1
       @coordinator = nil
       retry
     rescue ConnectionError
-      @logger.error "Connection error while trying to join group `#{@group_id}`; retrying..."
+      @logger.warn "Connection error while trying to join group `#{@group_id}`; retrying..."
       sleep 1
       @cluster.mark_as_stale!
       @coordinator = nil
@@ -69,6 +69,7 @@ def leave
         coordinator.leave_group(group_id: @group_id, member_id: @member_id)
       end
     rescue ConnectionError
+      @logger.warn "Connection error while leaving group `#{@group_id}`"
     end
 
     def fetch_offsets
@@ -111,7 +112,7 @@ def heartbeat
       @logger.error "Error sending heartbeat: #{e}"
       raise HeartbeatError, e
     rescue NotCoordinatorForGroup
-      @logger.error "Failed to find coordinator for group `#{@group_id}`; retrying..."
+      @logger.warn "Failed to find coordinator for group `#{@group_id}`; retrying..."
       sleep 1
       @coordinator = nil
       retry
@@ -139,7 +140,7 @@ def join_group
 
       @logger.info "Joined group `#{@group_id}` with member id `#{@member_id}`"
     rescue UnknownMemberId
-      @logger.error "Failed to join group; resetting member id and retrying in 1s..."
+      @logger.warn "Failed to join group; resetting member id and retrying in 1s..."
 
       @member_id = ""
       sleep 1
@@ -184,7 +185,7 @@ def synchronize
     def coordinator
       @coordinator ||= @cluster.get_group_coordinator(group_id: @group_id)
     rescue GroupCoordinatorNotAvailable
-      @logger.error "Group coordinator not available for group `#{@group_id}`"
+      @logger.warn "Group coordinator not available for group `#{@group_id}`, retrying in 1s"
 
       sleep 1
 

lib/kafka/version.rb

@@ -1,5 +1,5 @@
 # frozen_string_literal: true
 
 module Kafka
-  VERSION = "0.6.16"
+  VERSION = "0.6.17"
 end