Class: VertxKafkaClient::KafkaConsumerRecords
- Inherits:
-
Object
- Object
- VertxKafkaClient::KafkaConsumerRecords
- Defined in:
- /Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-kafka-client/kafka_consumer_records.rb
Overview
Vert.x Kafka consumer records
Instance Method Summary (collapse)
-
- (true, false) isEmpty
Whether this batch contains any records.
-
- (::VertxKafkaClient::KafkaConsumerRecord) recordAt(index)
Get the record at the given index.
-
- (Fixnum) size
The total number of records in this batch.
Instance Method Details
- (true, false) isEmpty
Returns whether this batch contains any records
48 49 50 51 52 53 54 55 56 57 |
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-kafka-client/kafka_consumer_records.rb', line 48 def empty? if !block_given? return @j_del.java_method(:isEmpty, []).call() end if defined?(super) super else raise ArgumentError, "Invalid arguments when calling empty?()" end end |
- (::VertxKafkaClient::KafkaConsumerRecord) recordAt(index)
Get the record at the given index
36 37 38 39 40 41 42 43 44 45 |
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-kafka-client/kafka_consumer_records.rb', line 36 def record_at(*args) if args[0].class == Fixnum && !block_given? return ::Vertx::Util::Utils.safe_create(@j_del.java_method(:recordAt, [Java::int.java_class]).call(args[0]),::VertxKafkaClient::KafkaConsumerRecord, nil, nil) end if defined?(super) super else raise ArgumentError, "Invalid arguments when calling record_at(#{args[0]})" end end |
- (Fixnum) size
Returns the total number of records in this batch
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_records.rb', line 22 def size if !block_given? return @j_del.java_method(:size, []).call() end if defined?(super) super else raise ArgumentError, "Invalid arguments when calling size()" end end |