Class CloudRecordSerializerFacade

java.lang.Object

io.confluent.kafkarest.controllers.CloudRecordSerializerFacade

All Implemented Interfaces:

io.confluent.kafkarest.controllers.RecordSerializer

public class CloudRecordSerializerFacade
extends Object
implements io.confluent.kafkarest.controllers.RecordSerializer

Method Summary

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

Methods inherited from class Object

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

Method Details

serialize

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

Specified by:

serialize in interface io.confluent.kafkarest.controllers.RecordSerializer