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.  val StringDeserializer: StringDeserializer

   Definition Classes

   KafkaTestKit

6.  val StringSerializer: StringSerializer

   Definition Classes

   KafkaTestKit

7.  def adminClient: Admin

   Access to the Kafka Admin client

   Access to the Kafka Admin client

   Definition Classes

   KafkaTestKit

8.  final def asInstanceOf[T0]: T0

   Definition Classes

   Any

9.  val bootstrapServers: String

   Definition Classes

   KafkaTestKitClass → KafkaTestKit

10.  def cleanUpAdminClient(): Unit

    Close internal admin client instances.

    Close internal admin client instances.

    Definition Classes

    KafkaTestKit

11.  def clone(): AnyRef

    Attributes

    protected[lang]

    Definition Classes

    AnyRef

    Annotations

    @throws(classOf[java.lang.CloneNotSupportedException]) @native()

12.  def committerDefaults: CommitterSettings

    Definition Classes

    KafkaTestKit

13.  def consume[K, V](topic: String, take: Long, keyDeserializer: Deserializer[K], valueDeserializer: Deserializer[V]): DrainingControl[List[ConsumerRecord[K, V]]]

    Attributes

    protected[javadsl]

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

    Attributes

    protected[javadsl]

15.  def consumerDefaults[K, V](keyDeserializer: Deserializer[K], valueDeserializer: Deserializer[V]): ConsumerSettings[K, V]

    Definition Classes

    KafkaTestKit

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

    Definition Classes

    KafkaTestKit

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

18.  def createGroupId(): String

    Return a unique group id with a default suffix.

    Return a unique group id with a default suffix.

    Definition Classes

    KafkaTestKit

19.  def createTopic(suffix: Int, partitions: Int, replication: Int, config: Map[String, String]): String

    Java Api

    Java Api

    Create a topic with given suffix, partition number, replication factor, and topic configuration.

    This method will block and return only when the topic has been successfully created.

    Definition Classes

    KafkaTestKit

20.  def createTopic(suffix: Int, partitions: Int, replication: Int, config: Map[String, String]): String

    Create a topic with given suffix, partition number, replication factor, and topic configuration.

    Create a topic with given suffix, partition number, replication factor, and topic configuration.

    This method will block and return only when the topic has been successfully created.

    Definition Classes

    KafkaTestKit

21.  def createTopic(suffix: Int, partitions: Int, replication: Int): String

    Create a topic with given suffix, partition number, replication factor, and no topic configuration.

    Create a topic with given suffix, partition number, replication factor, and no topic configuration.

    This method will block and return only when the topic has been successfully created.

    Definition Classes

    KafkaTestKit

22.  def createTopic(suffix: Int, partitions: Int): String

    Create a topic with a given suffix, partition number, a replication factor of one, and no topic configuration.

    Create a topic with a given suffix, partition number, a replication factor of one, and no topic configuration.

    This method will block and return only when the topic has been successfully created.

    Definition Classes

    KafkaTestKit

23.  def createTopic(suffix: Int): String

    Create a topic with a given suffix, single partitions, a replication factor of one, and no topic configuration.

    Create a topic with a given suffix, single partitions, a replication factor of one, and no topic configuration.

    This method will block and return only when the topic has been successfully created.

    Definition Classes

    KafkaTestKit

24.  def createTopic(): String

    Create a topic with a default suffix, single partition, a replication factor of one, and no topic configuration.

    Create a topic with a default suffix, single partition, a replication factor of one, and no topic configuration.

    This method will block and return only when the topic has been successfully created.

    Definition Classes

    KafkaTestKit

25.  def createTopicName(suffix: Int): String

    Return a unique topic name.

    Return a unique topic name.

    Definition Classes

    KafkaTestKit

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

27.  def createTransactionalId(): String

    Return a unique transactional id with a default suffix.

    Return a unique transactional id with a default suffix.

    Definition Classes

    KafkaTestKit

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

    Definition Classes

    AnyRef

29.  def equals(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef → Any

30.  def finalize(): Unit

    Attributes

    protected[lang]

    Definition Classes

    AnyRef

    Annotations

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

31.  final def getClass(): Class[_ <: AnyRef]

    Definition Classes

    AnyRef → Any

    Annotations

    @native()

32.  def hashCode(): Int

    Definition Classes

    AnyRef → Any

    Annotations

    @native()

33.  final def isInstanceOf[T0]: Boolean

    Definition Classes

    Any

34.  def log(): Logger

    Definition Classes

    BaseKafkaTest → KafkaTestKit

    Annotations

    @Override()

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

    Definition Classes

    AnyRef

36.  final def notify(): Unit

    Definition Classes

    AnyRef

    Annotations

    @native()

37.  final def notifyAll(): Unit

    Definition Classes

    AnyRef

    Annotations

    @native()

38.  final def produce[K, V](topic: String, keySerializer: Serializer[K], valueSerializer: Serializer[V], messages: <repeated...>[Pair[K, V]]): CompletionStage[Done]

    Attributes

    protected[javadsl]

    Annotations

    @SafeVarargs()

39.  def produceString(topic: String, message: String): CompletionStage[Done]

    Attributes

    protected[javadsl]

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

    Attributes

    protected[javadsl]

41.  def producerDefaults[K, V](keySerializer: Serializer[K], valueSerializer: Serializer[V]): ProducerSettings[K, V]

    Definition Classes

    KafkaTestKit

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

    Definition Classes

    KafkaTestKit

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

    Attributes

    protected[javadsl]

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

    Attributes

    protected[javadsl]

45.  def resultOfTimeout(): Duration

    Overwrite to set different default timeout for resultOf.

    Overwrite to set different default timeout for resultOf.

    Attributes

    protected[javadsl]

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

47.  val settings: KafkaTestkitSettings

    Definition Classes

    KafkaTestKit

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

    Definition Classes

    KafkaTestKit

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

    Definition Classes

    KafkaTestKit

50.  final def synchronized[T0](arg0: => T0): T0

    Definition Classes

    AnyRef

51.  val system: ActorSystem

    Definition Classes

    KafkaTestKitClass → KafkaTestKit

52.  def toString(): String

    Definition Classes

    AnyRef → Any

53.  final def wait(): Unit

    Definition Classes

    AnyRef

    Annotations

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

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

    Definition Classes

    AnyRef

    Annotations

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

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

    Definition Classes

    AnyRef

    Annotations

    @throws(classOf[java.lang.InterruptedException]) @native()

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

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

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