Constant Field Values

Contents

• org.springframework.*

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_KSTREAM_BUILDER_BEAN_NAME	"defaultKStreamBuilder"
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.adapter.AbstractRetryingMessageListenerAdapter<K,V,T>

Modifier and Type	Constant Field	Value
public static final java.lang.String	CONTEXT_ACKNOWLEDGMENT	"acknowledgment"
public static final java.lang.String	CONTEXT_RECORD	"record"

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	MESSAGE_KEY	"kafka_messageKey"
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	RECEIVED_MESSAGE_KEY	"kafka_receivedMessageKey"
public static final java.lang.String	RECEIVED_PARTITION_ID	"kafka_receivedPartitionId"
public static final java.lang.String	RECEIVED_TOPIC	"kafka_receivedTopic"
public static final java.lang.String	TOPIC	"kafka_topic"

org.springframework.kafka.test.core.BrokerAddress

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

org.springframework.kafka.test.rule.KafkaEmbedded

Modifier and Type	Constant Field	Value
public static final long	METADATA_PROPAGATION_TIMEOUT	10000L
public static final java.lang.String	SPRING_EMBEDDED_KAFKA_BROKERS	"spring.embedded.kafka.brokers"