Hierarchy For All Packages

Package Hierarchies:

• org.apache.kafka.connect.components,
• org.apache.kafka.connect.connector,
• org.apache.kafka.connect.connector.policy,
• org.apache.kafka.connect.data,
• org.apache.kafka.connect.errors,
• org.apache.kafka.connect.header,
• org.apache.kafka.connect.health,
• org.apache.kafka.connect.rest,
• org.apache.kafka.connect.sink,
• org.apache.kafka.connect.source,
• org.apache.kafka.connect.storage,
• org.apache.kafka.connect.transforms,
• org.apache.kafka.connect.transforms.predicates,
• org.apache.kafka.connect.util

Class Hierarchy

• java.lang.Object
  • org.apache.kafka.common.config.AbstractConfig
    • org.apache.kafka.connect.storage.ConverterConfig
      • org.apache.kafka.connect.storage.StringConverterConfig
  • org.apache.kafka.connect.health.AbstractState
    • org.apache.kafka.connect.health.ConnectorState
    • org.apache.kafka.connect.health.TaskState
  • org.apache.kafka.connect.header.ConnectHeaders (implements org.apache.kafka.connect.header.Headers)
  • org.apache.kafka.connect.connector.Connector (implements org.apache.kafka.connect.components.Versioned)
    • org.apache.kafka.connect.sink.SinkConnector
    • org.apache.kafka.connect.source.SourceConnector
  • org.apache.kafka.connect.connector.policy.ConnectorClientConfigRequest
  • org.apache.kafka.connect.health.ConnectorHealth
  • org.apache.kafka.connect.util.ConnectorUtils
  • org.apache.kafka.connect.connector.ConnectRecord<R>
    • org.apache.kafka.connect.sink.SinkRecord
    • org.apache.kafka.connect.source.SourceRecord
  • org.apache.kafka.connect.data.ConnectSchema (implements org.apache.kafka.connect.data.Schema)
  • org.apache.kafka.connect.data.Date
  • org.apache.kafka.connect.data.Decimal
  • org.apache.kafka.connect.data.Field
  • org.apache.kafka.connect.data.SchemaAndValue
  • org.apache.kafka.connect.data.SchemaBuilder (implements org.apache.kafka.connect.data.Schema)
  • org.apache.kafka.connect.data.SchemaProjector
  • org.apache.kafka.connect.storage.SimpleHeaderConverter (implements org.apache.kafka.connect.storage.HeaderConverter)
  • org.apache.kafka.connect.sink.SinkTask (implements org.apache.kafka.connect.connector.Task)
  • org.apache.kafka.connect.source.SourceTask (implements org.apache.kafka.connect.connector.Task)
  • org.apache.kafka.connect.storage.StringConverter (implements org.apache.kafka.connect.storage.Converter, org.apache.kafka.connect.storage.HeaderConverter)
  • org.apache.kafka.connect.data.Struct
  • java.lang.Throwable (implements java.io.Serializable)
    • java.lang.Exception
      • java.lang.RuntimeException
        • org.apache.kafka.common.KafkaException
          • org.apache.kafka.connect.errors.ConnectException
            • org.apache.kafka.connect.errors.AlreadyExistsException
            • org.apache.kafka.connect.errors.DataException
              • org.apache.kafka.connect.errors.SchemaBuilderException
              • org.apache.kafka.connect.errors.SchemaProjectorException
            • org.apache.kafka.connect.errors.IllegalWorkerStateException
            • org.apache.kafka.connect.errors.NotFoundException
            • org.apache.kafka.connect.errors.RetriableException
  • org.apache.kafka.connect.data.Time
  • org.apache.kafka.connect.data.Timestamp
  • org.apache.kafka.connect.data.Values
  • org.apache.kafka.connect.data.Values.Parser
  • org.apache.kafka.connect.data.Values.SchemaDetector

Interface Hierarchy

• java.lang.AutoCloseable
  • java.io.Closeable
    • org.apache.kafka.connect.rest.ConnectRestExtension (also extends org.apache.kafka.common.Configurable, org.apache.kafka.connect.components.Versioned)
    • org.apache.kafka.connect.storage.HeaderConverter (also extends org.apache.kafka.common.Configurable)
    • org.apache.kafka.connect.transforms.Transformation<R> (also extends org.apache.kafka.common.Configurable)
  • org.apache.kafka.connect.connector.policy.ConnectorClientConfigOverridePolicy (also extends org.apache.kafka.common.Configurable)
  • org.apache.kafka.connect.transforms.predicates.Predicate<R> (also extends org.apache.kafka.common.Configurable)
• org.apache.kafka.common.Configurable
  • org.apache.kafka.connect.connector.policy.ConnectorClientConfigOverridePolicy (also extends java.lang.AutoCloseable)
  • org.apache.kafka.connect.rest.ConnectRestExtension (also extends java.io.Closeable, org.apache.kafka.connect.components.Versioned)
  • org.apache.kafka.connect.storage.HeaderConverter (also extends java.io.Closeable)
  • org.apache.kafka.connect.transforms.predicates.Predicate<R> (also extends java.lang.AutoCloseable)
  • org.apache.kafka.connect.transforms.Transformation<R> (also extends java.io.Closeable)
• org.apache.kafka.connect.health.ConnectClusterDetails
• org.apache.kafka.connect.health.ConnectClusterState
• org.apache.kafka.connect.connector.ConnectorContext
  • org.apache.kafka.connect.sink.SinkConnectorContext
  • org.apache.kafka.connect.source.SourceConnectorContext
• org.apache.kafka.connect.rest.ConnectRestExtensionContext
• org.apache.kafka.connect.storage.Converter
• org.apache.kafka.connect.sink.ErrantRecordReporter
• org.apache.kafka.connect.header.Header
• org.apache.kafka.connect.header.Headers.HeaderTransform
• java.lang.Iterable<T>
  • org.apache.kafka.connect.header.Headers
• org.apache.kafka.connect.storage.OffsetStorageReader
• org.apache.kafka.connect.data.Schema
• org.apache.kafka.connect.sink.SinkTaskContext
• org.apache.kafka.connect.source.SourceTaskContext
• org.apache.kafka.connect.connector.Task
• org.apache.kafka.connect.source.TransactionContext
• org.apache.kafka.connect.components.Versioned
  • org.apache.kafka.connect.rest.ConnectRestExtension (also extends java.io.Closeable, org.apache.kafka.common.Configurable)

Enum Hierarchy

• java.lang.Object
  • java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)
    • org.apache.kafka.connect.connector.policy.ConnectorClientConfigRequest.ClientType
    • org.apache.kafka.connect.source.ConnectorTransactionBoundaries
    • org.apache.kafka.connect.health.ConnectorType
    • org.apache.kafka.connect.storage.ConverterType
    • org.apache.kafka.connect.source.ExactlyOnceSupport
    • org.apache.kafka.connect.data.Schema.Type
    • org.apache.kafka.connect.source.SourceTask.TransactionBoundary