Sha256: 24e280d530bedc0bfa1e0b4604db6dbf95d7cb76dc85d95de1f757ad791c3ba8
Contents?: true
Size: 1.04 KB
Versions: 20
Compression:
Stored size: 1.04 KB
Contents
# frozen_string_literal: true
# This Karafka component is a Pro component.
# All of the commercial components are present in the lib/karafka/pro directory of this
# repository and their usage requires commercial license agreement.
#
# Karafka has also commercial-friendly license, commercial support and commercial components.
#
# By sending a pull request to the pro components, you are agreeing to transfer the copyright of
# your code to Maciej Mensfeld.
module Karafka
module Pro
module Contracts
# Contract for validating correct Pro components setup on a consumer group and topic levels
class ConsumerGroup < Base
virtual do |data, errors|
next unless errors.empty?
next unless data.key?(:topics)
fetched_errors = []
data.fetch(:topics).each do |topic|
ConsumerGroupTopic.new.call(topic).errors.each do |key, value|
fetched_errors << [[topic, key].flatten, value]
end
end
fetched_errors
end
end
end
end
end
Version data entries
20 entries across 20 versions & 1 rubygems