Class OSONSerializer<T>

java.lang.Object
com.oracle.spring.json.kafka.OSONSerializer<T>
Type Parameters:
T - serialization type.
All Implemented Interfaces:
Closeable, AutoCloseable, org.apache.kafka.common.serialization.Serializer<T>
public class OSONSerializer<T> extends Object implements org.apache.kafka.common.serialization.Serializer<T>
The OSONSerializer converts java objects to a JSONB byte array.

  • Constructor Details

    • OSONSerializer

      public OSONSerializer(com.oracle.spring.json.jsonb.JSONB jsonb)

  • Method Details

    • serialize

      public byte[] serialize(String s, T obj)
      Specified by:
      serialize in interface org.apache.kafka.common.serialization.Serializer<T>