com.ibm.eventstreams.serdes

Class EventStreamsSerdes

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


    public class EventStreamsSerdes
    extends Object
    implements org.apache.kafka.common.serialization.Serde<org.apache.avro.generic.IndexedRecord>
    Wraps the Event Streams serializer and deserializer.
    • Constructor Detail

      • EventStreamsSerdes

        public EventStreamsSerdes()
    • Method Detail

      • configure

        public void configure(Map<String,?> configs,
                              boolean isKey)
        Specified by:
        configure in interface org.apache.kafka.common.serialization.Serde<org.apache.avro.generic.IndexedRecord>
      • close

        public void close()
        Specified by:
        close in interface Closeable
        Specified by:
        close in interface AutoCloseable
        Specified by:
        close in interface org.apache.kafka.common.serialization.Serde<org.apache.avro.generic.IndexedRecord>
      • serializer

        public org.apache.kafka.common.serialization.Serializer<org.apache.avro.generic.IndexedRecord> serializer()
        Specified by:
        serializer in interface org.apache.kafka.common.serialization.Serde<org.apache.avro.generic.IndexedRecord>
      • deserializer

        public org.apache.kafka.common.serialization.Deserializer<org.apache.avro.generic.IndexedRecord> deserializer()
        Specified by:
        deserializer in interface org.apache.kafka.common.serialization.Serde<org.apache.avro.generic.IndexedRecord>

Copyright © 2019. All rights reserved.