@nehanarkhede was there a specific reason the new consumer is written in Java? The previous consumers are all written in Scala.