EmbeddedKafka

Value Members

1. final def !=(arg0: Any): Boolean

   

   Definition Classes

   AnyRef → Any

2. final def ##(): Int

   

   Definition Classes

   AnyRef → Any

3. def +(other: String): String

   

   Implicit information

   This member is added by an implicit conversion from EmbeddedKafka to any2stringadd[EmbeddedKafka] performed by method any2stringadd in scala.Predef.

   Definition Classes

   any2stringadd

4. def ->[B](y: B): (EmbeddedKafka, B)

   

   Implicit information

   This member is added by an implicit conversion from EmbeddedKafka to ArrowAssoc[EmbeddedKafka] performed by method ArrowAssoc in scala.Predef.

   Definition Classes

   ArrowAssoc

   Annotations

   @inline()

5. final def ==(arg0: Any): Boolean

   

   Definition Classes

   AnyRef → Any

6. final def asInstanceOf[T0]: T0

   

   Definition Classes

   Any

7. def awaitCond(p: ⇒ Boolean, max: Duration = 3.seconds, interval: Duration = 100.millis, message: String = ""): Unit

   

   Await until the given condition evaluates to true or the timeout expires, whichever comes first.

   Await until the given condition evaluates to true or the timeout expires, whichever comes first. If no timeout is given, take it from the innermost enclosing within block.

   Definition Classes

   Assertions

8. def awaitPropagation(topic: String, partition: Int, timeout: Duration): Unit

   

9. def clone(): AnyRef

   

   Attributes

   protected[java.lang]

   Definition Classes

   AnyRef

   Annotations

   @throws( ... )

10. def closeAfterUse[T, C <: AnyRef { def close(): Unit }](closeable: C)(code: (C) ⇒ T): T

    

    Automatically closes resource after use.

    Automatically closes resource after use. Handy for closing streams, files, sessions etc. Similar to try-with-resources in Java 7.

    Definition Classes

    EmbeddedIO

11. def copyTextFileWithVariableSubstitution(source: InputStream, target: OutputStream, map: (String) ⇒ String): Unit

    

    Copies a text file substituting every occurrence of $ {VARIABLE} with a value from the given map

    Copies a text file substituting every occurrence of $ {VARIABLE} with a value from the given map

    Definition Classes

    EmbeddedIO

12. def createTempDir: File

    

    Definition Classes

    EmbeddedIO

13. def createTopic(topic: String, numPartitions: Int = 1, replicationFactor: Int = 1): Unit

    

14. def deleteRecursively(file: File): Unit

    

    Definition Classes

    EmbeddedIO

15. def ensuring(cond: (EmbeddedKafka) ⇒ Boolean, msg: ⇒ Any): EmbeddedKafka

    

    Implicit information

    This member is added by an implicit conversion from EmbeddedKafka to Ensuring[EmbeddedKafka] performed by method Ensuring in scala.Predef.

    Definition Classes

    Ensuring

16. def ensuring(cond: (EmbeddedKafka) ⇒ Boolean): EmbeddedKafka

    

    Implicit information

    This member is added by an implicit conversion from EmbeddedKafka to Ensuring[EmbeddedKafka] performed by method Ensuring in scala.Predef.

    Definition Classes

    Ensuring

17. def ensuring(cond: Boolean, msg: ⇒ Any): EmbeddedKafka

    

    Implicit information

    This member is added by an implicit conversion from EmbeddedKafka to Ensuring[EmbeddedKafka] performed by method Ensuring in scala.Predef.

    Definition Classes

    Ensuring

18. def ensuring(cond: Boolean): EmbeddedKafka

    

    Implicit information

    This member is added by an implicit conversion from EmbeddedKafka to Ensuring[EmbeddedKafka] performed by method Ensuring in scala.Predef.

    Definition Classes

    Ensuring

19. final def eq(arg0: AnyRef): Boolean

    

    Definition Classes

    AnyRef

20. def equals(arg0: Any): Boolean

    

    Definition Classes

    AnyRef → Any

21. def finalize(): Unit

    

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( classOf[java.lang.Throwable] )

22. def formatted(fmtstr: String): String

    

    Implicit information

    This member is added by an implicit conversion from EmbeddedKafka to StringFormat[EmbeddedKafka] performed by method StringFormat in scala.Predef.

    Definition Classes

    StringFormat

    Annotations

    @inline()

23. final def getClass(): Class[_]

    

    Definition Classes

    AnyRef → Any

24. def hasRootAsShutdownDeleteDir(file: File): Boolean

    

    Definition Classes

    EmbeddedIO

25. def hashCode(): Int

    

    Definition Classes

    AnyRef → Any

26. final def isInstanceOf[T0]: Boolean

    

    Definition Classes

    Any

27. def isSymlink(file: File): Boolean

    

    Definition Classes

    EmbeddedIO

28. val kafkaConfig: KafkaConfig

    

29. val kafkaParams: Map[String, String]

    

30. def listFilesSafely(file: File): Seq[File]

    

    Definition Classes

    EmbeddedIO

31. def mkdir(dir: File): File

    

    Makes a new directory or throws an IOException if it cannot be made

    Makes a new directory or throws an IOException if it cannot be made

    Definition Classes

    EmbeddedIO

32. final def ne(arg0: AnyRef): Boolean

    

    Definition Classes

    AnyRef

33. final def notify(): Unit

    

    Definition Classes

    AnyRef

34. final def notifyAll(): Unit

    

    Definition Classes

    AnyRef

35. def now: FiniteDuration

    

    Obtain current time (System.nanoTime) as Duration.

    Obtain current time (System.nanoTime) as Duration.

    Definition Classes

    Assertions

36. def produceAndSendMessage(topic: String, sent: Map[String, Int]): Unit

    

37. val producer: Producer[String, String]

    

38. val producerConfig: ProducerConfig

    

39. def registerShutdownDeleteDir(file: File): Unit

    

    Definition Classes

    EmbeddedIO

40. def remainingOr(duration: FiniteDuration): FiniteDuration

    

    Obtain time remaining for execution of the innermost enclosing within block or missing that it returns the given duration.

    Obtain time remaining for execution of the innermost enclosing within block or missing that it returns the given duration.

    Definition Classes

    Assertions

41. def remainingOrDefault: FiniteDuration

    

    Obtain time remaining for execution of the innermost enclosing within block or missing that it returns the properly dilated default for this case from settings (key "akka.test.single-expect-default").

    Obtain time remaining for execution of the innermost enclosing within block or missing that it returns the properly dilated default for this case from settings (key "akka.test.single-expect-default").

    Definition Classes

    Assertions

42. val server: KafkaServer

    

43. def shutdown(): Unit

    

44. val shutdownDeletePaths: HashSet[String]

    

    Definition Classes

    EmbeddedIO

45. final def synchronized[T0](arg0: ⇒ T0): T0

    

    Definition Classes

    AnyRef

46. def toString(): String

    

    Definition Classes

    AnyRef → Any

47. final def wait(): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

48. final def wait(arg0: Long, arg1: Int): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

49. final def wait(arg0: Long): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

50. def waitForPortOpen(host: InetAddress, port: Int, timeout: Long): Boolean

    

    Waits until a port at the given address is open or timeout passes.

    Waits until a port at the given address is open or timeout passes.

    returns

    true if managed to connect to the port, false if timeout happened first

    Definition Classes

    EmbeddedIO

51. def →[B](y: B): (EmbeddedKafka, B)

    

    Implicit information

    This member is added by an implicit conversion from EmbeddedKafka to ArrowAssoc[EmbeddedKafka] performed by method ArrowAssoc in scala.Predef.

    Definition Classes

    ArrowAssoc