Class ProtobufSerde<T extends com.google.protobuf.Message>

  • All Implemented Interfaces:
    Closeable, AutoCloseable, org.apache.kafka.common.serialization.Serde<T>

    public class ProtobufSerde<T extends com.google.protobuf.Message>
    extends AbstractSerde<T>
    Wraps the ProtobufKafkaSerializer and ProtobufKafkaDeserializer.
    • Constructor Detail

      • ProtobufSerde

        public ProtobufSerde()