Class: Kafka::PendingMessage

Inherits:
Struct
  • Object
show all
Defined in:
lib/kafka/pending_message.rb

Instance Attribute Summary collapse

Instance Attribute Details

#bytesize ⇒ Object

Returns the value of attribute bytesize

Returns:

  • (Object) —

    the current value of bytesize



2
3
4
 
# File 'lib/kafka/pending_message.rb', line 2

def bytesize
  @bytesize
end

#create_time ⇒ Object

Returns the value of attribute create_time

Returns:

  • (Object) —

    the current value of create_time



2
3
4
 
# File 'lib/kafka/pending_message.rb', line 2

def create_time
  @create_time
end

#key ⇒ Object

Returns the value of attribute key

Returns:

  • (Object) —

    the current value of key



2
3
4
 
# File 'lib/kafka/pending_message.rb', line 2

def key
  @key
end

#partition ⇒ Object

Returns the value of attribute partition

Returns:

  • (Object) —

    the current value of partition



2
3
4
 
# File 'lib/kafka/pending_message.rb', line 2

def partition
  @partition
end

#partition_key ⇒ Object

Returns the value of attribute partition_key

Returns:

  • (Object) —

    the current value of partition_key



2
3
4
 
# File 'lib/kafka/pending_message.rb', line 2

def partition_key
  @partition_key
end

#topic ⇒ Object

Returns the value of attribute topic

Returns:

  • (Object) —

    the current value of topic



2
3
4
 
# File 'lib/kafka/pending_message.rb', line 2

def topic
  @topic
end

#value ⇒ Object

Returns the value of attribute value

Returns:

  • (Object) —

    the current value of value



2
3
4
 
# File 'lib/kafka/pending_message.rb', line 2

def value
  @value
end