Package com.networknt.kafka.producer

Class SchemaRecordSerializer

java.lang.Object

com.networknt.kafka.producer.SchemaRecordSerializer

public class SchemaRecordSerializer
extends Object

Constructor Summary

Constructors

Constructor	Description
SchemaRecordSerializer(io.confluent.kafka.schemaregistry.client.SchemaRegistryClient schemaRegistryClient, Map<String,Object> avroSerializerConfigs, Map<String,Object> jsonschemaSerializerConfigs, Map<String,Object> protobufSerializerConfigs)

Method Summary

Modifier and Type	Method	Description
Optional<com.google.protobuf.ByteString>	serialize(EmbeddedFormat format, String topicName, Optional<RegisteredSchema> schema, com.fasterxml.jackson.databind.JsonNode data, boolean isKey)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SchemaRecordSerializer

public SchemaRecordSerializer(io.confluent.kafka.schemaregistry.client.SchemaRegistryClient schemaRegistryClient,
                              Map<String,Object> avroSerializerConfigs,
                              Map<String,Object> jsonschemaSerializerConfigs,
                              Map<String,Object> protobufSerializerConfigs)

Method Detail

serialize

public Optional<com.google.protobuf.ByteString> serialize(EmbeddedFormat format,
                                                          String topicName,
                                                          Optional<RegisteredSchema> schema,
                                                          com.fasterxml.jackson.databind.JsonNode data,
                                                          boolean isKey)