Package io.aiven.kafka.connect.amqp.source

Class AmqpSourceData.ULIDSerde

java.lang.Object
io.aiven.kafka.connect.amqp.source.AmqpSourceData.ULIDSerde
All Implemented Interfaces:
io.aiven.commons.kafka.connector.source.NativeSourceData.KeySerde<de.huxhorn.sulky.ulid.ULID.Value>
Enclosing class:
AmqpSourceData
public static class AmqpSourceData.ULIDSerde extends Object implements io.aiven.commons.kafka.connector.source.NativeSourceData.KeySerde<de.huxhorn.sulky.ulid.ULID.Value>
The AMQP native source data implementation of NativeSourceData.KeySerde.

  • Field Summary

    Fields inherited from interface io.aiven.commons.kafka.connector.source.NativeSourceData.KeySerde

    STRING_SERDE

  • Constructor Summary

    Constructors
    Constructor
    Description
    ULIDSerde()
    Default constructor

  • Method Summary

    Modifier and Type
    Method
    Description
    de.huxhorn.sulky.ulid.ULID.Value
    fromString(String nativeKeyString)
     
    String
    toString(de.huxhorn.sulky.ulid.ULID.Value nativeKey)
     

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Constructor Details

    • ULIDSerde

      public ULIDSerde()
      Default constructor

  • Method Details

    • toString

      public String toString(de.huxhorn.sulky.ulid.ULID.Value nativeKey)
      Specified by:
      toString in interface io.aiven.commons.kafka.connector.source.NativeSourceData.KeySerde<de.huxhorn.sulky.ulid.ULID.Value>

    • fromString

      public de.huxhorn.sulky.ulid.ULID.Value fromString(String nativeKeyString)
      Specified by:
      fromString in interface io.aiven.commons.kafka.connector.source.NativeSourceData.KeySerde<de.huxhorn.sulky.ulid.ULID.Value>