Sha256: 6a78bc2909c831e7fa1a165cef828832a3c92efe350ea1145fe01a6215db80a9

Contents?: true

Size: 135 Bytes

Versions: 5

Compression:

Stored size: 135 Bytes

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