Class: VertxKafkaClient::KafkaAdminClient
- Inherits:
-
Object
- Object
- VertxKafkaClient::KafkaAdminClient
- Defined in:
- /Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-kafka-client/kafka_admin_client.rb
Overview
Vert.x Kafka Admin client implementation
Constant Summary
- @@j_api_type =
Object.new
Class Method Summary (collapse)
- + (Boolean) accept?(obj)
-
+ (::VertxKafkaClient::KafkaAdminClient) create(vertx, config)
Create a new KafkaAdminClient instance.
- + (Object) j_api_type
- + (Object) j_class
- + (Object) unwrap(obj)
- + (Object) wrap(obj)
Instance Method Summary (collapse)
-
- (void) createTopics(topics, completionHandler) { ... }
Creates a batch of new Kafka topics.
-
- (void) deleteTopics(topicNames, completionHandler) { ... }
Deletes a batch of Kafka topics.
-
- (void) describeConsumerGroups(groupIds, completionHandler) { ... }
Describe some group ids in the cluster, with the default options.
-
- (void) describeTopics(topicNames, completionHandler) { ... }
Describe some topics in the cluster, with the default options.
-
- (void) listConsumerGroups(completionHandler) { ... }
Get the the consumer groups available in the cluster with the default options.
-
- (void) listTopics(completionHandler) { ... }
List the topics available in the cluster with the default options.
Class Method Details
+ (Boolean) accept?(obj)
20 21 22 |
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-kafka-client/kafka_admin_client.rb', line 20 def @@j_api_type.accept?(obj) obj.class == KafkaAdminClient end |
+ (::VertxKafkaClient::KafkaAdminClient) create(vertx, config)
Create a new KafkaAdminClient instance
102 103 104 105 106 107 108 109 110 111 |
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-kafka-client/kafka_admin_client.rb', line 102 def self.create(*args) if args[0].class.method_defined?(:j_del) && args[1].class == Hash && !block_given? return ::Vertx::Util::Utils.safe_create(Java::IoVertxKafkaAdmin::KafkaAdminClient.java_method(:create, [Java::IoVertxCore::Vertx.java_class,Java::JavaUtil::Map.java_class]).call(args[0].j_del,Hash[args[1].map { |k,v| [k,v] }]),::VertxKafkaClient::KafkaAdminClient) end if defined?(super) super else raise ArgumentError, "Invalid arguments when calling create(#{args[0]},#{args[1]})" end end |
+ (Object) j_api_type
29 30 31 |
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-kafka-client/kafka_admin_client.rb', line 29 def self.j_api_type @@j_api_type end |
+ (Object) j_class
32 33 34 |
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-kafka-client/kafka_admin_client.rb', line 32 def self.j_class Java::IoVertxKafkaAdmin::KafkaAdminClient.java_class end |
+ (Object) unwrap(obj)
26 27 28 |
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-kafka-client/kafka_admin_client.rb', line 26 def @@j_api_type.unwrap(obj) obj.j_del end |
+ (Object) wrap(obj)
23 24 25 |
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-kafka-client/kafka_admin_client.rb', line 23 def @@j_api_type.wrap(obj) KafkaAdminClient.new(obj) end |
Instance Method Details
- (void) createTopics(topics, completionHandler) { ... }
This method returns an undefined value.
Creates a batch of new Kafka topics
60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 |
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-kafka-client/kafka_admin_client.rb', line 60 def create_topics(*args) if args[0].class == Array && true if (block_given?) return @j_del.java_method(:createTopics, [Java::JavaUtil::List.java_class,Java::IoVertxCore::Handler.java_class]).call(args[0].map { |element| Java::IoVertxKafkaAdmin::NewTopic.new(::Vertx::Util::Utils.to_json_object(element)) },block_given? ? Proc.new { |ar| yield(ar.failed ? ar.cause : nil, ar.succeeded ? nil : nil) } : promise) else promise = ::Vertx::Util::Utils.promise @j_del.java_method(:createTopics, [Java::JavaUtil::List.java_class,Java::IoVertxCore::Handler.java_class]).call(args[0].map { |element| Java::IoVertxKafkaAdmin::NewTopic.new(::Vertx::Util::Utils.to_json_object(element)) },block_given? ? Proc.new { |ar| yield(ar.failed ? ar.cause : nil, ar.succeeded ? nil : nil) } : promise) return ::Vertx::Util::Utils.safe_create(promise.future(),::Vertx::Future, nil) end end if defined?(super) super else raise ArgumentError, "Invalid arguments when calling create_topics(#{args[0]})" end end |
- (void) deleteTopics(topicNames, completionHandler) { ... }
This method returns an undefined value.
Deletes a batch of Kafka topics
158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 |
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-kafka-client/kafka_admin_client.rb', line 158 def delete_topics(*args) if args[0].class == Array && true if (block_given?) return @j_del.java_method(:deleteTopics, [Java::JavaUtil::List.java_class,Java::IoVertxCore::Handler.java_class]).call(args[0].map { |element| element },block_given? ? Proc.new { |ar| yield(ar.failed ? ar.cause : nil, ar.succeeded ? nil : nil) } : promise) else promise = ::Vertx::Util::Utils.promise @j_del.java_method(:deleteTopics, [Java::JavaUtil::List.java_class,Java::IoVertxCore::Handler.java_class]).call(args[0].map { |element| element },block_given? ? Proc.new { |ar| yield(ar.failed ? ar.cause : nil, ar.succeeded ? nil : nil) } : promise) return ::Vertx::Util::Utils.safe_create(promise.future(),::Vertx::Future, nil) end end if defined?(super) super else raise ArgumentError, "Invalid arguments when calling delete_topics(#{args[0]})" end end |
- (void) describeConsumerGroups(groupIds, completionHandler) { ... }
This method returns an undefined value.
Describe some group ids in the cluster, with the default options
117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 |
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-kafka-client/kafka_admin_client.rb', line 117 def describe_consumer_groups(*args) if args[0].class == Array && true if (block_given?) return @j_del.java_method(:describeConsumerGroups, [Java::JavaUtil::List.java_class,Java::IoVertxCore::Handler.java_class]).call(args[0].map { |element| element },block_given? ? Proc.new { |ar| yield(ar.failed ? ar.cause : nil, ar.succeeded ? Java::IoVertxLangRuby::Helper.adaptingMap(ar.result, Proc.new { |val| val != nil ? JSON.parse(val.toJson.encode) : nil }, Proc.new { |val| ::Vertx::Util::Utils.to_object(val) }) : nil) } : promise) else promise = ::Vertx::Util::Utils.promise @j_del.java_method(:describeConsumerGroups, [Java::JavaUtil::List.java_class,Java::IoVertxCore::Handler.java_class]).call(args[0].map { |element| element },block_given? ? Proc.new { |ar| yield(ar.failed ? ar.cause : nil, ar.succeeded ? Java::IoVertxLangRuby::Helper.adaptingMap(ar.result, Proc.new { |val| val != nil ? JSON.parse(val.toJson.encode) : nil }, Proc.new { |val| ::Vertx::Util::Utils.to_object(val) }) : nil) } : promise) return ::Vertx::Util::Utils.safe_create(promise.future(),::Vertx::Future, nil) end end if defined?(super) super else raise ArgumentError, "Invalid arguments when calling describe_consumer_groups(#{args[0]})" end end |
- (void) describeTopics(topicNames, completionHandler) { ... }
This method returns an undefined value.
Describe some topics in the cluster, with the default options.
81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 |
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-kafka-client/kafka_admin_client.rb', line 81 def describe_topics(*args) if args[0].class == Array && true if (block_given?) return @j_del.java_method(:describeTopics, [Java::JavaUtil::List.java_class,Java::IoVertxCore::Handler.java_class]).call(args[0].map { |element| element },block_given? ? Proc.new { |ar| yield(ar.failed ? ar.cause : nil, ar.succeeded ? Java::IoVertxLangRuby::Helper.adaptingMap(ar.result, Proc.new { |val| val != nil ? JSON.parse(val.toJson.encode) : nil }, Proc.new { |val| ::Vertx::Util::Utils.to_object(val) }) : nil) } : promise) else promise = ::Vertx::Util::Utils.promise @j_del.java_method(:describeTopics, [Java::JavaUtil::List.java_class,Java::IoVertxCore::Handler.java_class]).call(args[0].map { |element| element },block_given? ? Proc.new { |ar| yield(ar.failed ? ar.cause : nil, ar.succeeded ? Java::IoVertxLangRuby::Helper.adaptingMap(ar.result, Proc.new { |val| val != nil ? JSON.parse(val.toJson.encode) : nil }, Proc.new { |val| ::Vertx::Util::Utils.to_object(val) }) : nil) } : promise) return ::Vertx::Util::Utils.safe_create(promise.future(),::Vertx::Future, nil) end end if defined?(super) super else raise ArgumentError, "Invalid arguments when calling describe_topics(#{args[0]})" end end |
- (void) listConsumerGroups(completionHandler) { ... }
This method returns an undefined value.
Get the the consumer groups available in the cluster with the default options
39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 |
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-kafka-client/kafka_admin_client.rb', line 39 def list_consumer_groups if true if (block_given?) return @j_del.java_method(:listConsumerGroups, [Java::IoVertxCore::Handler.java_class]).call(block_given? ? Proc.new { |ar| yield(ar.failed ? ar.cause : nil, ar.succeeded ? ar.result.to_a.map { |elt| elt != nil ? JSON.parse(elt.toJson.encode) : nil } : nil) } : promise) else promise = ::Vertx::Util::Utils.promise @j_del.java_method(:listConsumerGroups, [Java::IoVertxCore::Handler.java_class]).call(block_given? ? Proc.new { |ar| yield(ar.failed ? ar.cause : nil, ar.succeeded ? ar.result.to_a.map { |elt| elt != nil ? JSON.parse(elt.toJson.encode) : nil } : nil) } : promise) return ::Vertx::Util::Utils.safe_create(promise.future(),::Vertx::Future, nil) end end if defined?(super) super else raise ArgumentError, "Invalid arguments when calling list_consumer_groups()" end end |
- (void) listTopics(completionHandler) { ... }
This method returns an undefined value.
List the topics available in the cluster with the default options.
137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 |
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-kafka-client/kafka_admin_client.rb', line 137 def list_topics if true if (block_given?) return @j_del.java_method(:listTopics, [Java::IoVertxCore::Handler.java_class]).call(block_given? ? Proc.new { |ar| yield(ar.failed ? ar.cause : nil, ar.succeeded ? ::Vertx::Util::Utils.to_set(ar.result).map! { |elt| elt } : nil) } : promise) else promise = ::Vertx::Util::Utils.promise @j_del.java_method(:listTopics, [Java::IoVertxCore::Handler.java_class]).call(block_given? ? Proc.new { |ar| yield(ar.failed ? ar.cause : nil, ar.succeeded ? ::Vertx::Util::Utils.to_set(ar.result).map! { |elt| elt } : nil) } : promise) return ::Vertx::Util::Utils.safe_create(promise.future(),::Vertx::Future, nil) end end if defined?(super) super else raise ArgumentError, "Invalid arguments when calling list_topics()" end end |