addFilterWithCallback

fun addFilterWithCallback(filter: (ConsumerRecord<ByteArray, T>) -> Boolean, callback: (ConsumerRecord<ByteArray, T>) -> Unit)