Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

org.apache.kafka.common.serialization.Serializer

Code Block
languagejava
firstlineSerializer
    @Deprecated
    default byte[] serialize(String topic, T data) {
        throw new UnsupportedOperationException("this method is not used on production anymore");
    }

    @Deprecated
    default byte[] serialize(String topic, Headers headers, T data) {
        return serialize(topic, data);
    }

    default ByteBuffer serialize(String topic, T data, Headers headers) {
        byte[] array = serialize(topic, headers, data);
        return array == null ? null : ByteBuffer.wrap(array);
    }

...