Modifier and Type | Method and Description |
---|---|
static KafkaClientOptions |
KafkaClientOptions.fromMap(Map<String,Object> config,
boolean isProducer)
Create KafkaClientOptions from underlying Kafka config as map
|
static KafkaClientOptions |
KafkaClientOptions.fromProperties(Properties config,
boolean isProducer)
Create KafkaClientOptions from underlying Kafka config as Properties
|
KafkaClientOptions |
KafkaClientOptions.setConfig(Map<String,Object> config)
Set the Kafka config.
|
KafkaClientOptions |
KafkaClientOptions.setConfig(String key,
Object value)
Set a Kafka config entry.
|
KafkaClientOptions |
KafkaClientOptions.setTracePeerAddress(String tracePeerAddress)
Set the Kafka address to show in trace tags.
|
KafkaClientOptions |
KafkaClientOptions.setTracingPolicy(TracingPolicy tracingPolicy)
Set the Kafka tracing policy.
|
Modifier and Type | Method and Description |
---|---|
static void |
KafkaClientOptionsConverter.fromJson(Iterable<Map.Entry<String,Object>> json,
KafkaClientOptions obj) |
static void |
KafkaClientOptionsConverter.toJson(KafkaClientOptions obj,
JsonObject json) |
static void |
KafkaClientOptionsConverter.toJson(KafkaClientOptions obj,
Map<String,Object> json) |
Modifier and Type | Method and Description |
---|---|
static <S> ConsumerTracer |
ConsumerTracer.create(VertxTracer tracer,
KafkaClientOptions opts)
Creates a ConsumerTracer, which provides an opinionated facade for using
VertxTracer
with a Kafka Consumer use case. |
static <S> ProducerTracer |
ProducerTracer.create(VertxTracer tracer,
KafkaClientOptions opts)
Creates a ProducerTracer, which provides an opinionated facade for using
VertxTracer
with a Kafka Producer use case. |
Modifier and Type | Method and Description |
---|---|
static <K,V> KafkaReadStream<K,V> |
KafkaReadStream.create(Vertx vertx,
KafkaClientOptions options)
Create a new KafkaReadStream instance
|
static <K,V> KafkaConsumer<K,V> |
KafkaConsumer.create(Vertx vertx,
KafkaClientOptions options)
Create a new KafkaConsumer instance
|
static <K,V> KafkaReadStream<K,V> |
KafkaReadStream.create(Vertx vertx,
KafkaClientOptions options,
Class<K> keyType,
Class<V> valueType)
Create a new KafkaReadStream instance
|
static <K,V> KafkaConsumer<K,V> |
KafkaConsumer.create(Vertx vertx,
KafkaClientOptions options,
Class<K> keyType,
Class<V> valueType)
Create a new KafkaConsumer instance
|
static <K,V> KafkaReadStream<K,V> |
KafkaReadStream.create(Vertx vertx,
KafkaClientOptions options,
org.apache.kafka.common.serialization.Deserializer<K> keyDeserializer,
org.apache.kafka.common.serialization.Deserializer<V> valueDeserializer)
Create a new KafkaReadStream instance
|
static <K,V> KafkaConsumer<K,V> |
KafkaConsumer.create(Vertx vertx,
KafkaClientOptions options,
org.apache.kafka.common.serialization.Deserializer<K> keyDeserializer,
org.apache.kafka.common.serialization.Deserializer<V> valueDeserializer)
Create a new KafkaConsumer instance
|
Modifier and Type | Method and Description |
---|---|
static <K,V> KafkaWriteStream<K,V> |
KafkaWriteStream.create(Vertx vertx,
KafkaClientOptions options)
Create a new KafkaWriteStream instance
|
static <K,V> KafkaWriteStream<K,V> |
KafkaWriteStream.create(Vertx vertx,
KafkaClientOptions options,
Class<K> keyType,
Class<V> valueType)
Create a new KafkaWriteStream instance
|
static <K,V> KafkaWriteStream<K,V> |
KafkaWriteStream.create(Vertx vertx,
KafkaClientOptions options,
org.apache.kafka.common.serialization.Serializer<K> keySerializer,
org.apache.kafka.common.serialization.Serializer<V> valueSerializer)
Create a new KafkaWriteStream instance
|
static <K,V> KafkaProducer<K,V> |
KafkaProducer.createShared(Vertx vertx,
String name,
KafkaClientOptions options)
Get or create a KafkaProducer instance which shares its stream with any other KafkaProducer created with the same
name |
static <K,V> KafkaProducer<K,V> |
KafkaProducer.createShared(Vertx vertx,
String name,
KafkaClientOptions options,
Class<K> keyType,
Class<V> valueType)
Get or create a KafkaProducer instance which shares its stream with any other KafkaProducer created with the same
name |
static <K,V> KafkaProducer<K,V> |
KafkaProducer.createShared(Vertx vertx,
String name,
KafkaClientOptions options,
org.apache.kafka.common.serialization.Serializer<K> keySerializer,
org.apache.kafka.common.serialization.Serializer<V> valueSerializer)
Get or create a KafkaProducer instance which shares its stream with any other KafkaProducer created with the same
name |
Modifier and Type | Method and Description |
---|---|
static <K,V> KafkaConsumer<K,V> |
KafkaConsumer.create(Vertx vertx,
KafkaClientOptions options)
Create a new KafkaConsumer instance
|
static <K,V> KafkaConsumer<K,V> |
KafkaConsumer.create(Vertx vertx,
KafkaClientOptions options,
Class<K> keyType,
Class<V> valueType)
Create a new KafkaConsumer instance
|
Modifier and Type | Method and Description |
---|---|
static <K,V> KafkaProducer<K,V> |
KafkaProducer.createShared(Vertx vertx,
String name,
KafkaClientOptions options)
Get or create a KafkaProducer instance which shares its stream with any other KafkaProducer created with the same
name |
static <K,V> KafkaProducer<K,V> |
KafkaProducer.createShared(Vertx vertx,
String name,
KafkaClientOptions options,
Class<K> keyType,
Class<V> valueType)
Get or create a KafkaProducer instance which shares its stream with any other KafkaProducer created with the same
name |
Modifier and Type | Method and Description |
---|---|
static <K,V> KafkaConsumer<K,V> |
KafkaConsumer.create(Vertx vertx,
KafkaClientOptions options)
Create a new KafkaConsumer instance
|
static <K,V> KafkaConsumer<K,V> |
KafkaConsumer.create(Vertx vertx,
KafkaClientOptions options,
Class<K> keyType,
Class<V> valueType)
Create a new KafkaConsumer instance
|
Modifier and Type | Method and Description |
---|---|
static <K,V> KafkaProducer<K,V> |
KafkaProducer.createShared(Vertx vertx,
String name,
KafkaClientOptions options)
Get or create a KafkaProducer instance which shares its stream with any other KafkaProducer created with the same
name |
static <K,V> KafkaProducer<K,V> |
KafkaProducer.createShared(Vertx vertx,
String name,
KafkaClientOptions options,
Class<K> keyType,
Class<V> valueType)
Get or create a KafkaProducer instance which shares its stream with any other KafkaProducer created with the same
name |
Copyright © 2021 Eclipse. All rights reserved.