KafkaTestFixture

class KafkaTestFixture(clientPrefix: String = "wow-test-client") : BeforeEachCallback, TestWatcher

Constructors

constructor(clientPrefix: String = "wow-test-client")

open override fun beforeEach(context: ExtensionContext)

fun clientId(suffix: String = "client"): String

fun kafkaProperties(clientId: String = clientId()): Map<String, Any>

fun receiverOptions(clientId: String = clientId("receiver"), groupId: String = clientId("group")): ReceiverOptions<String, String>

fun senderOptions(clientId: String = clientId("sender")): SenderOptions<String, String>

open fun testAborted(context: ExtensionContext?, cause: @Nullable Throwable?)

open fun testDisabled(context: ExtensionContext?, reason: Optional<String?>?)

open override fun testFailed(context: ExtensionContext, cause: Throwable?)

open fun testSuccessful(context: ExtensionContext?)