Как использовать собственный сериализатор в клиенте Vertx Kafka?

Question

У меня есть следующие свойства производителя kafka.

value.serializer=MyEventSerializer
value.deserializer=MyEventDeserializer
default.value.serde=MyEventSerde

И я прошел сериализаторы на Vertx сайте и создал производителя, используя

KafkaProducer<String, MyEvent> producer = KafkaProducer.create(vertx, configProperties, String.class, MyEvent.class);

но я получаю следующую ошибку:

SEVERE: Unknown class for built-in 
serializer. Supported types are: String, Short, Integer, Long, Float, Double, ByteArray, ByteBuffer, Bytes
java.lang.IllegalArgumentException: Unknown class for built-in serializer. Supported types are: String, Short, Integer, Long, Float, Double, ByteArray, ByteBuffer, Bytes

Есть ли способ иметь собственный сериализатор в клиенте Vertx kafka?

Answer 1

Мне пришлось сделать это вручную, что делает KafkaProducer.create().

Serializer<String> keySerializer = VertxSerdes.serdeFrom(String.class).serializer();
Serializer<MyEvent> valueSerializer = new MyEventSerializer();
KafkaWriteStream<String, MyEvent> stream = new KafkaWriteStreamImpl(vertx.getOrCreateContext(), new org.apache.kafka.clients.producer.KafkaProducer(configProperties, keySerializer, valueSerializer));
KafkaProducer<String,MyEvent> producer=(new KafkaProducerImpl(stream)).registerCloseHook();

, а затем записать записи, используя ..

KafkaProducerRecord producerRecord= KafkaProducerRecord.create(topicName,key,value);

        producer.write(producerRecord, done -> {
            if (done.succeeded()) {
                // TODO if succeeded
            } else {
                // TODO if failed
            }

         });