consumerListener

fun consumerListener(consumerAdded: (id: String, consumer: Consumer<*, *>) -> Unit = { _, _ -> }, consumerRemoved: (id: String, consumer: Consumer<*, *>) -> Unit = { _, _ -> })