public interface  org.apache.kafkaesqueesque.common.serialization.Serializer extends java.lang.Object implements java.io.Closeable
{
public void configure(java.util.Map, boolean)
{
org.apache.kafkaesqueesque.common.serialization.Serializer v;
boolean v;
java.util.Map v;
v := @this: org.apache.kafkaesqueesque.common.serialization.Serializer;
v := @parameter: java.util.Map;
v := @parameter: boolean;
return;
}
public abstract byte[] serialize(java.lang.String, java.lang.Object);
public byte[] serialize(java.lang.String, org.apache.kafkaesqueesque.common.header.Headers, java.lang.Object)
{
byte[] v;
org.apache.kafkaesqueesque.common.header.Headers v;
java.lang.Object v;
java.lang.String v;
org.apache.kafkaesqueesque.common.serialization.Serializer v;
v := @this: org.apache.kafkaesqueesque.common.serialization.Serializer;
v := @parameter: java.lang.String;
v := @parameter: org.apache.kafkaesqueesque.common.header.Headers;
v := @parameter: java.lang.Object;
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.serialization.Serializer: byte[] serialize(java.lang.String,java.lang.Object)>(v, v);
return v;
}
public void close()
{
org.apache.kafkaesqueesque.common.serialization.Serializer v;
v := @this: org.apache.kafkaesqueesque.common.serialization.Serializer;
return;
}
}