Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
DEFAULT_KAFKA_LISTENER_CONTAINER_FACTORY_BEAN_NAME |
"kafkaListenerContainerFactory" |
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" |
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" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
DEFAULT_PHASE |
2147483547 |
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" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
KAFKA_CLIENT_CONTEXT_NAME |
"KafkaClient" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
JSON_TYPES |
"spring_json_header_types" |
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 |
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 |
PARTITION_ID |
"kafka_partitionId" |
public static final java.lang.String |
RAW_DATA |
"kafka_data" |
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 |
TIMESTAMP |
"kafka_timestamp" |
public static final java.lang.String |
TIMESTAMP_TYPE |
"kafka_timestampType" |
public static final java.lang.String |
TOPIC |
"kafka_topic" |
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__" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
DEFAULT_KEY_TYPE |
"spring.json.key.default.type" |
public static final java.lang.String |
DEFAULT_VALUE_TYPE |
"spring.json.default.value.type" |
public static final java.lang.String |
TRUSTED_PACKAGES |
"spring.json.trusted.packages" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
ADD_TYPE_INFO_HEADERS |
"spring.json.add.type.headers" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
DEFAULT_PORT |
9092 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
BEAN_NAME |
"kafkaEmbedded" |
public static final long |
METADATA_PROPAGATION_TIMEOUT |
10000L |
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" |