Constant Field Values
Contents
org.springframework.*
-
org.springframework.kafka.annotation.KafkaListenerAnnotationBeanPostProcessor<K,V> Modifier and Type Constant Field Value public static final java.lang.String
DEFAULT_KAFKA_LISTENER_CONTAINER_FACTORY_BEAN_NAME
"kafkaListenerContainerFactory"
-
org.springframework.kafka.annotation.KafkaStreamsDefaultConfiguration Modifier and Type Constant Field Value public static final java.lang.String
DEFAULT_STREAMS_BUILDER_BEAN_NAME
"defaultKafkaStreamsBuilder"
public static final java.lang.String
DEFAULT_STREAMS_CONFIG_BEAN_NAME
"defaultKafkaStreamsConfig"
-
org.springframework.kafka.config.KafkaListenerConfigUtils Modifier and Type Constant Field Value public static final java.lang.String
KAFKA_LISTENER_ANNOTATION_PROCESSOR_BEAN_NAME
"org.springframework.kafka.config.internalKafkaListenerAnnotationProcessor"
public static final java.lang.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 java.lang.String
CONTEXT_ACKNOWLEDGMENT
"acknowledgment"
public static final java.lang.String
CONTEXT_CONSUMER
"consumer"
public static final java.lang.String
CONTEXT_RECORD
"record"
-
org.springframework.kafka.requestreply.AggregatingReplyingKafkaTemplate<K,V,R> Modifier and Type Constant Field Value public static final java.lang.String
AGGREGATED_RESULTS_TOPIC
"aggregatedResults"
public static final java.lang.String
PARTIAL_RESULTS_AFTER_TIMEOUT_TOPIC
"partialResultsAfterTimeout"
-
org.springframework.kafka.retrytopic.RetryTopicConstants Modifier and Type Constant Field Value public static final java.lang.String
DEFAULT_DLT_SUFFIX
"-dlt"
public static final int
DEFAULT_MAX_ATTEMPTS
3
public static final java.lang.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 java.lang.String
DEFAULT_HEADER_ATTEMPTS
"retry_topic-attempts"
public static final java.lang.String
DEFAULT_HEADER_BACKOFF_TIMESTAMP
"retry_topic-backoff-timestamp"
public static final java.lang.String
DEFAULT_HEADER_ORIGINAL_TIMESTAMP
"retry_topic-original-timestamp"
-
org.springframework.kafka.retrytopic.RetryTopicInternalBeanNames Modifier and Type Constant Field Value public static final java.lang.String
DEFAULT_KAFKA_TEMPLATE_BEAN_NAME
"retryTopicDefaultKafkaTemplate"
public static final java.lang.String
INTERNAL_BACKOFF_CLOCK_BEAN_NAME
"internalBackOffClock"
public static final java.lang.String
RETRY_TOPIC_BOOTSTRAPPER
"internalRetryTopicBootstrapper"
public static final java.lang.String
RETRY_TOPIC_CONFIGURER
"internalRetryTopicConfigurer"
-
org.springframework.kafka.security.jaas.KafkaJaasLoginModuleInitializer Modifier and Type Constant Field Value public static final java.lang.String
KAFKA_CLIENT_CONTEXT_NAME
"KafkaClient"
-
org.springframework.kafka.streams.RecoveringDeserializationExceptionHandler Modifier and Type Constant Field Value public static final java.lang.String
KSTREAM_DESERIALIZATION_RECOVERER
"spring.deserialization.recoverer"
-
org.springframework.kafka.support.DefaultKafkaHeaderMapper Modifier and Type Constant Field Value public static final java.lang.String
JSON_TYPES
"spring_json_header_types"
-
org.springframework.kafka.support.KafkaHeaders Modifier and Type Constant Field Value public static final java.lang.String
ACKNOWLEDGMENT
"kafka_acknowledgment"
public static final java.lang.String
BATCH_CONVERTED_HEADERS
"kafka_batchConvertedHeaders"
public static final java.lang.String
CONSUMER
"kafka_consumer"
public static final java.lang.String
CORRELATION_ID
"kafka_correlationId"
public static final java.lang.String
DELIVERY_ATTEMPT
"kafka_deliveryAttempt"
public static final java.lang.String
DLT_EXCEPTION_FQCN
"kafka_dlt-exception-fqcn"
public static final java.lang.String
DLT_EXCEPTION_MESSAGE
"kafka_dlt-exception-message"
public static final java.lang.String
DLT_EXCEPTION_STACKTRACE
"kafka_dlt-exception-stacktrace"
public static final java.lang.String
DLT_KEY_EXCEPTION_FQCN
"kafka_dlt-key-exception-fqcn"
public static final java.lang.String
DLT_KEY_EXCEPTION_MESSAGE
"kafka_dlt-key-exception-message"
public static final java.lang.String
DLT_KEY_EXCEPTION_STACKTRACE
"kafka_dlt-key-exception-stacktrace"
public static final java.lang.String
DLT_ORIGINAL_OFFSET
"kafka_dlt-original-offset"
public static final java.lang.String
DLT_ORIGINAL_PARTITION
"kafka_dlt-original-partition"
public static final java.lang.String
DLT_ORIGINAL_TIMESTAMP
"kafka_dlt-original-timestamp"
public static final java.lang.String
DLT_ORIGINAL_TIMESTAMP_TYPE
"kafka_dlt-original-timestamp-type"
public static final java.lang.String
DLT_ORIGINAL_TOPIC
"kafka_dlt-original-topic"
public static final java.lang.String
EXCEPTION_FQCN
"kafka_exception-fqcn"
public static final java.lang.String
EXCEPTION_MESSAGE
"kafka_exception-message"
public static final java.lang.String
EXCEPTION_STACKTRACE
"kafka_exception-stacktrace"
public static final java.lang.String
GROUP_ID
"kafka_groupId"
public static final java.lang.String
KEY_EXCEPTION_FQCN
"kafka_key-exception-fqcn"
public static final java.lang.String
KEY_EXCEPTION_MESSAGE
"kafka_key-exception-message"
public static final java.lang.String
KEY_EXCEPTION_STACKTRACE
"kafka_key-exception-stacktrace"
public static final java.lang.String
MESSAGE_KEY
"kafka_messageKey"
public static final java.lang.String
NATIVE_HEADERS
"kafka_nativeHeaders"
public static final java.lang.String
OFFSET
"kafka_offset"
public static final java.lang.String
ORIGINAL_OFFSET
"kafka_original-offset"
public static final java.lang.String
ORIGINAL_PARTITION
"kafka_original-partition"
public static final java.lang.String
ORIGINAL_TIMESTAMP
"kafka_original-timestamp"
public static final java.lang.String
ORIGINAL_TIMESTAMP_TYPE
"kafka_original-timestamp-type"
public static final java.lang.String
ORIGINAL_TOPIC
"kafka_original-topic"
public static final java.lang.String
PARTITION_ID
"kafka_partitionId"
public static final java.lang.String
PREFIX
"kafka_"
public static final java.lang.String
RAW_DATA
"kafka_data"
public static final java.lang.String
RECEIVED
"kafka_received"
public static final java.lang.String
RECEIVED_MESSAGE_KEY
"kafka_receivedMessageKey"
public static final java.lang.String
RECEIVED_PARTITION_ID
"kafka_receivedPartitionId"
public static final java.lang.String
RECEIVED_TIMESTAMP
"kafka_receivedTimestamp"
public static final java.lang.String
RECEIVED_TOPIC
"kafka_receivedTopic"
public static final java.lang.String
RECORD_METADATA
"kafka_recordMetadata"
public static final java.lang.String
REPLY_PARTITION
"kafka_replyPartition"
public static final java.lang.String
REPLY_TOPIC
"kafka_replyTopic"
public static final java.lang.String
TIMESTAMP
"kafka_timestamp"
public static final java.lang.String
TIMESTAMP_TYPE
"kafka_timestampType"
public static final java.lang.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.converter.AbstractJavaTypeMapper Modifier and Type Constant Field Value public static final java.lang.String
DEFAULT_CLASSID_FIELD_NAME
"__TypeId__"
public static final java.lang.String
DEFAULT_CONTENT_CLASSID_FIELD_NAME
"__ContentTypeId__"
public static final java.lang.String
DEFAULT_KEY_CLASSID_FIELD_NAME
"__KeyTypeId__"
public static final java.lang.String
KEY_DEFAULT_CLASSID_FIELD_NAME
"__Key_TypeId__"
public static final java.lang.String
KEY_DEFAULT_CONTENT_CLASSID_FIELD_NAME
"__Key_ContentTypeId__"
public static final java.lang.String
KEY_DEFAULT_KEY_CLASSID_FIELD_NAME
"__Key_KeyTypeId__"
-
org.springframework.kafka.support.serializer.DelegatingSerializer Modifier and Type Constant Field Value public static final java.lang.String
KEY_SERIALIZATION_SELECTOR
"spring.kafka.key.serialization.selector"
public static final java.lang.String
KEY_SERIALIZATION_SELECTOR_CONFIG
"spring.kafka.key.serialization.selector.config"
public static final java.lang.String
VALUE_SERIALIZATION_SELECTOR
"spring.kafka.serialization.selector"
public static final java.lang.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 java.lang.String
KEY_DESERIALIZER_CLASS
"spring.deserializer.key.delegate.class"
public static final java.lang.String
KEY_DESERIALIZER_EXCEPTION_HEADER
"springDeserializerExceptionKey"
public static final java.lang.String
KEY_DESERIALIZER_EXCEPTION_HEADER_PREFIX
"springDeserializerException"
public static final java.lang.String
KEY_FUNCTION
"spring.deserializer.key.function"
public static final java.lang.String
VALUE_DESERIALIZER_CLASS
"spring.deserializer.value.delegate.class"
public static final java.lang.String
VALUE_DESERIALIZER_EXCEPTION_HEADER
"springDeserializerExceptionValue"
public static final java.lang.String
VALUE_FUNCTION
"spring.deserializer.value.function"
-
org.springframework.kafka.support.serializer.JsonDeserializer<T> Modifier and Type Constant Field Value public static final java.lang.String
KEY_DEFAULT_TYPE
"spring.json.key.default.type"
public static final java.lang.String
KEY_TYPE_METHOD
"spring.json.key.type.method"
public static final java.lang.String
REMOVE_TYPE_INFO_HEADERS
"spring.json.remove.type.headers"
public static final java.lang.String
TRUSTED_PACKAGES
"spring.json.trusted.packages"
public static final java.lang.String
TYPE_MAPPINGS
"spring.json.type.mapping"
public static final java.lang.String
USE_TYPE_INFO_HEADERS
"spring.json.use.type.headers"
public static final java.lang.String
VALUE_DEFAULT_TYPE
"spring.json.value.default.type"
public static final java.lang.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 java.lang.String
ADD_TYPE_INFO_HEADERS
"spring.json.add.type.headers"
public static final java.lang.String
TYPE_MAPPINGS
"spring.json.type.mapping"
-
org.springframework.kafka.support.serializer.ParseStringDeserializer<T> Modifier and Type Constant Field Value public static final java.lang.String
KEY_PARSER
"spring.message.key.parser"
public static final java.lang.String
VALUE_PARSER
"spring.message.value.parser"
-
org.springframework.kafka.support.serializer.ToStringSerializer<T> Modifier and Type Constant Field Value public static final java.lang.String
ADD_TYPE_INFO_HEADERS
"spring.message.add.type.headers"
public static final java.lang.String
KEY_TYPE
"spring.message.key.type"
public static final java.lang.String
VALUE_TYPE
"spring.message.value.type"
-
org.springframework.kafka.test.EmbeddedKafkaBroker Modifier and Type Constant Field Value public static final java.lang.String
BEAN_NAME
"embeddedKafka"
public static final java.lang.String
BROKER_LIST_PROPERTY
"spring.embedded.kafka.brokers.property"
public static final int
DEFAULT_ZK_CONNECTION_TIMEOUT
6000
public static final int
DEFAULT_ZK_SESSION_TIMEOUT
6000
public static final java.lang.String
SPRING_EMBEDDED_KAFKA_BROKERS
"spring.embedded.kafka.brokers"
public static final java.lang.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