abstract class KafkaSpec extends TestKit with KafkaTestKit
- Alphabetic
- By Inheritance
- KafkaSpec
- KafkaTestKit
- TestKit
- TestKitBase
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Instance Constructors
Abstract Value Members
-
abstract
def
bootstrapServers: String
- Definition Classes
- KafkaTestKit
Concrete 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
- val InitialMsg: String
- implicit val adapter: LoggingAdapter
-
def
adminClient: AdminClient
- Definition Classes
- KafkaTestKit
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
awaitAssert[A](a: ⇒ A, max: Duration, interval: Duration): A
- Definition Classes
- TestKitBase
-
def
awaitCond(p: ⇒ Boolean, max: Duration, interval: Duration, message: String): Unit
- Definition Classes
- TestKitBase
- def awaitMultiple[T](d: FiniteDuration, futures: Future[T]*): Seq[T]
- def awaitProduce(futures: Future[Done]*): Unit
-
def
batchMessagesExpected(topics: Seq[String], batches: Int, batchSize: Int): (Seq[String], Long)
Messages expected from #produceBatches generation.
-
def
childActorOf(props: Props): ActorRef
- Definition Classes
- TestKitBase
-
def
childActorOf(props: Props, name: String): ActorRef
- Definition Classes
- TestKitBase
-
def
childActorOf(props: Props, supervisorStrategy: SupervisorStrategy): ActorRef
- Definition Classes
- TestKitBase
-
def
childActorOf(props: Props, name: String, supervisorStrategy: SupervisorStrategy): ActorRef
- Definition Classes
- TestKitBase
- def cleanUp(): 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
- @native() @throws( ... )
-
def
committerDefaults: CommitterSettings
- Definition Classes
- KafkaTestKit
-
def
consumerDefaults: ConsumerSettings[String, String]
- Definition Classes
- KafkaTestKit
-
def
createGroupId(number: Int = 0): String
- Definition Classes
- KafkaTestKit
- def createProbe(consumerSettings: ConsumerSettings[String, String], topic: String*): (Control, Probe[String])
-
def
createTopic(number: Int = 0, partitions: Int = 1, replication: Int = 1): String
Create a topic with given partition number and replication factor.
Create a topic with given partition number and replication factor.
This method will block and return only when the topic has been successfully created.
- Definition Classes
- KafkaTestKit
-
def
createTopicName(number: Int): String
- Definition Classes
- KafkaTestKit
- def createTopics(topics: Int*): Seq[String]
-
def
createTransactionalId(number: Int = 0): String
- Definition Classes
- KafkaTestKit
- implicit val ec: ExecutionContext
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
expectMsg[T](max: FiniteDuration, hint: String, obj: T): T
- Definition Classes
- TestKitBase
-
def
expectMsg[T](max: FiniteDuration, obj: T): T
- Definition Classes
- TestKitBase
-
def
expectMsg[T](obj: T): T
- Definition Classes
- TestKitBase
-
def
expectMsgAllClassOf[T](max: FiniteDuration, obj: Class[_ <: T]*): Seq[T]
- Definition Classes
- TestKitBase
-
def
expectMsgAllClassOf[T](obj: Class[_ <: T]*): Seq[T]
- Definition Classes
- TestKitBase
-
def
expectMsgAllConformingOf[T](max: FiniteDuration, obj: Class[_ <: T]*): Seq[T]
- Definition Classes
- TestKitBase
-
def
expectMsgAllConformingOf[T](obj: Class[_ <: T]*): Seq[T]
- Definition Classes
- TestKitBase
-
def
expectMsgAllOf[T](max: FiniteDuration, obj: T*): Seq[T]
- Definition Classes
- TestKitBase
-
def
expectMsgAllOf[T](obj: T*): Seq[T]
- Definition Classes
- TestKitBase
-
def
expectMsgAnyClassOf[C](max: FiniteDuration, obj: Class[_ <: C]*): C
- Definition Classes
- TestKitBase
-
def
expectMsgAnyClassOf[C](obj: Class[_ <: C]*): C
- Definition Classes
- TestKitBase
-
def
expectMsgAnyOf[T](max: FiniteDuration, obj: T*): T
- Definition Classes
- TestKitBase
-
def
expectMsgAnyOf[T](obj: T*): T
- Definition Classes
- TestKitBase
-
def
expectMsgClass[C](max: FiniteDuration, c: Class[C]): C
- Definition Classes
- TestKitBase
-
def
expectMsgClass[C](c: Class[C]): C
- Definition Classes
- TestKitBase
-
def
expectMsgPF[T](max: Duration, hint: String)(f: PartialFunction[Any, T]): T
- Definition Classes
- TestKitBase
-
def
expectMsgType[T](max: FiniteDuration)(implicit t: ClassTag[T]): T
- Definition Classes
- TestKitBase
-
def
expectMsgType[T](implicit t: ClassTag[T]): T
- Definition Classes
- TestKitBase
-
def
expectNoMessage(): Unit
- Definition Classes
- TestKitBase
-
def
expectNoMessage(max: FiniteDuration): Unit
- Definition Classes
- TestKitBase
-
def
expectTerminated(target: ActorRef, max: Duration): Terminated
- Definition Classes
- TestKitBase
-
def
finalize(): Unit
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
def
fishForMessage(max: Duration, hint: String)(f: PartialFunction[Any, Boolean]): Any
- Definition Classes
- TestKitBase
-
def
fishForSpecificMessage[T](max: Duration, hint: String)(f: PartialFunction[Any, T]): T
- Definition Classes
- TestKitBase
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def givenInitializedTopic(topic: String): Unit
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
def
ignoreMsg(f: PartialFunction[Any, Boolean]): Unit
- Definition Classes
- TestKitBase
-
def
ignoreNoMsg(): Unit
- Definition Classes
- TestKitBase
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- val kafkaPort: Int
-
def
lastSender: ActorRef
- Definition Classes
- TestKitBase
-
val
log: Logger
- Definition Classes
- KafkaSpec → KafkaTestKit
- implicit val mat: Materializer
-
def
msgAvailable: Boolean
- Definition Classes
- TestKitBase
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
nextNumber(): Int
- Definition Classes
- KafkaTestKit
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
def
now: FiniteDuration
- Definition Classes
- TestKitBase
- val partition0: Int
- def periodicalCheck[T](description: String, maxTries: Int = 10, sleepInBetween: FiniteDuration = 100.millis)(data: () ⇒ T)(predicate: (T) ⇒ Boolean): Unit
-
def
produce(topic: String, range: Range, settings: ProducerSettings[String, String]): Future[Done]
Produce messages to topic using specified range and return a Future so the caller can synchronize consumption.
-
def
produce(topic: String, range: Seq[Int], partition: Int = partition0): Future[Done]
Produce messages to topic using specified range and return a Future so the caller can synchronize consumption.
-
def
produceBatches(topics: Seq[String], batches: Int, batchSize: Int): Future[Seq[Done]]
Produce batches over several topics.
- def produceString(topic: String, range: Seq[String], partition: Int = partition0): Future[Done]
- def produceTimestamped(topic: String, timestampedRange: Seq[(Int, Long)]): Future[Done]
-
def
producerDefaults: ProducerSettings[String, String]
- Definition Classes
- KafkaTestKit
-
def
receiveN(n: Int, max: FiniteDuration): Seq[AnyRef]
- Definition Classes
- TestKitBase
-
def
receiveN(n: Int): Seq[AnyRef]
- Definition Classes
- TestKitBase
-
def
receiveOne(max: Duration): AnyRef
- Definition Classes
- TestKitBase
-
def
receiveWhile[T](max: Duration, idle: Duration, messages: Int)(f: PartialFunction[AnyRef, T]): Seq[T]
- Definition Classes
- TestKitBase
-
def
remaining: FiniteDuration
- Definition Classes
- TestKitBase
-
def
remainingOr(duration: FiniteDuration): FiniteDuration
- Definition Classes
- TestKitBase
-
def
remainingOrDefault: FiniteDuration
- Definition Classes
- TestKitBase
-
def
setAutoPilot(pilot: AutoPilot): Unit
- Definition Classes
- TestKitBase
- def setUp(): 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
-
def
shutdown(actorSystem: ActorSystem, duration: Duration, verifySystemShutdown: Boolean): Unit
- Definition Classes
- TestKitBase
- def sleep(time: FiniteDuration, msg: String = ""): Unit
- def sleepAfterProduce: FiniteDuration
-
def
sleepMillis(ms: Long, msg: String): Unit
- Definition Classes
- KafkaTestKit
- def sleepQuietly(time: FiniteDuration): Unit
-
def
sleepSeconds(s: Int, msg: String): Unit
- Definition Classes
- KafkaTestKit
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
implicit
val
system: ActorSystem
- Definition Classes
- TestKit → TestKitBase
-
val
testActor: ActorRef
- Definition Classes
- TestKitBase
-
def
testActorName: String
- Attributes
- protected
- Definition Classes
- TestKitBase
-
val
testKitSettings: TestKitSettings
- Definition Classes
- TestKitBase
- var testProducer: Producer[String, String]
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
def
unwatch(ref: ActorRef): ActorRef
- Definition Classes
- TestKitBase
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
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( ... )
-
def
waitUntilCluster(maxTries: Int = 10, sleepInBetween: FiniteDuration = 100.millis)(predicate: (DescribeClusterResult) ⇒ Boolean): 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
maxTries
, throws an exception. -
def
waitUntilConsumerGroup(groupId: String, timeout: Duration = 1.second, sleepInBetween: FiniteDuration = 100.millis)(predicate: (ConsumerGroupDescription) ⇒ Boolean): 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
maxTries
, throws an exception. -
def
waitUntilConsumerSummary(groupId: String, timeout: Duration = 1.second, sleepInBetween: FiniteDuration = 100.millis)(predicate: PartialFunction[List[MemberDescription], Boolean]): 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
maxTries
, throws an exception. -
def
watch(ref: ActorRef): ActorRef
- Definition Classes
- TestKitBase
-
def
within[T](max: FiniteDuration)(f: ⇒ T): T
- Definition Classes
- TestKitBase
-
def
within[T](min: FiniteDuration, max: FiniteDuration)(f: ⇒ T): T
- Definition Classes
- TestKitBase
- val zooKeeperPort: Int
Deprecated Value Members
-
def
expectNoMsg(max: FiniteDuration): Unit
- Definition Classes
- TestKitBase
- Annotations
- @deprecated
- Deprecated
(Since version 2.5.5) Use expectNoMessage instead
-
def
expectNoMsg(): Unit
- Definition Classes
- TestKitBase
- Annotations
- @deprecated
- Deprecated
(Since version 2.5.5) Use expectNoMessage instead