Class: VertxKafkaClient::KafkaConsumerRecord

Inherits:
Object
  • Object
show all
Defined in:
/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-kafka-client/kafka_consumer_record.rb

Overview

Vert.x Kafka consumer record

Instance Method Summary (collapse)

Instance Method Details

- (Fixnum) checksum

Returns the checksum (CRC32) of the record.

Returns:

  • (Fixnum)
    the checksum (CRC32) of the record.


58
59
60
61
62
63
64
65
66
67
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-kafka-client/kafka_consumer_record.rb', line 58

def checksum
  if !block_given?
    return @j_del.java_method(:checksum, []).call()
  end
  if defined?(super)
    super
  else
    raise ArgumentError, "Invalid arguments when calling checksum()"
  end
end

- (Array<::VertxKafkaClient::KafkaHeader>) headers

Returns the list of consumer record headers

Returns:



22
23
24
25
26
27
28
29
30
31
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-kafka-client/kafka_consumer_record.rb', line 22

def headers
  if !block_given?
    return @j_del.java_method(:headers, []).call().to_a.map { |elt| ::Vertx::Util::Utils.safe_create(elt,::VertxKafkaClient::KafkaHeader) }
  end
  if defined?(super)
    super
  else
    raise ArgumentError, "Invalid arguments when calling headers()"
  end
end

- (Object) key

Returns the key (or null if no key is specified)

Returns:

  • (Object)
    the key (or null if no key is specified)


106
107
108
109
110
111
112
113
114
115
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-kafka-client/kafka_consumer_record.rb', line 106

def key
  if !block_given?
    return @j_arg_K.wrap(@j_del.java_method(:key, []).call())
  end
  if defined?(super)
    super
  else
    raise ArgumentError, "Invalid arguments when calling key()"
  end
end

- (Fixnum) offset

Returns the position of this record in the corresponding Kafka partition.

Returns:

  • (Fixnum)
    the position of this record in the corresponding Kafka partition.


46
47
48
49
50
51
52
53
54
55
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-kafka-client/kafka_consumer_record.rb', line 46

def offset
  if !block_given?
    return @j_del.java_method(:offset, []).call()
  end
  if defined?(super)
    super
  else
    raise ArgumentError, "Invalid arguments when calling offset()"
  end
end

- (Fixnum) partition

Returns the partition from which this record is received

Returns:

  • (Fixnum)
    the partition from which this record is received


34
35
36
37
38
39
40
41
42
43
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-kafka-client/kafka_consumer_record.rb', line 34

def partition
  if !block_given?
    return @j_del.java_method(:partition, []).call()
  end
  if defined?(super)
    super
  else
    raise ArgumentError, "Invalid arguments when calling partition()"
  end
end

- (Fixnum) timestamp

Returns the timestamp of this record

Returns:

  • (Fixnum)
    the timestamp of this record


118
119
120
121
122
123
124
125
126
127
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-kafka-client/kafka_consumer_record.rb', line 118

def timestamp
  if !block_given?
    return @j_del.java_method(:timestamp, []).call()
  end
  if defined?(super)
    super
  else
    raise ArgumentError, "Invalid arguments when calling timestamp()"
  end
end

- (:NO_TIMESTAMP_TYPE, ...) timestampType

Returns the timestamp type of this record

Returns:

  • (:NO_TIMESTAMP_TYPE, :CREATE_TIME, :LOG_APPEND_TIME)
    the timestamp type of this record


82
83
84
85
86
87
88
89
90
91
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-kafka-client/kafka_consumer_record.rb', line 82

def timestamp_type
  if !block_given?
    return @j_del.java_method(:timestampType, []).call().name.intern
  end
  if defined?(super)
    super
  else
    raise ArgumentError, "Invalid arguments when calling timestamp_type()"
  end
end

- (String) topic

Returns the topic this record is received from

Returns:

  • (String)
    the topic this record is received from


70
71
72
73
74
75
76
77
78
79
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-kafka-client/kafka_consumer_record.rb', line 70

def topic
  if !block_given?
    return @j_del.java_method(:topic, []).call()
  end
  if defined?(super)
    super
  else
    raise ArgumentError, "Invalid arguments when calling topic()"
  end
end

- (Object) value

Returns the value

Returns:

  • (Object)
    the value


94
95
96
97
98
99
100
101
102
103
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-kafka-client/kafka_consumer_record.rb', line 94

def value
  if !block_given?
    return @j_arg_V.wrap(@j_del.java_method(:value, []).call())
  end
  if defined?(super)
    super
  else
    raise ArgumentError, "Invalid arguments when calling value()"
  end
end