K
- The key deserializer typeV
- The value deserializer type@EachProperty(value="kafka.producers", primary="default") @Requires(beans=KafkaDefaultConfiguration.class) public class KafkaProducerConfiguration<K,V> extends AbstractKafkaProducerConfiguration<K,V>
Modifier and Type | Field and Description |
---|---|
static String |
PREFIX
The default configuration for producers.
|
DEFAULT_BOOTSTRAP_SERVERS, DEFAULT_KAFKA_PORT, EMBEDDED, EMBEDDED_TOPICS
Constructor and Description |
---|
KafkaProducerConfiguration(String producerName,
KafkaDefaultConfiguration defaultConfiguration,
Environment environment)
Constructs the default producer configuration.
|
getKeySerializer, getValueSerializer, setKeySerializer, setValueSerializer
getConfig
public static final String PREFIX
public KafkaProducerConfiguration(@Parameter String producerName, KafkaDefaultConfiguration defaultConfiguration, Environment environment)
producerName
- The name of the producerdefaultConfiguration
- The default Kafka configurationenvironment
- The environment