Sha256: 94066c2ca705277e49333bf426ee5aecaa02a9377ed4f63ad9c21460f9f38784
Contents?: true
Size: 539 Bytes
Versions: 6
Compression:
Stored size: 539 Bytes
Contents
# frozen_string_literal: true
module Karafka
module Messages
# Simple batch metadata object that stores all non-message information received from Kafka
# cluster while fetching the data.
#
# @note This metadata object refers to per batch metadata, not `#message.metadata`
BatchMetadata = Struct.new(
:size,
:first_offset,
:last_offset,
:deserializer,
:partition,
:topic,
:scheduled_at,
:consumption_lag,
:processing_lag,
keyword_init: true
)
end
end
Version data entries
6 entries across 6 versions & 1 rubygems