K
- The key deserializer typeV
- The value deserializer typepublic abstract class AbstractKafkaConfiguration<K,V> extends Object
Modifier and Type | Field and Description |
---|---|
static String |
DEFAULT_BOOTSTRAP_SERVERS
The default bootstrap server address.
|
static int |
DEFAULT_KAFKA_PORT
The default kafka port.
|
static String |
EMBEDDED
The property to use to enable embedded Kafka.
|
static String |
EMBEDDED_TOPICS
The topics that should be created.
|
static String |
PREFIX
The default prefix used for Kafka configuration.
|
Modifier | Constructor and Description |
---|---|
protected |
AbstractKafkaConfiguration(Properties config)
Constructs a new instance.
|
public static final int DEFAULT_KAFKA_PORT
public static final String PREFIX
public static final String EMBEDDED
public static final String EMBEDDED_TOPICS
public static final String DEFAULT_BOOTSTRAP_SERVERS
protected AbstractKafkaConfiguration(Properties config)
config
- The config to use@Nonnull public Properties getConfig()