Package io.confluent.kafka.formatter

Interface SchemaMessageSerializer<T>

All Superinterfaces:

AutoCloseable, Closeable

public interface SchemaMessageSerializer<T>
extends Closeable

Method Summary

Modifier and Type	Method	Description
default void	close()
void	configure(Map<String,?> configs, boolean isKey)
org.apache.kafka.common.serialization.Serializer	getKeySerializer()
SchemaRegistryClient	getSchemaRegistryClient()
byte[]	serialize(String subject, String topic, boolean isKey, org.apache.kafka.common.header.Headers headers, T object, ParsedSchema schema)
byte[]	serializeKey(String topic, org.apache.kafka.common.header.Headers headers, Object payload)

Method Details

configure

void configure(Map<String,?> configs,
 boolean isKey)

getKeySerializer

org.apache.kafka.common.serialization.Serializer getKeySerializer()

serializeKey

byte[] serializeKey(String topic,
 org.apache.kafka.common.header.Headers headers,
 Object payload)

serialize

byte[] serialize(String subject,
 String topic,
 boolean isKey,
 org.apache.kafka.common.header.Headers headers,
 T object,
 ParsedSchema schema)

getSchemaRegistryClient

SchemaRegistryClient getSchemaRegistryClient()

close

default void close()
            throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException