awaitStarted

suspend fun awaitStarted()

Waits until the topic's partitions are known and the lease group joined.