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 |