JavaScript is disabled on your browser.
Skip navigation links
Overview
Package
Class
Tree
Deprecated
Index
Help
Prev
Next
Frames
No Frames
All Classes
A
B
C
D
E
F
G
H
I
K
M
O
P
R
S
T
V
W
A
after()
- Method in class org.springframework.kafka.test.rule.
KafkaEmbedded
B
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
bounce(int)
- Method in class org.springframework.kafka.test.rule.
KafkaEmbedded
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
C
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
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
ConsumerRecordValueCondition(V)
- Constructor for class org.springframework.kafka.test.assertj.
KafkaConditions.ConsumerRecordValueCondition
ConsumerRecordValueMatcher(V)
- Constructor for class org.springframework.kafka.test.hamcrest.
KafkaMatchers.ConsumerRecordValueMatcher
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.ConsumerRecordValueMatcher
E
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
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
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
Condition
s.
KafkaConditions.ConsumerRecordKeyCondition
<
K
> - Class in
org.springframework.kafka.test.assertj
KafkaConditions.ConsumerRecordPartitionCondition
- 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.
KafkaMatchers
- Class in
org.springframework.kafka.test.hamcrest
Hamcrest
Matcher
s utilities.
KafkaMatchers.ConsumerRecordKeyMatcher
<
K
> - Class in
org.springframework.kafka.test.hamcrest
KafkaMatchers.ConsumerRecordPartitionMatcher
- 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
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<?, 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.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.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
startZookeeper()
- Method in class org.springframework.kafka.test.rule.
KafkaEmbedded
T
toString()
- Method in class org.springframework.kafka.test.core.
BrokerAddress
V
value(V)
- Static method in class org.springframework.kafka.test.assertj.
KafkaConditions
W
waitUntilSynced(String, int)
- Method in class org.springframework.kafka.test.rule.
KafkaEmbedded
A
B
C
D
E
F
G
H
I
K
M
O
P
R
S
T
V
W
Skip navigation links
Overview
Package
Class
Tree
Deprecated
Index
Help
Prev
Next
Frames
No Frames
All Classes