diff --git a/lib/kafka/consumer.rb b/lib/kafka/consumer.rb
index cb5632e47..d78fece5e 100644
--- a/lib/kafka/consumer.rb
+++ b/lib/kafka/consumer.rb
@@ -79,7 +79,7 @@ def initialize(cluster:, logger:, instrumenter:, group:, fetcher:, offset_manage
       @current_offsets = Hash.new { |h, k| h[k] = {} }
 
       # Map storing subscribed topics with their configuration
-      @subscribed_topics = Concurrent::Map.new
+      @subscribed_topics = Hash.new
 
       # Set storing topics that matched topics in @subscribed_topics
       @matched_topics = Set.new