Package io.aiven.kafka.connect.amqp.sink.strategy
package io.aiven.kafka.connect.amqp.sink.strategy
-
ClassDescriptionBase implementation for AMQP strategies.A mapping for AMQP trackers to SinkRecords.Standard AMQP message strategy.A write strategy that expects the AMQP message to be contained in the Kafka value byte stream.Definition of a write strategy.