abstract class EmbeddedKafkaTest extends KafkaTest
JUnit 5 aka Jupiter base-class with some convenience for creating an embedded Kafka broker before
running the tests. Extending classes must be annotated with @TestInstance(Lifecycle.PER_CLASS)
to create a single instance of the test class with @BeforeAll
and @AfterAll
annotated methods
called by the test framework.
- Source
- EmbeddedKafkaTest.java
- Alphabetic
- By Inheritance
- EmbeddedKafkaTest
- KafkaTest
- BaseKafkaTest
- KafkaTestKitClass
- KafkaTestKit
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Instance Constructors
-
new
EmbeddedKafkaTest(system: ActorSystem, materializer: Materializer, kafkaPort: Int)
- Attributes
- protected[akka.kafka.testkit.javadsl]
-
new
EmbeddedKafkaTest(system: ActorSystem, materializer: Materializer, kafkaPort: Int, replicationFactor: Int)
- Attributes
- protected[akka.kafka.testkit.javadsl]
Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
val
DefaultKey: String
- Definition Classes
- KafkaTestKit
-
def
adminClient: AdminClient
Access to the Kafka AdminClient which life
Access to the Kafka AdminClient which life
- Definition Classes
- KafkaTestKit
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
val
bootstrapServers: String
- Definition Classes
- KafkaTestKitClass → KafkaTestKit
-
def
checkForStageLeaks(): Unit
- Definition Classes
- KafkaTest
-
def
cleanUpAdmin(): Unit
- Definition Classes
- KafkaTest
-
def
cleanUpAdminClient(): Unit
Close internal admin client instances.
Close internal admin client instances.
- Definition Classes
- KafkaTestKit
-
def
clone(): AnyRef
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate() @throws( ... )
-
def
committerDefaults: CommitterSettings
- Definition Classes
- KafkaTestKit
-
def
consumeString(topic: String, take: Long): DrainingControl[List[ConsumerRecord[String, String]]]
- Attributes
- protected[akka.kafka.testkit.javadsl]
- Definition Classes
- BaseKafkaTest
-
def
consumerDefaults: ConsumerSettings[String, String]
- Definition Classes
- KafkaTestKit
-
def
createGroupId(suffix: Int): String
Return a unique group id with a given suffix.
Return a unique group id with a given suffix.
- Definition Classes
- KafkaTestKit
-
def
createGroupId(): String
Return a unique group id with a default suffix.
Return a unique group id with a default suffix.
- Definition Classes
- KafkaTestKit
-
def
createTopic(suffix: Int, partitions: Int, replication: Int): String
Create a topic with given suffix, partition number and replication factor.
Create a topic with given suffix, partition number and replication factor.
This method will block and return only when the topic has been successfully created.
- Definition Classes
- KafkaTestKit
-
def
createTopic(suffix: Int, partitions: Int): String
Create a topic with a given suffix, partition number and a replication factor of one.
Create a topic with a given suffix, partition number and a replication factor of one.
This method will block and return only when the topic has been successfully created.
- Definition Classes
- KafkaTestKit
-
def
createTopic(suffix: Int): String
Create a topic with a given suffix, single partitions and a replication factor of one.
Create a topic with a given suffix, single partitions and a replication factor of one.
This method will block and return only when the topic has been successfully created.
- Definition Classes
- KafkaTestKit
-
def
createTopic(): String
Create a topic with a default suffix, single partition and a replication factor of one.
Create a topic with a default suffix, single partition and a replication factor of one.
This method will block and return only when the topic has been successfully created.
- Definition Classes
- KafkaTestKit
-
def
createTopicName(suffix: Int): String
Return a unique topic name.
Return a unique topic name.
- Definition Classes
- KafkaTestKit
-
def
createTransactionalId(suffix: Int): String
Return a unique transactional id with a given suffix.
Return a unique transactional id with a given suffix.
- Definition Classes
- KafkaTestKit
-
def
createTransactionalId(): String
Return a unique transactional id with a default suffix.
Return a unique transactional id with a default suffix.
- Definition Classes
- KafkaTestKit
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
def
log(): Logger
- Definition Classes
- BaseKafkaTest → KafkaTestKit
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
def
produceString(topic: String, messageCount: Int, partition: Int): CompletionStage[Done]
- Attributes
- protected[akka.kafka.testkit.javadsl]
- Definition Classes
- BaseKafkaTest
-
def
producerDefaults: ProducerSettings[String, String]
- Definition Classes
- KafkaTestKit
-
def
resultOf[T](stage: CompletionStage[T], timeout: Duration): T
- Attributes
- protected[akka.kafka.testkit.javadsl]
- Definition Classes
- BaseKafkaTest
-
def
resultOf[T](stage: CompletionStage[T]): T
- Attributes
- protected[akka.kafka.testkit.javadsl]
- Definition Classes
- BaseKafkaTest
-
def
resultOfTimeout(): Duration
Overwrite to set different default timeout for #resultOf.
Overwrite to set different default timeout for #resultOf.
- Attributes
- protected[akka.kafka.testkit.javadsl]
- Definition Classes
- BaseKafkaTest
-
def
setUpAdminClient(): Unit
Create internal admin clients.
Create internal admin clients. Gives access to
adminClient
, be sure to callcleanUpAdminClient
after the tests are done.- Definition Classes
- KafkaTestKit
-
val
settings: KafkaTestkitSettings
- Definition Classes
- KafkaTestKit
-
def
setupAdmin(): Unit
- Definition Classes
- KafkaTest
-
def
sleepMillis(ms: Long, msg: String): Unit
- Definition Classes
- KafkaTestKit
-
def
sleepSeconds(s: Int, msg: String): Unit
- Definition Classes
- KafkaTestKit
-
def
startEmbeddedKafka(kafkaPort: Int, replicationFactor: Int): Unit
- Attributes
- protected[akka.kafka.testkit.javadsl]
-
def
stopEmbeddedKafka(): Unit
- Attributes
- protected[akka.kafka.testkit.javadsl]
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
val
system: ActorSystem
- Definition Classes
- KafkaTestKitClass → KafkaTestKit
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @throws( ... )
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
def
waitUntilCluster(predicate: Predicate[DescribeClusterResult]): Unit
Periodically checks if a given predicate on cluster state holds.
Periodically checks if a given predicate on cluster state holds.
If the predicate does not hold after configured amount of time, throws an exception.
- Definition Classes
- BaseKafkaTest
-
def
waitUntilConsumerGroup(groupId: String, predicate: Predicate[ConsumerGroupDescription]): Unit
Periodically checks if the given predicate on consumer group state holds.
Periodically checks if the given predicate on consumer group state holds.
If the predicate does not hold after configured amount of time, throws an exception.
- Definition Classes
- BaseKafkaTest
-
def
waitUntilConsumerSummary(groupId: String, predicate: Predicate[Collection[MemberDescription]]): Unit
Periodically checks if the given predicate on consumer summary holds.
Periodically checks if the given predicate on consumer summary holds.
If the predicate does not hold after configured amount of time, throws an exception.
- Definition Classes
- BaseKafkaTest