Merge pull request #263 from malandrina/upgrade-rdkafka

Upgrade to rdkafka 0.10.0
zendesk · Sep 20, 2021 · 8a30dae · 8a30dae
2 parents 4cb0f33 + 410648c
commit 8a30dae
Show file tree

Hide file tree

Showing 4 changed files with 10 additions and 7 deletions.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -2,6 +2,8 @@
 
 ## Unreleased
 
+* Update librdkafka version from 1.4.0 to 1.5.0 by upgrading from rdkafka 0.8.0 to 0.10.0. ([#263](https://github.com/zendesk/racecar/pull/263))
+
 ## racecar v2.3.1
 
 * Handle `ERR_NOT_COORDINATOR` (#209)

diff --git a/Gemfile.lock b/Gemfile.lock
@@ -1,9 +1,9 @@
 PATH
   remote: .
   specs:
-    racecar (2.3.0)
+    racecar (2.3.1)
       king_konf (~> 1.0.0)
-      rdkafka (~> 0.8.0)
+      rdkafka (~> 0.10.0)
 
 GEM
   remote: https://rubygems.org/
@@ -18,18 +18,18 @@ GEM
     concurrent-ruby (1.1.7)
     diff-lcs (1.4.4)
     dogstatsd-ruby (4.8.2)
-    ffi (1.15.3)
+    ffi (1.15.4)
     i18n (1.8.5)
       concurrent-ruby (~> 1.0)
     king_konf (1.0.0)
     method_source (1.0.0)
-    mini_portile2 (2.6.1)
+    mini_portile2 (2.7.0)
     minitest (5.14.2)
     pry (0.13.1)
       coderay (~> 1.1)
       method_source (~> 1.0)
     rake (13.0.1)
-    rdkafka (0.8.1)
+    rdkafka (0.10.0)
       ffi (~> 1.9)
       mini_portile2 (~> 2.1)
       rake (>= 12.3)
@@ -66,4 +66,4 @@ DEPENDENCIES
   timecop
 
 BUNDLED WITH
-   2.1.4
+   2.2.15
diff --git a/racecar.gemspec b/racecar.gemspec
@@ -21,7 +21,7 @@ Gem::Specification.new do |spec|
   spec.require_paths = ["lib"]
 
   spec.add_runtime_dependency "king_konf", "~> 1.0.0"
-  spec.add_runtime_dependency "rdkafka",   "~> 0.8.0"
+  spec.add_runtime_dependency "rdkafka",   "~> 0.10.0"
 
   spec.add_development_dependency "bundler", [">= 1.13", "< 3"]
   spec.add_development_dependency "pry"

diff --git a/spec/integration/consumer_spec.rb b/spec/integration/consumer_spec.rb
@@ -73,6 +73,7 @@ def process(message)
 
     before do
       create_topic(topic: input_topic, partitions: topic_partitions)
+      create_topic(topic: output_topic, partitions: topic_partitions)
 
       consumer_class.subscribes_to(input_topic)
       consumer_class.output_topic = output_topic