Module: Karafka::Pro::Routing::Features::Multiplexing::Patches::Contracts::ConsumerGroup

Defined in:
lib/karafka/pro/routing/features/multiplexing/patches/contracts/consumer_group.rb

Overview

Consumer group contract patches

Instance Method Summary collapse

Instance Method Details

#topic_unique_key(topic) ⇒ Array

Redefines the setup allowing for multiple sgs as long as with different names

Parameters:

  • topic (Hash) —

    topic config hash

Returns:

  • (Array) —

    topic unique key for validators



21
22
23
24
25
26
 
# File 'lib/karafka/pro/routing/features/multiplexing/patches/contracts/consumer_group.rb', line 21

def topic_unique_key(topic)
  [
    topic[:name],
    topic[:subscription_group_details]
  ]
end