public class KafkaExporterConfig extends ExporterConfig
ExporterConfig.ExporterType
ENABLED_CONFIG, ENABLED_CONFIG_DEFAULT, ENABLED_CONFIG_DOC, EVENTS_ENABLED_CONFIG, EVENTS_ENABLED_CONFIG_DEFAULT, EVENTS_ENABLED_CONFIG_DOC, EXPORTER_COMMON_CONFIG_PREFIXES, EXPORTER_COMMON_CONFIGS, METRICS_ENABLED_CONFIG, METRICS_ENABLED_CONFIG_DEFAULT, METRICS_ENABLED_CONFIG_DOC, PREFIX_EVENTS, PREFIX_EXPORTER, RECONFIGURABLES, TYPE_CONFIG, TYPE_CONFIG_DOC
Constructor and Description |
---|
KafkaExporterConfig(Map<String,?> originals) |
Modifier and Type | Method and Description |
---|---|
io.cloudevents.core.message.Encoding |
getEncoding() |
static void |
main(String[] args) |
parseType
documentationOf, equals, getBoolean, getClass, getConfiguredInstance, getConfiguredInstance, getConfiguredInstances, getConfiguredInstances, getConfiguredInstances, getDouble, getInt, getList, getLong, getPassword, getShort, getString, hashCode, ignore, logUnused, nonInternalValues, originals, originals, originalsStrings, originalsWithPrefix, originalsWithPrefix, typeOf, unused, values, valuesWithPrefixAllOrNothing, valuesWithPrefixOverride
public static final int MAX_REQUEST_SIZE
public static final int DEFAULT_MIN_ISR
public static final String PREFIX_PRODUCER
public static final String PREFIX_TOPIC
public static final String BOOTSTRAP_SERVERS_CONFIG
public static final String BOOTSTRAP_SERVERS_DOC
public static final String TOPIC_NAME_CONFIG
public static final String TOPIC_NAME_DOC
public static final String DEFAULT_TOPIC_NAME
public static final String TOPIC_CREATE_CONFIG
public static final String TOPIC_CREATE_DOC
public static final boolean DEFAULT_TOPIC_CREATE
public static final String TOPIC_PARTITIONS_CONFIG
public static final String TOPIC_PARTITIONS_DOC
public static final int DEFAULT_TOPIC_PARTITIONS
public static final String TOPIC_REPLICAS_CONFIG
public static final String TOPIC_REPLICAS_DOC
public static final int DEFAULT_TOPIC_REPLICAS
public static final String TOPIC_RETENTION_MS_CONFIG
public static final String TOPIC_RETENTION_MS_DOC
public static final long DEFAULT_TOPIC_RETENTION_MS
public static final String TOPIC_RETENTION_BYTES_CONFIG
public static final String TOPIC_RETENTION_BYTES_DOC
public static final long DEFAULT_TOPIC_RETENTION_BYTES
public static final String TOPIC_ROLL_MS_CONFIG
public static final String TOPIC_ROLL_MS_DOC
public static final long DEFAULT_TOPIC_ROLL_MS
public static final String TOPIC_MAX_MESSAGE_BYTES_CONFIG
public static final String TOPIC_MAX_MESSAGE_BYTES_DOC
public static final int DEFAULT_TOPIC_MAX_MESSAGE_BYTES
public static final String CLOUD_EVENT_STRUCTURED_ENCODING
public static final String CLOUD_EVENT_BINARY_ENCODING
public static final String CLOUD_EVENT_ENCODING_CONFIG
public static final String DEFAULT_CLOUD_EVENT_ENCODING_CONFIG
public static final String CLOUD_EVENT_ENCODING_DOC
public static final String EVENT_QUEUE_SIZE
public static final String EVENT_QUEUE_SIZE_DOC
public static final int DEFAULT_EVENT_QUEUE_SIZE
public static final int DEFAULT_PRODUCER_CLOSE_TIMEOUT
public static final String SUBSET_PARTITIONER_ENABLED
public static final String SUBSET_PARTITIONER_ENABLED_DOC
public static final boolean DEFAULT_SUBSET_PARTITIONER_ENABLED
public static void main(String[] args)
public io.cloudevents.core.message.Encoding getEncoding()