public class KafkaCodecs extends Object
The BufferSerializer and BufferDeserializer are registered along with the out of the box Kafka
ones.
Vert.x Kafka Client uses it for looking up classes to find Serializer and Deserializer classes
when using KafkaConsumer.create(Vertx, Map, Class, Class) or
KafkaProducer.create(Vertx, Map, Class, Class).
| Constructor and Description |
|---|
KafkaCodecs() |
| Modifier and Type | Method and Description |
|---|---|
static <T> org.apache.kafka.common.serialization.Deserializer<T> |
deserializer(Class<T> type) |
static <T> org.apache.kafka.common.serialization.Serializer<T> |
serializer(Class<T> type) |
public static <T> org.apache.kafka.common.serialization.Serializer<T> serializer(Class<T> type)
type.public static <T> org.apache.kafka.common.serialization.Deserializer<T> deserializer(Class<T> type)
type.Copyright © 2017. All rights reserved.