Method: Kafka::PendingMessage#initialize

Defined in:
lib/kafka/pending_message.rb

#initialize(value:, key:, headers: {}, topic:, partition:, partition_key:, create_time:) ⇒ PendingMessage

Returns a new instance of PendingMessage.



7
8
9
10
11
12
13
14
15
16
 
# File 'lib/kafka/pending_message.rb', line 7

def initialize(value:, key:, headers: {}, topic:, partition:, partition_key:, create_time:)
  @value = value
  @key = key
  @headers = headers
  @topic = topic
  @partition = partition
  @partition_key = partition_key
  @create_time = create_time
  @bytesize = key.to_s.bytesize + value.to_s.bytesize
end