Contents

module GlassOctopus
  # Represents a message from a Kafka topic.
  Message = Struct.new(:topic, :partition, :offset, :key, :value)
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
glass_octopus-2.2.0	lib/glass_octopus/message.rb
glass_octopus-2.1.0	lib/glass_octopus/message.rb
glass_octopus-2.0.0	lib/glass_octopus/message.rb
glass_octopus-1.1.0	lib/glass_octopus/message.rb
glass_octopus-1.0.0	lib/glass_octopus/message.rb