Class: VertxKafkaClient::KafkaConsumerRecord
- Inherits:
-
Object
- Object
- VertxKafkaClient::KafkaConsumerRecord
- 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)
-
- (Fixnum) checksum
The checksum (CRC32) of the record.
-
- (Array<::VertxKafkaClient::KafkaHeader>) headers
The list of consumer record headers.
-
- (Object) key
The key (or null if no key is specified).
-
- (Fixnum) offset
The position of this record in the corresponding Kafka partition.
-
- (Fixnum) partition
The partition from which this record is received.
-
- (Fixnum) timestamp
The timestamp of this record.
-
- (:NO_TIMESTAMP_TYPE, ...) timestampType
The timestamp type of this record.
-
- (String) topic
The topic this record is received from.
-
- (Object) value
The value.
Instance Method Details
- (Fixnum) checksum
Returns 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
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)
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.
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
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
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 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
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 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
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
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 |