Contents

# frozen_string_literal: true

require "forwardable"

module Racecar
  class Message
    extend Forwardable

    def initialize(rdkafka_message)
      @rdkafka_message = rdkafka_message
    end

    def_delegators :@rdkafka_message, :topic, :partition, :offset, :key, :headers

    def value
      @rdkafka_message.payload
    end

    def create_time
      @rdkafka_message.timestamp
    end

    def ==(other)
      @rdkafka_message == other.instance_variable_get(:@rdkafka_message)
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
racecar-2.1.1	lib/racecar/message.rb
racecar-2.1.0	lib/racecar/message.rb