Constant Field Values

Contents

• org.springframework.*

org.springframework.*

org.springframework.kafka.annotation.KafkaListenerAnnotationBeanPostProcessor<K,V>

Modifier and Type	Constant Field	Value
public static final String	DEFAULT_KAFKA_LISTENER_CONTAINER_FACTORY_BEAN_NAME	"kafkaListenerContainerFactory"

org.springframework.kafka.annotation.KafkaStreamsDefaultConfiguration

Modifier and Type	Constant Field	Value
public static final String	DEFAULT_STREAMS_BUILDER_BEAN_NAME	"defaultKafkaStreamsBuilder"
public static final String	DEFAULT_STREAMS_CONFIG_BEAN_NAME	"defaultKafkaStreamsConfig"

org.springframework.kafka.config.KafkaListenerConfigUtils

Modifier and Type	Constant Field	Value
public static final String	KAFKA_LISTENER_ANNOTATION_PROCESSOR_BEAN_NAME	"org.springframework.kafka.config.internalKafkaListenerAnnotationProcessor"
public static final String	KAFKA_LISTENER_ENDPOINT_REGISTRY_BEAN_NAME	"org.springframework.kafka.config.internalKafkaListenerEndpointRegistry"

org.springframework.kafka.listener.AbstractMessageListenerContainer<K,V>

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_PHASE	2147483547

org.springframework.kafka.listener.ConsumerProperties

Modifier and Type	Constant Field	Value
public static final long	DEFAULT_POLL_TIMEOUT	5000L

org.springframework.kafka.listener.ContainerProperties

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_MONITOR_INTERVAL	30
public static final float	DEFAULT_NO_POLL_THRESHOLD	3.0f
public static final long	DEFAULT_SHUTDOWN_TIMEOUT	10000L

org.springframework.kafka.listener.SeekUtils

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_MAX_FAILURES	10

org.springframework.kafka.listener.adapter.RetryingMessageListenerAdapter<K,V>

Modifier and Type	Constant Field	Value
public static final String	CONTEXT_ACKNOWLEDGMENT	"acknowledgment"
public static final String	CONTEXT_CONSUMER	"consumer"
public static final String	CONTEXT_RECORD	"record"

org.springframework.kafka.requestreply.AggregatingReplyingKafkaTemplate<K,V,R>

Modifier and Type	Constant Field	Value
public static final String	AGGREGATED_RESULTS_TOPIC	"aggregatedResults"
public static final String	PARTIAL_RESULTS_AFTER_TIMEOUT_TOPIC	"partialResultsAfterTimeout"

org.springframework.kafka.retrytopic.RetryTopicConstants

Modifier and Type	Constant Field	Value
public static final String	DEFAULT_DLT_SUFFIX	"-dlt"
public static final int	DEFAULT_MAX_ATTEMPTS	3
public static final String	DEFAULT_RETRY_SUFFIX	"-retry"
public static final int	NOT_SET	-1

org.springframework.kafka.retrytopic.RetryTopicHeaders

Modifier and Type	Constant Field	Value
public static final String	DEFAULT_HEADER_ATTEMPTS	"retry_topic-attempts"
public static final String	DEFAULT_HEADER_BACKOFF_TIMESTAMP	"retry_topic-backoff-timestamp"
public static final String	DEFAULT_HEADER_ORIGINAL_TIMESTAMP	"retry_topic-original-timestamp"

org.springframework.kafka.retrytopic.RetryTopicInternalBeanNames

Modifier and Type	Constant Field	Value
public static final String	BACKOFF_SLEEPER_BEAN_NAME	"internalBackoffSleeper"
public static final String	BACKOFF_TASK_EXECUTOR	"internalBackOffTaskExecutor"
public static final String	DEAD_LETTER_PUBLISHING_RECOVERER_FACTORY_BEAN_NAME	"internalDeadLetterPublishingRecovererProvider"
public static final String	DEFAULT_KAFKA_TEMPLATE_BEAN_NAME	"retryTopicDefaultKafkaTemplate"
public static final String	DEFAULT_LISTENER_FACTORY_BEAN_NAME	"internalRetryTopicListenerContainerFactory"
public static final String	DESTINATION_TOPIC_CONTAINER_NAME	"internalDestinationTopicContainer"
public static final String	DESTINATION_TOPIC_PROCESSOR_NAME	"internalDestinationTopicProcessor"
public static final String	INTERNAL_BACKOFF_CLOCK_BEAN_NAME	"internalBackOffClock"
public static final String	INTERNAL_BACKOFF_TIMING_ADJUSTMENT_MANAGER	"internalKafkaConsumerTimingAdjustmentManager"
public static final String	INTERNAL_KAFKA_CONSUMER_BACKOFF_MANAGER_FACTORY	"internalKafkaConsumerBackOffManagerFactory"
public static final String	KAFKA_CONSUMER_BACKOFF_MANAGER	"internalKafkaConsumerBackoffManager"
public static final String	LISTENER_CONTAINER_FACTORY_CONFIGURER_NAME	"internalListenerContainerFactoryConfigurer"
public static final String	LISTENER_CONTAINER_FACTORY_RESOLVER_NAME	"internalListenerContainerFactoryResolver"
public static final String	RETRY_TOPIC_BOOTSTRAPPER	"internalRetryTopicBootstrapper"
public static final String	RETRY_TOPIC_CONFIGURER	"internalRetryTopicConfigurer"
public static final String	RETRY_TOPIC_NAMES_PROVIDER_FACTORY	"internalRetryTopicNamesProviderFactory"

org.springframework.kafka.security.jaas.KafkaJaasLoginModuleInitializer

Modifier and Type	Constant Field	Value
public static final String	KAFKA_CLIENT_CONTEXT_NAME	"KafkaClient"

org.springframework.kafka.streams.RecoveringDeserializationExceptionHandler

Modifier and Type	Constant Field	Value
public static final String	KSTREAM_DESERIALIZATION_RECOVERER	"spring.deserialization.recoverer"

org.springframework.kafka.support.DefaultKafkaHeaderMapper

Modifier and Type	Constant Field	Value
public static final String	JSON_TYPES	"spring_json_header_types"

org.springframework.kafka.support.KafkaHeaders

Modifier and Type	Constant Field	Value
public static final String	ACKNOWLEDGMENT	"kafka_acknowledgment"
public static final String	BATCH_CONVERTED_HEADERS	"kafka_batchConvertedHeaders"
public static final String	CONSUMER	"kafka_consumer"
public static final String	CONVERSION_FAILURES	"kafka_conversionFailures"
public static final String	CORRELATION_ID	"kafka_correlationId"
public static final String	DELIVERY_ATTEMPT	"kafka_deliveryAttempt"
public static final String	DLT_EXCEPTION_CAUSE_FQCN	"kafka_dlt-exception-cause-fqcn"
public static final String	DLT_EXCEPTION_FQCN	"kafka_dlt-exception-fqcn"
public static final String	DLT_EXCEPTION_MESSAGE	"kafka_dlt-exception-message"
public static final String	DLT_EXCEPTION_STACKTRACE	"kafka_dlt-exception-stacktrace"
public static final String	DLT_KEY_EXCEPTION_FQCN	"kafka_dlt-key-exception-fqcn"
public static final String	DLT_KEY_EXCEPTION_MESSAGE	"kafka_dlt-key-exception-message"
public static final String	DLT_KEY_EXCEPTION_STACKTRACE	"kafka_dlt-key-exception-stacktrace"
public static final String	DLT_ORIGINAL_CONSUMER_GROUP	"kafka_dlt-original-consumer-group"
public static final String	DLT_ORIGINAL_OFFSET	"kafka_dlt-original-offset"
public static final String	DLT_ORIGINAL_PARTITION	"kafka_dlt-original-partition"
public static final String	DLT_ORIGINAL_TIMESTAMP	"kafka_dlt-original-timestamp"
public static final String	DLT_ORIGINAL_TIMESTAMP_TYPE	"kafka_dlt-original-timestamp-type"
public static final String	DLT_ORIGINAL_TOPIC	"kafka_dlt-original-topic"
public static final String	EXCEPTION_CAUSE_FQCN	"kafka_exception-fqcn"
public static final String	EXCEPTION_FQCN	"kafka_exception-fqcn"
public static final String	EXCEPTION_MESSAGE	"kafka_exception-message"
public static final String	EXCEPTION_STACKTRACE	"kafka_exception-stacktrace"
public static final String	GROUP_ID	"kafka_groupId"
public static final String	KEY_EXCEPTION_FQCN	"kafka_key-exception-fqcn"
public static final String	KEY_EXCEPTION_MESSAGE	"kafka_key-exception-message"
public static final String	KEY_EXCEPTION_STACKTRACE	"kafka_key-exception-stacktrace"
public static final String	LISTENER_INFO	"kafka_listenerInfo"
public static final String	MESSAGE_KEY	"kafka_messageKey"
public static final String	NATIVE_HEADERS	"kafka_nativeHeaders"
public static final String	OFFSET	"kafka_offset"
public static final String	ORIGINAL_CONSUMER_GROUP	"kafka_dlt-original-consumer-group"
public static final String	ORIGINAL_OFFSET	"kafka_original-offset"
public static final String	ORIGINAL_PARTITION	"kafka_original-partition"
public static final String	ORIGINAL_TIMESTAMP	"kafka_original-timestamp"
public static final String	ORIGINAL_TIMESTAMP_TYPE	"kafka_original-timestamp-type"
public static final String	ORIGINAL_TOPIC	"kafka_original-topic"
public static final String	PARTITION_ID	"kafka_partitionId"
public static final String	PREFIX	"kafka_"
public static final String	RAW_DATA	"kafka_data"
public static final String	RECEIVED	"kafka_received"
public static final String	RECEIVED_MESSAGE_KEY	"kafka_receivedMessageKey"
public static final String	RECEIVED_PARTITION_ID	"kafka_receivedPartitionId"
public static final String	RECEIVED_TIMESTAMP	"kafka_receivedTimestamp"
public static final String	RECEIVED_TOPIC	"kafka_receivedTopic"
public static final String	RECORD_METADATA	"kafka_recordMetadata"
public static final String	REPLY_PARTITION	"kafka_replyPartition"
public static final String	REPLY_TOPIC	"kafka_replyTopic"
public static final String	TIMESTAMP	"kafka_timestamp"
public static final String	TIMESTAMP_TYPE	"kafka_timestampType"
public static final String	TOPIC	"kafka_topic"

org.springframework.kafka.support.LoggingProducerListener<K,V>

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_MAX_CONTENT_LOGGED	100

org.springframework.kafka.support.mapping.AbstractJavaTypeMapper

Modifier and Type	Constant Field	Value
public static final String	DEFAULT_CLASSID_FIELD_NAME	"__TypeId__"
public static final String	DEFAULT_CONTENT_CLASSID_FIELD_NAME	"__ContentTypeId__"
public static final String	DEFAULT_KEY_CLASSID_FIELD_NAME	"__KeyTypeId__"
public static final String	KEY_DEFAULT_CLASSID_FIELD_NAME	"__Key_TypeId__"
public static final String	KEY_DEFAULT_CONTENT_CLASSID_FIELD_NAME	"__Key_ContentTypeId__"
public static final String	KEY_DEFAULT_KEY_CLASSID_FIELD_NAME	"__Key_KeyTypeId__"

org.springframework.kafka.support.serializer.DelegatingByTopicSerialization<T extends Closeable>

Modifier and Type	Constant Field	Value
public static final String	CASE_SENSITIVE	"spring.kafka.value.serialization.bytopic.case.insensitive"
public static final String	KEY_SERIALIZATION_TOPIC_CONFIG	"spring.kafka.key.serialization.bytopic.config"
public static final String	KEY_SERIALIZATION_TOPIC_DEFAULT	"spring.kafka.key.serialization.bytopic.default"
public static final String	VALUE_SERIALIZATION_TOPIC_CONFIG	"spring.kafka.value.serialization.bytopic.config"
public static final String	VALUE_SERIALIZATION_TOPIC_DEFAULT	"spring.kafka.value.serialization.bytopic.default"

org.springframework.kafka.support.serializer.DelegatingSerializer

Modifier and Type	Constant Field	Value
public static final String	KEY_SERIALIZATION_SELECTOR	"spring.kafka.key.serialization.selector"
public static final String	KEY_SERIALIZATION_SELECTOR_CONFIG	"spring.kafka.key.serialization.selector.config"
public static final String	VALUE_SERIALIZATION_SELECTOR	"spring.kafka.serialization.selector"
public static final String	VALUE_SERIALIZATION_SELECTOR_CONFIG	"spring.kafka.serialization.selector.config"

org.springframework.kafka.support.serializer.ErrorHandlingDeserializer<T>

Modifier and Type	Constant Field	Value
public static final String	KEY_DESERIALIZER_CLASS	"spring.deserializer.key.delegate.class"
public static final String	KEY_FUNCTION	"spring.deserializer.key.function"
public static final String	VALUE_DESERIALIZER_CLASS	"spring.deserializer.value.delegate.class"
public static final String	VALUE_FUNCTION	"spring.deserializer.value.function"

org.springframework.kafka.support.serializer.JsonDeserializer<T>

Modifier and Type	Constant Field	Value
public static final String	KEY_DEFAULT_TYPE	"spring.json.key.default.type"
public static final String	KEY_TYPE_METHOD	"spring.json.key.type.method"
public static final String	REMOVE_TYPE_INFO_HEADERS	"spring.json.remove.type.headers"
public static final String	TRUSTED_PACKAGES	"spring.json.trusted.packages"
public static final String	TYPE_MAPPINGS	"spring.json.type.mapping"
public static final String	USE_TYPE_INFO_HEADERS	"spring.json.use.type.headers"
public static final String	VALUE_DEFAULT_TYPE	"spring.json.value.default.type"
public static final String	VALUE_TYPE_METHOD	"spring.json.value.type.method"

org.springframework.kafka.support.serializer.JsonSerializer<T>

Modifier and Type	Constant Field	Value
public static final String	ADD_TYPE_INFO_HEADERS	"spring.json.add.type.headers"
public static final String	TYPE_MAPPINGS	"spring.json.type.mapping"

org.springframework.kafka.support.serializer.ParseStringDeserializer<T>

Modifier and Type	Constant Field	Value
public static final String	KEY_PARSER	"spring.message.key.parser"
public static final String	VALUE_PARSER	"spring.message.value.parser"

org.springframework.kafka.support.serializer.SerializationUtils

Modifier and Type	Constant Field	Value
public static final String	DESERIALIZER_EXCEPTION_HEADER_PREFIX	"springDeserializerException"
public static final String	KEY_DESERIALIZER_EXCEPTION_HEADER	"springDeserializerExceptionKey"
public static final String	VALUE_DESERIALIZER_EXCEPTION_HEADER	"springDeserializerExceptionValue"

org.springframework.kafka.support.serializer.ToStringSerializer<T>

Modifier and Type	Constant Field	Value
public static final String	ADD_TYPE_INFO_HEADERS	"spring.message.add.type.headers"
public static final String	KEY_TYPE	"spring.message.key.type"
public static final String	VALUE_TYPE	"spring.message.value.type"

org.springframework.kafka.test.EmbeddedKafkaBroker

Modifier and Type	Constant Field	Value
public static final String	BEAN_NAME	"embeddedKafka"
public static final String	BROKER_LIST_PROPERTY	"spring.embedded.kafka.brokers.property"
public static final int	DEFAULT_ZK_CONNECTION_TIMEOUT	18000
public static final int	DEFAULT_ZK_SESSION_TIMEOUT	18000
public static final String	SPRING_EMBEDDED_KAFKA_BROKERS	"spring.embedded.kafka.brokers"
public static final String	SPRING_EMBEDDED_ZOOKEEPER_CONNECT	"spring.embedded.zookeeper.connect"

org.springframework.kafka.test.core.BrokerAddress

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_PORT	9092