rubocop

bruce-szalwinski-he · May 5, 2024 · 6244d01 · 6244d01
1 parent 3fba4bb
commit 6244d01
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 7 deletions.
diff --git a/examples/waterdrop/Gemfile b/examples/waterdrop/Gemfile
@@ -2,5 +2,5 @@ source "https://rubygems.org"
 
 gem "aws-msk-iam-sasl-signer"
 gem "base64"
-gem 'waterdrop'
 gem "rexml", "~> 3.2"
+gem "waterdrop"
diff --git a/examples/waterdrop/oauth_token_refresher.rb b/examples/waterdrop/oauth_token_refresher.rb
@@ -10,7 +10,7 @@ def on_oauthbearer_token_refresh(event)
     event[:bearer].oauthbearer_set_token(
       token: token.token,
       lifetime_ms: token.expiration_time_ms,
-      principal_name: 'kafka-cluster'
+      principal_name: "kafka-cluster"
     )
   end
 end
diff --git a/examples/waterdrop/producer.rb b/examples/waterdrop/producer.rb
@@ -1,22 +1,20 @@
 # frozen_string_literal: true
 
 require_relative "oauth_token_refresher"
-require 'waterdrop'
+require "waterdrop"
 
 module Producer
-
   def self.start!(kafka_config)
     @producer = WaterDrop::Producer.new do |config|
       config.deliver = true
       config.kafka = kafka_config
       # can either configure the listener or subscribe to the event
-      #config.oauth.token_provider_listener = OAuthTokenRefresher.new
+      # config.oauth.token_provider_listener = OAuthTokenRefresher.new
     end
 
-    @producer.monitor.subscribe('oauthbearer.token_refresh') do |event|
+    @producer.monitor.subscribe("oauthbearer.token_refresh") do |event|
       OAuthTokenRefresher.new.on_oauthbearer_token_refresh(event)
     end
-
   end
 
   def self.produce(**args)