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

A

after() - Method in class org.springframework.kafka.test.rule.KafkaEmbedded
 
afterPropertiesSet() - Method in class org.springframework.kafka.test.rule.KafkaEmbedded
 
apply(Statement, FrameworkMethod, Object) - Method in class org.springframework.kafka.test.rule.Log4jLevelAdjuster
 

B

BEAN_NAME - Static variable in class org.springframework.kafka.test.rule.KafkaEmbedded
 
before() - Method in class org.springframework.kafka.test.rule.KafkaEmbedded
 
bounce(BrokerAddress) - Method in class org.springframework.kafka.test.rule.KafkaEmbedded
 
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.
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.rule.KafkaEmbedded
Specify the properties to configure Kafka Broker before start, e.g.
brokerProperty(String, Object) - Method in class org.springframework.kafka.test.rule.KafkaEmbedded
Specify a broker property.

C

consumeFromAllEmbeddedTopics(Consumer<?, ?>) - Method in class org.springframework.kafka.test.rule.KafkaEmbedded
Subscribe a consumer to all the embedded topics.
consumeFromAnEmbeddedTopic(Consumer<?, ?>, String) - Method in class org.springframework.kafka.test.rule.KafkaEmbedded
Subscribe a consumer to one of the embedded topics.
consumeFromEmbeddedTopics(Consumer<?, ?>, String...) - Method in class org.springframework.kafka.test.rule.KafkaEmbedded
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
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
 

D

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.rule.KafkaEmbedded
 

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.
equals(Object) - Method in class org.springframework.kafka.test.core.BrokerAddress
 

F

fromAddress(String) - Static method in class org.springframework.kafka.test.core.BrokerAddress
 

G

getBrokerAddress(int) - Method in class org.springframework.kafka.test.rule.KafkaEmbedded
 
getBrokerAddresses() - Method in class org.springframework.kafka.test.rule.KafkaEmbedded
 
getBrokerAddresses() - Method in interface org.springframework.kafka.test.rule.KafkaRule
 
getBrokersAsString() - Method in class org.springframework.kafka.test.rule.KafkaEmbedded
 
getBrokersAsString() - Method in interface org.springframework.kafka.test.rule.KafkaRule
 
getHost() - Method in class org.springframework.kafka.test.core.BrokerAddress
 
getKafkaServer(int) - Method in class org.springframework.kafka.test.rule.KafkaEmbedded
 
getKafkaServers() - Method in class org.springframework.kafka.test.rule.KafkaEmbedded
 
getKafkaServers() - Method in interface org.springframework.kafka.test.rule.KafkaRule
 
getPartitionsPerTopic() - Method in class org.springframework.kafka.test.rule.KafkaEmbedded
 
getPartitionsPerTopic() - Method in interface org.springframework.kafka.test.rule.KafkaRule
 
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.
getZkClient() - Method in class org.springframework.kafka.test.rule.KafkaEmbedded
 
getZkClient() - Method in interface org.springframework.kafka.test.rule.KafkaRule
 
getZookeeper() - Method in class org.springframework.kafka.test.rule.KafkaEmbedded
 
getZookeeperConnectionString() - Method in class org.springframework.kafka.test.rule.KafkaEmbedded
 
getZookeeperConnectionString() - Method in interface org.springframework.kafka.test.rule.KafkaRule
 

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

isEmbedded() - Method in class org.springframework.kafka.test.rule.KafkaEmbedded
 
isEmbedded() - Method in interface org.springframework.kafka.test.rule.KafkaRule
 

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
The KafkaRule implementation for the embedded Kafka Broker and Zookeeper.
KafkaEmbedded(int) - Constructor for class org.springframework.kafka.test.rule.KafkaEmbedded
 
KafkaEmbedded(int, boolean, String...) - Constructor for class org.springframework.kafka.test.rule.KafkaEmbedded
Create embedded Kafka brokers.
KafkaEmbedded(int, boolean, int, String...) - Constructor for class org.springframework.kafka.test.rule.KafkaEmbedded
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
 
KafkaRule - Interface in org.springframework.kafka.test.rule
Common functionality for the Kafka JUnit rules
KafkaTestUtils - Class in org.springframework.kafka.test.utils
Kafka testing utilities.
key(K) - Static method in class org.springframework.kafka.test.assertj.KafkaConditions
 

L

Log4jLevelAdjuster - Class in org.springframework.kafka.test.rule
A JUnit method @Rule that changes the logger level for a set of classes or packages while a test method is running.
Log4jLevelAdjuster(Level, Class<?>...) - Constructor for class org.springframework.kafka.test.rule.Log4jLevelAdjuster
 
Log4jLevelAdjuster(Level, String...) - Constructor for class org.springframework.kafka.test.rule.Log4jLevelAdjuster
 

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
 

O

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
Set up test properties for an <Integer, String> producer.

R

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

S

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

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
 

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