spec_helper.rb in rdkafka-0.15.0

- old
+ new

@@ -9,10 +9,11 @@
 
 require "pry"
 require "rspec"
 require "rdkafka"
 require "timeout"
+require "securerandom"
 
 def rdkafka_base_config
   {
     :"api.version.request" => false,
     :"broker.version.fallback" => "1.0",
@@ -33,11 +34,11 @@
   # Generate the base config
   config = rdkafka_base_config
   # Add consumer specific fields to it
   config[:"auto.offset.reset"] = "earliest"
   config[:"enable.partition.eof"] = false
-  config[:"group.id"] = "ruby-test-#{Random.new.rand(0..1_000_000)}"
+  config[:"group.id"] = "ruby-test-#{SecureRandom.uuid}"
   # Enable debug mode if required
   if ENV["DEBUG_CONSUMER"]
     config[:debug] = "cgrp,topic,fetch"
   end
   # Merge overrides
@@ -132,9 +133,10 @@
         load_test_topic:         3,
         produce_test_topic:      3,
         rake_test_topic:         3,
         watermarks_test_topic:   3,
         partitioner_test_topic: 25,
+        example_topic:           1
     }.each do |topic, partitions|
       create_topic_handle = admin.create_topic(topic.to_s, partitions, 1)
       begin
         create_topic_handle.wait(max_wait_timeout: 15)
       rescue Rdkafka::RdkafkaError => ex