Skip navigation links
A B C D E F G H I K L M O P R S T V W 

A

addTopics(String...) - Method in class org.springframework.kafka.test.EmbeddedKafkaBroker
Add topics to the existing broker(s) using the configured number of partitions.
addTopics(NewTopic...) - Method in class org.springframework.kafka.test.EmbeddedKafkaBroker
Add topics to the existing broker(s).
after() - Method in class org.springframework.kafka.test.rule.EmbeddedKafkaRule
 
afterPropertiesSet() - Method in class org.springframework.kafka.test.EmbeddedKafkaBroker
 
afterPropertiesSet() - Method in class org.springframework.kafka.test.rule.KafkaEmbedded
Deprecated.
 
apply(Statement, FrameworkMethod, Object) - Method in class org.springframework.kafka.test.rule.Log4j2LevelAdjuster
 

B

BEAN_NAME - Static variable in class org.springframework.kafka.test.EmbeddedKafkaBroker
 
BEAN_NAME - Static variable in class org.springframework.kafka.test.rule.KafkaEmbedded
Deprecated.
 
before() - Method in class org.springframework.kafka.test.rule.EmbeddedKafkaRule
 
bounce(BrokerAddress) - Method in class org.springframework.kafka.test.EmbeddedKafkaBroker
 
bounce(BrokerAddress) - Method in class org.springframework.kafka.test.rule.KafkaEmbedded
Deprecated.
 
bounce(int, boolean) - Method in class org.springframework.kafka.test.rule.KafkaEmbedded
Deprecated.
bounce(int) - Method in class org.springframework.kafka.test.rule.KafkaEmbedded
Deprecated.
BROKER_LIST_PROPERTY - Static variable in class org.springframework.kafka.test.EmbeddedKafkaBroker
Set the value of this property to a property name that should be set to the list of embedded broker addresses instead of "spring.embedded.kafka.brokers".
BrokerAddress - Class in org.springframework.kafka.test.core
Encapsulates the address of a Kafka broker.
BrokerAddress(String, int) - Constructor for class org.springframework.kafka.test.core.BrokerAddress
 
BrokerAddress(String) - Constructor for class org.springframework.kafka.test.core.BrokerAddress
 
BrokerAddress(BrokerEndPoint) - Constructor for class org.springframework.kafka.test.core.BrokerAddress
 
brokerProperties(Map<String, String>) - Method in class org.springframework.kafka.test.EmbeddedKafkaBroker
Specify the properties to configure Kafka Broker before start, e.g.
brokerProperties(Map<String, String>) - Method in class org.springframework.kafka.test.rule.EmbeddedKafkaRule
Specify the properties to configure Kafka Broker before start, e.g.
brokerProperties(Map<String, String>) - Method in class org.springframework.kafka.test.rule.KafkaEmbedded
Deprecated.
Specify the properties to configure Kafka Broker before start, e.g.
brokerProperty(String, Object) - Method in class org.springframework.kafka.test.EmbeddedKafkaBroker
Specify a broker property.
brokerProperty(String, Object) - Method in class org.springframework.kafka.test.rule.EmbeddedKafkaRule
Specify a broker property.
brokerProperty(String, Object) - Method in class org.springframework.kafka.test.rule.KafkaEmbedded
Deprecated.
Specify a broker property.

C

categories(String...) - Method in class org.springframework.kafka.test.rule.Log4j2LevelAdjuster
Specify the categories for logging level adjusting configured before.
categories(boolean, String...) - Method in class org.springframework.kafka.test.rule.Log4j2LevelAdjuster
Specify the categories for logging level adjusting configured before.
classes(Class<?>...) - Method in class org.springframework.kafka.test.rule.Log4j2LevelAdjuster
Specify the classes for logging level adjusting configured before.
classes(boolean, Class<?>...) - Method in class org.springframework.kafka.test.rule.Log4j2LevelAdjuster
Specify the classes for logging level adjusting configured before.
consumeFromAllEmbeddedTopics(Consumer<?, ?>) - Method in class org.springframework.kafka.test.EmbeddedKafkaBroker
Subscribe a consumer to all the embedded topics.
consumeFromAllEmbeddedTopics(Consumer<?, ?>) - Method in class org.springframework.kafka.test.rule.KafkaEmbedded
Deprecated.
Subscribe a consumer to all the embedded topics.
consumeFromAnEmbeddedTopic(Consumer<?, ?>, String) - Method in class org.springframework.kafka.test.EmbeddedKafkaBroker
Subscribe a consumer to one of the embedded topics.
consumeFromAnEmbeddedTopic(Consumer<?, ?>, String) - Method in class org.springframework.kafka.test.rule.KafkaEmbedded
Deprecated.
Subscribe a consumer to one of the embedded topics.
consumeFromEmbeddedTopics(Consumer<?, ?>, String...) - Method in class org.springframework.kafka.test.EmbeddedKafkaBroker
Subscribe a consumer to one or more of the embedded topics.
consumeFromEmbeddedTopics(Consumer<?, ?>, String...) - Method in class org.springframework.kafka.test.rule.KafkaEmbedded
Deprecated.
Subscribe a consumer to one or more of the embedded topics.
consumerProps(String, String, KafkaEmbedded) - Static method in class org.springframework.kafka.test.utils.KafkaTestUtils
consumerProps(String, String, EmbeddedKafkaBroker) - Static method in class org.springframework.kafka.test.utils.KafkaTestUtils
Set up test properties for an <Integer, String> consumer.
consumerProps(String, String, String) - Static method in class org.springframework.kafka.test.utils.KafkaTestUtils
Set up test properties for an <Integer, String> consumer.
ConsumerRecordKeyCondition(K) - Constructor for class org.springframework.kafka.test.assertj.KafkaConditions.ConsumerRecordKeyCondition
 
ConsumerRecordKeyMatcher(K) - Constructor for class org.springframework.kafka.test.hamcrest.KafkaMatchers.ConsumerRecordKeyMatcher
 
ConsumerRecordPartitionCondition(int) - Constructor for class org.springframework.kafka.test.assertj.KafkaConditions.ConsumerRecordPartitionCondition
 
ConsumerRecordPartitionMatcher(int) - Constructor for class org.springframework.kafka.test.hamcrest.KafkaMatchers.ConsumerRecordPartitionMatcher
 
ConsumerRecordTimestampCondition(TimestampType, long) - Constructor for class org.springframework.kafka.test.assertj.KafkaConditions.ConsumerRecordTimestampCondition
 
ConsumerRecordTimestampMatcher(TimestampType, long) - Constructor for class org.springframework.kafka.test.hamcrest.KafkaMatchers.ConsumerRecordTimestampMatcher
 
ConsumerRecordValueCondition(V) - Constructor for class org.springframework.kafka.test.assertj.KafkaConditions.ConsumerRecordValueCondition
 
ConsumerRecordValueMatcher(V) - Constructor for class org.springframework.kafka.test.hamcrest.KafkaMatchers.ConsumerRecordValueMatcher
 
ContainerTestUtils - Class in org.springframework.kafka.test.utils
Utilities for testing listener containers.
createBrokerProperties(int) - Method in class org.springframework.kafka.test.rule.KafkaEmbedded
Deprecated.
 

D

debug() - Static method in class org.springframework.kafka.test.rule.Log4j2LevelAdjuster
The factory to produce Log4j2LevelAdjuster instances for Level.DEBUG logging with the org.springframework.integration as default category.
DEFAULT_PORT - Static variable in class org.springframework.kafka.test.core.BrokerAddress
 
describeTo(Description) - Method in class org.springframework.kafka.test.hamcrest.KafkaMatchers.ConsumerRecordKeyMatcher
 
describeTo(Description) - Method in class org.springframework.kafka.test.hamcrest.KafkaMatchers.ConsumerRecordPartitionMatcher
 
describeTo(Description) - Method in class org.springframework.kafka.test.hamcrest.KafkaMatchers.ConsumerRecordTimestampMatcher
 
describeTo(Description) - Method in class org.springframework.kafka.test.hamcrest.KafkaMatchers.ConsumerRecordValueMatcher
 
destroy() - Method in class org.springframework.kafka.test.EmbeddedKafkaBroker
 
destroy() - Method in class org.springframework.kafka.test.rule.KafkaEmbedded
Deprecated.
 
doWithAdmin(Consumer<AdminClient>) - Method in class org.springframework.kafka.test.EmbeddedKafkaBroker
Create an AdminClient; invoke the callback and reliably close the admin.
doWithAdmin(Consumer<AdminClient>) - Method in class org.springframework.kafka.test.rule.KafkaEmbedded
Deprecated.
Create an AdminClient; invoke the callback and reliably close the admin.

E

EmbeddedKafka - Annotation Type in org.springframework.kafka.test.context
Annotation that can be specified on a test class that runs Spring Kafka based tests.
EmbeddedKafkaBroker - Class in org.springframework.kafka.test
An embedded Kafka Broker(s) and Zookeeper manager.
EmbeddedKafkaBroker(int) - Constructor for class org.springframework.kafka.test.EmbeddedKafkaBroker
 
EmbeddedKafkaBroker(int, boolean, String...) - Constructor for class org.springframework.kafka.test.EmbeddedKafkaBroker
Create embedded Kafka brokers.
EmbeddedKafkaBroker(int, boolean, int, String...) - Constructor for class org.springframework.kafka.test.EmbeddedKafkaBroker
Create embedded Kafka brokers listening on random ports.
EmbeddedKafkaRule - Class in org.springframework.kafka.test.rule
A TestRule wrapper around an EmbeddedKafkaBroker.
EmbeddedKafkaRule(int) - Constructor for class org.springframework.kafka.test.rule.EmbeddedKafkaRule
 
EmbeddedKafkaRule(int, boolean, String...) - Constructor for class org.springframework.kafka.test.rule.EmbeddedKafkaRule
Create embedded Kafka brokers.
EmbeddedKafkaRule(int, boolean, int, String...) - Constructor for class org.springframework.kafka.test.rule.EmbeddedKafkaRule
Create embedded Kafka brokers listening on random ports.
equals(Object) - Method in class org.springframework.kafka.test.core.BrokerAddress
 

F

forLevel(Level) - Static method in class org.springframework.kafka.test.rule.Log4j2LevelAdjuster
The factory to produce Log4j2LevelAdjuster instances for arbitrary logging Level with the org.springframework.integration as default category.
fromAddress(String) - Static method in class org.springframework.kafka.test.core.BrokerAddress
 

G

getBrokerAddress(int) - Method in class org.springframework.kafka.test.EmbeddedKafkaBroker
 
getBrokerAddress(int) - Method in class org.springframework.kafka.test.rule.KafkaEmbedded
Deprecated.
 
getBrokerAddresses() - Method in class org.springframework.kafka.test.EmbeddedKafkaBroker
 
getBrokerAddresses() - Method in class org.springframework.kafka.test.rule.KafkaEmbedded
Deprecated.
 
getBrokerAddresses() - Method in interface org.springframework.kafka.test.rule.KafkaRule
Deprecated.
 
getBrokersAsString() - Method in class org.springframework.kafka.test.EmbeddedKafkaBroker
 
getBrokersAsString() - Method in class org.springframework.kafka.test.rule.KafkaEmbedded
Deprecated.
 
getBrokersAsString() - Method in interface org.springframework.kafka.test.rule.KafkaRule
Deprecated.
 
getEmbeddedKafka() - Method in class org.springframework.kafka.test.rule.EmbeddedKafkaRule
Return an underlying delegator EmbeddedKafkaBroker instance.
getHost() - Method in class org.springframework.kafka.test.core.BrokerAddress
 
getKafkaServer(int) - Method in class org.springframework.kafka.test.EmbeddedKafkaBroker
 
getKafkaServer(int) - Method in class org.springframework.kafka.test.rule.KafkaEmbedded
Deprecated.
 
getKafkaServers() - Method in class org.springframework.kafka.test.EmbeddedKafkaBroker
 
getKafkaServers() - Method in class org.springframework.kafka.test.rule.KafkaEmbedded
Deprecated.
 
getKafkaServers() - Method in interface org.springframework.kafka.test.rule.KafkaRule
Deprecated.
 
getPartitionsPerTopic() - Method in class org.springframework.kafka.test.EmbeddedKafkaBroker
 
getPartitionsPerTopic() - Method in class org.springframework.kafka.test.rule.KafkaEmbedded
Deprecated.
 
getPartitionsPerTopic() - Method in interface org.springframework.kafka.test.rule.KafkaRule
Deprecated.
 
getPort() - Method in class org.springframework.kafka.test.core.BrokerAddress
 
getPropertyValue(Object, String) - Static method in class org.springframework.kafka.test.utils.KafkaTestUtils
Uses nested DirectFieldAccessors to obtain a property using dotted notation to traverse fields; e.g.
getPropertyValue(Object, String, Class<T>) - Static method in class org.springframework.kafka.test.utils.KafkaTestUtils
getRecords(Consumer<K, V>) - Static method in class org.springframework.kafka.test.utils.KafkaTestUtils
Poll the consumer for records.
getRecords(Consumer<K, V>, long) - Static method in class org.springframework.kafka.test.utils.KafkaTestUtils
Poll the consumer for records.
getSingleRecord(Consumer<K, V>, String) - Static method in class org.springframework.kafka.test.utils.KafkaTestUtils
Poll the consumer, expecting a single record for the specified topic.
getSingleRecord(Consumer<K, V>, String, long) - Static method in class org.springframework.kafka.test.utils.KafkaTestUtils
Poll the consumer, expecting a single record for the specified topic.
getTopics() - Method in class org.springframework.kafka.test.EmbeddedKafkaBroker
 
getTopics() - Method in class org.springframework.kafka.test.rule.KafkaEmbedded
Deprecated.
 
getZkClient() - Method in class org.springframework.kafka.test.EmbeddedKafkaBroker
 
getZkClient() - Method in class org.springframework.kafka.test.rule.KafkaEmbedded
Deprecated.
 
getZkClient() - Method in interface org.springframework.kafka.test.rule.KafkaRule
Deprecated.
 
getZookeeper() - Method in class org.springframework.kafka.test.EmbeddedKafkaBroker
 
getZookeeper() - Method in class org.springframework.kafka.test.rule.KafkaEmbedded
Deprecated.
 
getZookeeperConnectionString() - Method in class org.springframework.kafka.test.EmbeddedKafkaBroker
 
getZookeeperConnectionString() - Method in class org.springframework.kafka.test.rule.KafkaEmbedded
Deprecated.
 
getZookeeperConnectionString() - Method in interface org.springframework.kafka.test.rule.KafkaRule
Deprecated.
 

H

hashCode() - Method in class org.springframework.kafka.test.core.BrokerAddress
 
hasKey(K) - Static method in class org.springframework.kafka.test.hamcrest.KafkaMatchers
 
hasPartition(int) - Static method in class org.springframework.kafka.test.hamcrest.KafkaMatchers
 
hasTimestamp(long) - Static method in class org.springframework.kafka.test.hamcrest.KafkaMatchers
Matcher testing the timestamp of a ConsumerRecord asssuming the topic has been set with CreateTime.
hasTimestamp(TimestampType, long) - Static method in class org.springframework.kafka.test.hamcrest.KafkaMatchers
Matcher testing the timestamp of a ConsumerRecord
hasValue(V) - Static method in class org.springframework.kafka.test.hamcrest.KafkaMatchers
 

I

info() - Static method in class org.springframework.kafka.test.rule.Log4j2LevelAdjuster
The factory to produce Log4j2LevelAdjuster instances for Level.INFO logging with the org.springframework.integration as default category.
isEmbedded() - Method in class org.springframework.kafka.test.rule.KafkaEmbedded
Deprecated.
 
isEmbedded() - Method in interface org.springframework.kafka.test.rule.KafkaRule
Deprecated.
 

K

KafkaConditions - Class in org.springframework.kafka.test.assertj
AssertJ custom Conditions.
KafkaConditions.ConsumerRecordKeyCondition<K> - Class in org.springframework.kafka.test.assertj
 
KafkaConditions.ConsumerRecordPartitionCondition - Class in org.springframework.kafka.test.assertj
 
KafkaConditions.ConsumerRecordTimestampCondition - Class in org.springframework.kafka.test.assertj
 
KafkaConditions.ConsumerRecordValueCondition<V> - Class in org.springframework.kafka.test.assertj
 
KafkaEmbedded - Class in org.springframework.kafka.test.rule
Deprecated.
since 2.2 in favor of EmbeddedKafkaRule
KafkaEmbedded(int) - Constructor for class org.springframework.kafka.test.rule.KafkaEmbedded
Deprecated.
 
KafkaEmbedded(int, boolean, String...) - Constructor for class org.springframework.kafka.test.rule.KafkaEmbedded
Deprecated.
Create embedded Kafka brokers.
KafkaEmbedded(int, boolean, int, String...) - Constructor for class org.springframework.kafka.test.rule.KafkaEmbedded
Deprecated.
Create embedded Kafka brokers listening on random ports.
KafkaMatchers - Class in org.springframework.kafka.test.hamcrest
Hamcrest Matchers utilities.
KafkaMatchers.ConsumerRecordKeyMatcher<K> - Class in org.springframework.kafka.test.hamcrest
 
KafkaMatchers.ConsumerRecordPartitionMatcher - Class in org.springframework.kafka.test.hamcrest
 
KafkaMatchers.ConsumerRecordTimestampMatcher - Class in org.springframework.kafka.test.hamcrest
 
KafkaMatchers.ConsumerRecordValueMatcher<V> - Class in org.springframework.kafka.test.hamcrest
 
kafkaPorts(int...) - Method in class org.springframework.kafka.test.EmbeddedKafkaBroker
Set explicit ports on which the kafka brokers will listen.
kafkaPorts(int...) - Method in class org.springframework.kafka.test.rule.EmbeddedKafkaRule
Set explicit ports on which the kafka brokers will listen.
KafkaRule - Interface in org.springframework.kafka.test.rule
Deprecated.
since 2.2 in favor of EmbeddedKafkaRule
KafkaTestUtils - Class in org.springframework.kafka.test.utils
Kafka testing utilities.
key(K) - Static method in class org.springframework.kafka.test.assertj.KafkaConditions
 

L

Log4j2LevelAdjuster - Class in org.springframework.kafka.test.rule
A JUnit method Rule that changes the Log4J 2 logger level for a set of classes or packages while a test method is running.

M

matches(ConsumerRecord<K, ?>) - Method in class org.springframework.kafka.test.assertj.KafkaConditions.ConsumerRecordKeyCondition
 
matches(ConsumerRecord<?, ?>) - Method in class org.springframework.kafka.test.assertj.KafkaConditions.ConsumerRecordPartitionCondition
 
matches(ConsumerRecord<?, ?>) - Method in class org.springframework.kafka.test.assertj.KafkaConditions.ConsumerRecordTimestampCondition
 
matches(ConsumerRecord<?, V>) - Method in class org.springframework.kafka.test.assertj.KafkaConditions.ConsumerRecordValueCondition
 
matches(Object, Description) - Method in class org.springframework.kafka.test.hamcrest.KafkaMatchers.ConsumerRecordKeyMatcher
 
matches(Object, Description) - Method in class org.springframework.kafka.test.hamcrest.KafkaMatchers.ConsumerRecordPartitionMatcher
 
matches(Object, Description) - Method in class org.springframework.kafka.test.hamcrest.KafkaMatchers.ConsumerRecordTimestampMatcher
 
matches(Object, Description) - Method in class org.springframework.kafka.test.hamcrest.KafkaMatchers.ConsumerRecordValueMatcher
 
METADATA_PROPAGATION_TIMEOUT - Static variable in class org.springframework.kafka.test.rule.KafkaEmbedded
Deprecated.
 

O

org.springframework.kafka.test - package org.springframework.kafka.test
 
org.springframework.kafka.test.assertj - package org.springframework.kafka.test.assertj
 
org.springframework.kafka.test.context - package org.springframework.kafka.test.context
 
org.springframework.kafka.test.core - package org.springframework.kafka.test.core
 
org.springframework.kafka.test.hamcrest - package org.springframework.kafka.test.hamcrest
 
org.springframework.kafka.test.rule - package org.springframework.kafka.test.rule
 
org.springframework.kafka.test.utils - package org.springframework.kafka.test.utils
 

P

partition(int) - Static method in class org.springframework.kafka.test.assertj.KafkaConditions
 
producerProps(KafkaEmbedded) - Static method in class org.springframework.kafka.test.utils.KafkaTestUtils
Deprecated.
producerProps(EmbeddedKafkaBroker) - Static method in class org.springframework.kafka.test.utils.KafkaTestUtils
Set up test properties for an <Integer, String> producer.

R

restart(int) - Method in class org.springframework.kafka.test.EmbeddedKafkaBroker
 
restart(int) - Method in class org.springframework.kafka.test.rule.KafkaEmbedded
Deprecated.
 

S

senderProps(String) - Static method in class org.springframework.kafka.test.utils.KafkaTestUtils
Set up test properties for an <Integer, String> producer.
setAdminTimeout(int) - Method in class org.springframework.kafka.test.EmbeddedKafkaBroker
Set the timeout in seconds for admin operations (e.g.
setKafkaPorts(int...) - Method in class org.springframework.kafka.test.rule.KafkaEmbedded
Deprecated.
Set explicit ports on which the kafka brokers will listen.
SPRING_EMBEDDED_KAFKA_BROKERS - Static variable in class org.springframework.kafka.test.EmbeddedKafkaBroker
 
SPRING_EMBEDDED_KAFKA_BROKERS - Static variable in class org.springframework.kafka.test.rule.KafkaEmbedded
Deprecated.
 
SPRING_EMBEDDED_ZOOKEEPER_CONNECT - Static variable in class org.springframework.kafka.test.EmbeddedKafkaBroker
 
SPRING_EMBEDDED_ZOOKEEPER_CONNECT - Static variable in class org.springframework.kafka.test.rule.KafkaEmbedded
Deprecated.
 
startZookeeper() - Method in class org.springframework.kafka.test.rule.KafkaEmbedded
Deprecated.
 

T

timestamp(long) - Static method in class org.springframework.kafka.test.assertj.KafkaConditions
 
timestamp(TimestampType, long) - Static method in class org.springframework.kafka.test.assertj.KafkaConditions
 
toString() - Method in class org.springframework.kafka.test.core.BrokerAddress
 
trace() - Static method in class org.springframework.kafka.test.rule.Log4j2LevelAdjuster
The factory to produce Log4j2LevelAdjuster instances for Level.TRACE logging with the org.springframework.integration as default category.

V

value(V) - Static method in class org.springframework.kafka.test.assertj.KafkaConditions
 

W

waitForAssignment(Object, int) - Static method in class org.springframework.kafka.test.utils.ContainerTestUtils
Wait until the container has the required number of assigned partitions.
waitUntilSynced(String, int) - Method in class org.springframework.kafka.test.rule.KafkaEmbedded
Deprecated.
A B C D E F G H I K L M O P R S T V W 
Skip navigation links