Package io.aiven.kafka.connect.amqp.sink.config

Class AmqpSinkConfigDef.Setter

java.lang.Object

io.aiven.commons.kafka.config.fragment.AbstractFragmentSetter<AmqpSinkConfigDef.Setter>

io.aiven.kafka.connect.amqp.sink.config.AmqpSinkConfigDef.Setter

Enclosing class:

AmqpSinkConfigDef

public static class AmqpSinkConfigDef.Setter
extends io.aiven.commons.kafka.config.fragment.AbstractFragmentSetter<AmqpSinkConfigDef.Setter>

The Setter for the AMQP sink specific options.

Field Summary

Fields inherited from class io.aiven.commons.kafka.config.fragment.AbstractFragmentSetter

self

Constructor Summary

Constructors

Constructor	Description
Setter(Map<String,String> data)	Constructor.

Method Summary

Modifier and Type	Method	Description
AmqpSinkConfigDef.Setter	strategy(AmqpStrategy strategy)	Sets the write strategy.

Methods inherited from class io.aiven.commons.kafka.config.fragment.AbstractFragmentSetter

data, setValue, setValue, setValue, setValue, setValue, setValue

Methods inherited from class java.lang.Object

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

Constructor Details

Setter

public Setter(Map<String,String> data)

Constructor.

Parameters:

data - the map of data items being set.getMessageFormat

Method Details

strategy

public AmqpSinkConfigDef.Setter strategy(AmqpStrategy strategy)

Sets the write strategy.

Parameters:

strategy - The write strategy to use.

Returns:

this