Oğuzhan Soykan
06/10/2024, 9:01 AMvalidate {
kafka {
val productId = randomString() + "[productCreated]"
publish("product", message = ProductCreated(productId), key = randomString().some())
shouldBePublished<ProductCreated> {
actual.productId == productId
}
shouldBeConsumed<ProductCreated> {
actual.productId == productId
}
}
If you have any feedback please reach out to me!