Contents

# frozen_string_literal: true

module KafkaCommand
  class ConsumerGroupPartition
    attr_reader :lag, :topic_name, :offset, :partition_id, :group_id

    def initialize(lag:, topic_name:, offset:, group_id:, partition_id:)
      @group_id     = group_id
      @lag          = lag
      @topic_name   = topic_name
      @offset       = offset
      @partition_id = partition_id
    end

    def as_json(*)
      {
        lag: @lag,
        offset: @offset,
        partition_id: @partition_id
      }
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
kafka_command-0.0.3	app/models/kafka_command/consumer_group_partition.rb
kafka_command-0.0.2	app/models/kafka_command/consumer_group_partition.rb
kafka_command-0.0.1	app/models/kafka_command/consumer_group_partition.rb