Package org.apache.kafka.streams.internals

Class QuietStreamsConfig

java.lang.Object

org.apache.kafka.common.config.AbstractConfig

org.apache.kafka.streams.StreamsConfig

org.apache.kafka.streams.internals.QuietStreamsConfig

public class QuietStreamsConfig
extends StreamsConfig

A StreamsConfig that does not log its configuration on construction. This producer cleaner output for unit tests using the test-utils, since logging the config is not really valuable in this context.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.kafka.streams.StreamsConfig

StreamsConfig.InternalConfig

Field Summary

Fields inherited from class org.apache.kafka.streams.StreamsConfig

ACCEPTABLE_RECOVERY_LAG_CONFIG, ADMIN_CLIENT_PREFIX, APPLICATION_DIR_ACES_CONFIG, APPLICATION_ID_CONFIG, APPLICATION_SERVER_CONFIG, AT_LEAST_ONCE, BUFFERED_RECORDS_PER_PARTITION_CONFIG, BUILT_IN_METRICS_VERSION_CONFIG, CACHE_MAX_BYTES_BUFFERING_CONFIG, CLIENT_ID_CONFIG, COMMIT_INTERVAL_MS_CONFIG, CONNECTIONS_MAX_IDLE_MS_CONFIG, CONSUMER_PREFIX, DEFAULT_DESERIALIZATION_EXCEPTION_HANDLER_CLASS_CONFIG, DEFAULT_KEY_SERDE_CLASS_CONFIG, DEFAULT_PRODUCTION_EXCEPTION_HANDLER_CLASS_CONFIG, DEFAULT_TIMESTAMP_EXTRACTOR_CLASS_CONFIG, DEFAULT_VALUE_SERDE_CLASS_CONFIG, DEFAULT_WINDOWED_KEY_SERDE_INNER_CLASS, DEFAULT_WINDOWED_VALUE_SERDE_INNER_CLASS, DUMMY_THREAD_INDEX, EXACTLY_ONCE, EXACTLY_ONCE_BETA, GLOBAL_CONSUMER_PREFIX, MAIN_CONSUMER_PREFIX, MAX_TASK_IDLE_MS_CONFIG, MAX_WARMUP_REPLICAS_CONFIG, METADATA_MAX_AGE_CONFIG, METRIC_REPORTER_CLASSES_CONFIG, METRICS_0100_TO_24, METRICS_LATEST, METRICS_NUM_SAMPLES_CONFIG, METRICS_RECORDING_LEVEL_CONFIG, METRICS_SAMPLE_WINDOW_MS_CONFIG, NO_OPTIMIZATION, NUM_STANDBY_REPLICAS_CONFIG, NUM_STREAM_THREADS_CONFIG, OPTIMIZE, PARTITION_GROUPER_CLASS_CONFIG, POLL_MS_CONFIG, PROBING_REBALANCE_INTERVAL_MS_CONFIG, PROCESSING_GUARANTEE_CONFIG, PRODUCER_PREFIX, RECEIVE_BUFFER_CONFIG, RECONNECT_BACKOFF_MAX_MS_CONFIG, RECONNECT_BACKOFF_MS_CONFIG, REPLICATION_FACTOR_CONFIG, REQUEST_TIMEOUT_MS_CONFIG, RESTORE_CONSUMER_PREFIX, RETRIES_CONFIG, RETRY_BACKOFF_MS_CONFIG, ROCKSDB_CONFIG_SETTER_CLASS_CONFIG, SECURITY_PROTOCOL_CONFIG, SEND_BUFFER_CONFIG, STATE_CLEANUP_DELAY_MS_CONFIG, STATE_DIR_CONFIG, STREAMS_DEFAULT_STREAM_CONFIG, STREAMS_INTERNAL_STREAM_COMMON_FOLDER, TOPIC_PREFIX, TOPOLOGY_OPTIMIZATION, UPGRADE_FROM_0100, UPGRADE_FROM_0101, UPGRADE_FROM_0102, UPGRADE_FROM_0110, UPGRADE_FROM_10, UPGRADE_FROM_11, UPGRADE_FROM_20, UPGRADE_FROM_21, UPGRADE_FROM_22, UPGRADE_FROM_23, UPGRADE_FROM_CONFIG, WINDOW_STORE_CHANGE_LOG_ADDITIONAL_RETENTION_MS_CONFIG

Fields inherited from class org.apache.kafka.common.config.AbstractConfig

CONFIG_PROVIDERS_CONFIG

Constructor Summary

Constructors

Constructor	Description
QuietStreamsConfig(Map<?,?> props)

Method Summary

Methods inherited from class org.apache.kafka.streams.StreamsConfig

adminClientPrefix, configDef, consumerPrefix, defaultDeserializationExceptionHandler, defaultKeySerde, defaultProductionExceptionHandler, defaultTimestampExtractor, defaultValueSerde, getAdminConfigs, getConsumerConfigs, getGlobalConsumerConfigs, getMainConsumerConfigs, getProducerConfigs, getRestoreConsumerConfigs, getStreamsCliSideAssignmentInternalStream, getStreamsInternalStreamCompacted, getStreamsInternalStreamFolder, getStreamsInternalStreamNotcompacted, globalConsumerPrefix, main, mainConsumerPrefix, postProcessParsedConfig, producerPrefix, restoreConsumerPrefix, topicPrefix

Methods inherited from class org.apache.kafka.common.config.AbstractConfig

documentationOf, equals, get, getBoolean, getClass, getConfiguredInstance, getConfiguredInstances, getConfiguredInstances, getConfiguredInstances, getDouble, getInt, getList, getLong, getPassword, getShort, getString, hashCode, ignore, logUnused, originals, originalsStrings, originalsWithPrefix, originalsWithPrefix, typeOf, unused, values, valuesWithPrefixAllOrNothing, valuesWithPrefixOverride

Methods inherited from class java.lang.Object

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

Constructor Detail

QuietStreamsConfig

public QuietStreamsConfig(Map<?,?> props)