Value Members

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

   Definition Classes

   AnyRef → Any

2.  final def ##(): Int

   Definition Classes

   AnyRef → Any

3.  final def ==(arg0: Any): Boolean

   Definition Classes

   AnyRef → Any

4.  val DefaultKey: String

   Definition Classes

   KafkaTestKit

5.  def adminClient: AdminClient

   Definition Classes

   KafkaTestKit

6.  final def asInstanceOf[T0]: T0

   Definition Classes

   Any

7.  val bootstrapServers: String

   Definition Classes

   KafkaTestKitClass → KafkaTestKit

8.  def cleanUpAdminClient(): Unit

   Close internal admin client instances.

   Close internal admin client instances.

   Definition Classes

   KafkaTestKit

9.  def clone(): AnyRef

   Attributes

   protected[java.lang]

   Definition Classes

   AnyRef

   Annotations

   @native() @throws( ... )

10.  def committerDefaults: CommitterSettings

    Definition Classes

    KafkaTestKit

11.  def consumeString(topic: String, take: Long): DrainingControl[List[ConsumerRecord[String, String]]]

    Attributes

    protected[akka.kafka.testkit.javadsl]

12.  def consumerDefaults: ConsumerSettings[String, String]

    Definition Classes

    KafkaTestKit

13.  def createGroupId(number: Int = 0): String

    Definition Classes

    KafkaTestKit

14.  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

15.  def createTopicName(number: Int): String

    Definition Classes

    KafkaTestKit

16.  def createTransactionalId(number: Int = 0): String

    Definition Classes

    KafkaTestKit

17.  final def eq(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef

18.  def equals(arg0: Any): Boolean

    Definition Classes

    AnyRef → Any

19.  def finalize(): Unit

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

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

20.  final def getClass(): Class[_]

    Definition Classes

    AnyRef → Any

    Annotations

    @native()

21.  def hashCode(): Int

    Definition Classes

    AnyRef → Any

    Annotations

    @native()

22.  final def isInstanceOf[T0]: Boolean

    Definition Classes

    Any

23.  def log(): Logger

    Definition Classes

    BaseKafkaTest → KafkaTestKit

24.  final def ne(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef

25.  def nextNumber(): Int

    Definition Classes

    KafkaTestKit

26.  final def notify(): Unit

    Definition Classes

    AnyRef

    Annotations

    @native()

27.  final def notifyAll(): Unit

    Definition Classes

    AnyRef

    Annotations

    @native()

28.  def produceString(topic: String, messageCount: Int, partition: Int): CompletionStage[Done]

    Attributes

    protected[akka.kafka.testkit.javadsl]

29.  def producerDefaults: ProducerSettings[String, String]

    Definition Classes

    KafkaTestKit

30.  def resultOf[T](stage: CompletionStage[T], timeout: Duration): T

    Attributes

    protected[akka.kafka.testkit.javadsl]

31.  def resultOf[T](stage: CompletionStage[T]): T

    Attributes

    protected[akka.kafka.testkit.javadsl]

32.  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]

33.  def setUpAdminClient(): Unit

    Create internal admin clients.

    Create internal admin clients. Gives access to adminClient, be sure to call cleanUpAdminClient after the tests are done.

    Definition Classes

    KafkaTestKit

34.  def sleepMillis(ms: Long, msg: String): Unit

    Definition Classes

    KafkaTestKit

35.  def sleepSeconds(s: Int, msg: String): Unit

    Definition Classes

    KafkaTestKit

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

    Definition Classes

    AnyRef

37.  val system: ActorSystem

    Definition Classes

    KafkaTestKitClass → KafkaTestKit

38.  def toString(): String

    Definition Classes

    AnyRef → Any

39.  final def wait(): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

41.  final def wait(arg0: Long): Unit

    Definition Classes

    AnyRef

    Annotations

    @native() @throws( ... )