I have a version of this working locally and would be happy to get a PR submitted once I kick the tires on it a bit more. But let me know of any requirements that you might want for this and if it would be a welcome addition. Currently it reflects the existing Kafka layer with very few changes, e.g. :
import _root_.kafka.server.KafkaConfig
import io.github.embeddedkafka.schemaregistry.{EmbeddedKWithSR, EmbeddedKafka, EmbeddedKafkaConfig}
import zio.*
object KafkaSchemaRegistry {
/**
* Creates an in-memory Kafka instance with a random port.
*/
def embedded: ZLayer[Any, Throwable, Kafka] = embeddedWith(_ => Map.empty)
// ....