abstract class KafkaJunit4Test extends BaseKafkaTest
JUnit 4 base-class with some convenience for accessing a Kafka broker.
- Source
- KafkaJunit4Test.java
- Alphabetic
- By Inheritance
- KafkaJunit4Test
- BaseKafkaTest
- KafkaTestKitClass
- KafkaTestKit
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Instance Constructors
- new KafkaJunit4Test(system: ActorSystem, materializer: Materializer, bootstrapServers: String)
- 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
- def cleanUpAdmin(): Unit
- 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
- @throws(classOf[java.lang.CloneNotSupportedException]) @native() @HotSpotIntrinsicCandidate()
- 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: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- final def getClass(): Class[_ <: AnyRef]
- 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 setUpAdmin(): Unit
- 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 sleepMillis(ms: Long, msg: String): Unit
- Definition Classes
- KafkaTestKit
- def sleepSeconds(s: Int, msg: String): Unit
- Definition Classes
- KafkaTestKit
- 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(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- 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