Constant Field Values (Spring for Apache Kafka 3.0.8 API)

相关文章推荐

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"


    public static final
    
     String


    
     KAFKA_CONSUMER_BACK_OFF_MANAGER_BEAN_NAME


    "org.springframework.kafka.config.internalKafkaConsumerBackOffManager"


    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


    public static final float


    
     DEFAULT_NO_POLL_THRESHOLD


    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

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"


    public static final
    
     String


    
     DEFAULT_KAFKA_TEMPLATE_BEAN_NAME


    "defaultRetryTopicKafkaTemplate"


    public static final
    
     String


    
     DEFAULT_LISTENER_CONTAINER_FACTORY_BEAN_NAME


    "defaultRetryTopicListenerContainerFactory"


    public static final
    
     String


    
     DEFAULT_RETRY_TOPIC_CONFIG_SUPPORT_BEAN_NAME


    "org.springframework.kafka.retrytopic.internalRetryTopicConfigurationSupport"


    public static final
    
     String


    
     DEFAULT_SCHEDULER_WRAPPER_BEAN_NAME


    "defaultRetryTopicSchedulerWrapper"


    public static final
    
     String


    
     DESTINATION_TOPIC_RESOLVER_BEAN_NAME


    "org.springframework.kafka.retrytopic.internalDestinationTopicResolver"


    public static final
    
     String


    
     RETRY_TOPIC_CONFIGURER_BEAN_NAME


    "org.springframework.kafka.retrytopic.internalRetryTopicConfigurer"

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


    public static final
    
     String


    
     DEFAULT_RETRY_SUFFIX


    "-retry"


    public static final int


    
     NOT_SET

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.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"


    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-cause-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


    "kafka_messageKey"


    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


    
     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


    "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_KEY


    "kafka_receivedMessageKey"


    public static final
    
     String


    
     RECEIVED_PARTITION


    "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

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"


    "spring.embedded.kafka.brokers"


    public static final
    
     String


    
     SPRING_EMBEDDED_ZOOKEEPER_CONNECT


    "spring.embedded.zookeeper.connect"

org.springframework.kafka.test.junit. GlobalEmbeddedKafkaTestExecutionListener

Modifier and Type

Constant Field

Value


    public static final
    
     String


    
     BROKER_PROPERTIES_LOCATION_PROPERTY_NAME


    "spring.kafka.embedded.broker.properties.location"


    public static final
    
     String


    
     COUNT_PROPERTY_NAME


    "spring.kafka.embedded.count"


    public static final
    
     String


    
     LISTENER_ENABLED_PROPERTY_NAME


    "spring.kafka.global.embedded.enabled"


    public static final
    
     String


    
     PARTITIONS_PROPERTY_NAME


    "spring.kafka.embedded.partitions"


    public static final
    
     String


    
     PORTS_PROPERTY_NAME


    "spring.kafka.embedded.ports"


    public static final
    
     String


    
     TOPICS_PROPERTY_NAME


    "spring.kafka.embedded.topics"