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

Class AmqpExtractor

java.lang.Object
io.aiven.commons.kafka.connector.source.extractor.Extractor
io.aiven.kafka.connect.amqp.source.extractor.AmqpExtractor
All Implemented Interfaces:
AutoCloseable
public final class AmqpExtractor extends io.aiven.commons.kafka.connector.source.extractor.Extractor
Extracts data from the AMQP Message. Each AMQP message generates a single Kafka message

  • Field Summary

    Fields inherited from class io.aiven.commons.kafka.connector.source.extractor.Extractor

    config, info

  • Constructor Summary

    Constructors
    Constructor
    Description
    AmqpExtractor(io.aiven.commons.kafka.connector.source.config.SourceCommonConfig config)
    Creates AmqpExtractor

  • Method Summary

    Modifier and Type
    Method
    Description
    org.apache.kafka.connect.data.SchemaAndValue
    generateKeyData(io.aiven.commons.kafka.connector.source.EvolvingSourceRecord evolvingSourceRecord)
     
    Stream<org.apache.kafka.connect.data.SchemaAndValue>
    generateRecords(io.aiven.commons.kafka.connector.source.EvolvingSourceRecord sourceRecord)
     
    static io.aiven.commons.kafka.connector.source.extractor.ExtractorInfo
    info()
    Creates an ExtractorInfo for this extractor.
    static com.fasterxml.jackson.databind.ObjectMapper
    registerSerializers(com.fasterxml.jackson.databind.ObjectMapper objectMapper)
    Registeres the standard JSON serializers used by the extractor.

    Methods inherited from class io.aiven.commons.kafka.connector.source.extractor.Extractor

    close

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • AmqpExtractor

      public AmqpExtractor(io.aiven.commons.kafka.connector.source.config.SourceCommonConfig config)
      Creates AmqpExtractor
      Parameters:
      config - the

  • Method Details

    • registerSerializers

      public static com.fasterxml.jackson.databind.ObjectMapper registerSerializers(com.fasterxml.jackson.databind.ObjectMapper objectMapper)
      Registeres the standard JSON serializers used by the extractor.
      Parameters:
      objectMapper - the ObjectMapper to add the serializers to.
      Returns:
      the objectMapper parameter with serializers added.

    • info

      public static io.aiven.commons.kafka.connector.source.extractor.ExtractorInfo info()
      Creates an ExtractorInfo for this extractor.
      Returns:
      the ExtractorInfo for this extractor.

    • generateRecords

      public Stream<org.apache.kafka.connect.data.SchemaAndValue> generateRecords(io.aiven.commons.kafka.connector.source.EvolvingSourceRecord sourceRecord)
      Specified by:
      generateRecords in class io.aiven.commons.kafka.connector.source.extractor.Extractor

    • generateKeyData

      public org.apache.kafka.connect.data.SchemaAndValue generateKeyData(io.aiven.commons.kafka.connector.source.EvolvingSourceRecord evolvingSourceRecord)
      Overrides:
      generateKeyData in class io.aiven.commons.kafka.connector.source.extractor.Extractor