Hierarchy For All Packages

Package Hierarchies:

• io.aiven.kafka.connect.amqp,
• io.aiven.kafka.connect.amqp.common,
• io.aiven.kafka.connect.amqp.common.config,
• io.aiven.kafka.connect.amqp.common.data,
• io.aiven.kafka.connect.amqp.sink,
• io.aiven.kafka.connect.amqp.sink.config,
• io.aiven.kafka.connect.amqp.sink.errant,
• io.aiven.kafka.connect.amqp.sink.strategy,
• io.aiven.kafka.connect.amqp.source,
• io.aiven.kafka.connect.amqp.source.config

Class Hierarchy

• java.lang.Object
  • io.aiven.kafka.connect.amqp.sink.strategy.AbstractAmqpStrategy (implements io.aiven.kafka.connect.amqp.sink.strategy.Strategy)
    • io.aiven.kafka.connect.amqp.sink.strategy.AmqpBodyFmt
    • io.aiven.kafka.connect.amqp.sink.strategy.AmqpRawFmt
  • org.apache.kafka.common.config.AbstractConfig
    • io.aiven.commons.kafka.config.CommonConfig
      • io.aiven.commons.kafka.connector.common.config.ConnectorCommonConfig
        • io.aiven.kafka.connect.amqp.sink.config.AmqpSinkConfig (implements io.aiven.kafka.connect.amqp.common.config.AmqpCommonConfig)
        • io.aiven.commons.kafka.connector.source.config.SourceCommonConfig
          • io.aiven.kafka.connect.amqp.source.config.AmqpSourceConfig (implements io.aiven.kafka.connect.amqp.common.config.AmqpCommonConfig)
  • io.aiven.commons.kafka.config.fragment.AbstractFragmentSetter<T>
    • io.aiven.kafka.connect.amqp.common.config.AmqpFragment.Setter
    • io.aiven.kafka.connect.amqp.sink.config.AmqpSinkConfigDef.Setter
  • io.aiven.commons.kafka.connector.source.AbstractSourceNativeInfo<K,N> (implements java.lang.Comparable<T>)
    • io.aiven.kafka.connect.amqp.source.AmqpSourceNativeInfo
  • io.aiven.kafka.connect.amqp.AmqpConverter (implements org.apache.kafka.connect.storage.Converter)
  • io.aiven.kafka.connect.amqp.source.AmqpOffsetManagerEntry (implements io.aiven.commons.kafka.connector.source.OffsetManager.OffsetManagerEntry)
  • io.aiven.kafka.connect.amqp.sink.AmqpSinkVersionInfo
  • io.aiven.kafka.connect.amqp.source.AmqpSourceVersionInfo
  • org.apache.kafka.common.config.ConfigDef
    • io.aiven.commons.kafka.config.CommonConfigDef
      • io.aiven.commons.kafka.connector.common.config.ConnectorCommonConfigDef
        • io.aiven.kafka.connect.amqp.sink.config.AmqpSinkConfigDef
        • io.aiven.commons.kafka.connector.source.config.SourceCommonConfig.SourceCommonConfigDef
          • io.aiven.kafka.connect.amqp.source.config.AmqpSourceConfigDef
  • io.aiven.commons.kafka.config.fragment.ConfigFragment (implements io.aiven.commons.kafka.config.fragment.FragmentDataAccess)
    • io.aiven.kafka.connect.amqp.common.config.AmqpFragment (implements io.aiven.kafka.connect.amqp.common.config.AmqpCommonConfig)
  • org.apache.kafka.connect.connector.Connector (implements org.apache.kafka.connect.components.Versioned)
    • org.apache.kafka.connect.sink.SinkConnector
      • io.aiven.kafka.connect.amqp.sink.AmqpSinkConnector
    • org.apache.kafka.connect.source.SourceConnector
      • io.aiven.kafka.connect.amqp.source.AmqpSourceConnector
  • io.aiven.commons.kafka.connector.source.task.Context
    • io.aiven.kafka.connect.amqp.source.AmqpContext
  • io.aiven.commons.kafka.connector.source.task.Context.Builder<T>
    • io.aiven.kafka.connect.amqp.source.AmqpContext.AmqpContextBuilder
  • io.aiven.kafka.connect.amqp.common.data.EncoderDecoder
    • io.aiven.kafka.connect.amqp.common.data.AmqpEnDec
    • io.aiven.kafka.connect.amqp.common.data.CollectionEnDec
    • io.aiven.kafka.connect.amqp.common.data.EncoderDecoder.ChainedEnDec
    • io.aiven.kafka.connect.amqp.common.data.KafkaEnDec
    • io.aiven.kafka.connect.amqp.common.data.UniqueTypeEnDec
  • io.aiven.kafka.connect.amqp.sink.errant.ErrantRecordHandler
  • io.aiven.kafka.connect.amqp.sink.errant.ErrantRecordHandler.LoggingReporter (implements org.apache.kafka.connect.sink.ErrantRecordReporter)
  • io.aiven.kafka.connect.amqp.common.data.HeaderExtractor
  • io.aiven.commons.kafka.connector.source.NativeSourceData<K> (implements java.lang.AutoCloseable)
    • io.aiven.kafka.connect.amqp.source.AmqpSourceData
  • org.apache.kafka.connect.sink.SinkTask (implements org.apache.kafka.connect.connector.Task)
    • io.aiven.kafka.connect.amqp.sink.AmqpSinkTask
  • org.apache.kafka.connect.source.SourceTask (implements org.apache.kafka.connect.connector.Task)
    • io.aiven.commons.kafka.connector.source.AbstractSourceTask
      • io.aiven.kafka.connect.amqp.source.AmqpSourceTask
  • java.lang.Throwable (implements java.io.Serializable)
    • java.lang.Exception
      • io.aiven.kafka.connect.amqp.common.AmqpParseException

Interface Hierarchy

• io.aiven.kafka.connect.amqp.common.config.AmqpCommonConfig
• io.aiven.kafka.connect.amqp.sink.strategy.Strategy

Enum Class Hierarchy

• java.lang.Object
  • java.lang.Enum<E> (implements java.lang.Comparable<T>, java.lang.constant.Constable, java.io.Serializable)
    • io.aiven.kafka.connect.amqp.common.config.AmqpFormat
    • io.aiven.kafka.connect.amqp.common.config.AmqpHeaderProperties
    • io.aiven.kafka.connect.amqp.sink.config.AmqpStrategy

Record Class Hierarchy

• java.lang.Object
  • java.lang.Record
    • io.aiven.kafka.connect.amqp.sink.strategy.AbstractAmqpStrategy.TrackerSinkRecord
    • io.aiven.kafka.connect.amqp.common.KafkaRecordKey (implements java.lang.Comparable<T>)