Как реализовать SimpleConsumer в версии Kafka 2.0?

Question

Я использую версию kafka 2.0 со scala, некоторые из apis устарели во второй версии. Ниже

Это доступно в версиях Kafka 0.9 и .8, но во 2-й версии я не нашел ни одного API для SimpleConsumer Map[TopicAndPartition, SimpleConsumer] = Map[TopicAndPartition, SimpleConsumer]()

Вот так некоторые из нижеприведенных apis не могут найти в 2

• SimpleConsumer

• PartitionOffsetRequestInfo

• getOffsetsBefore

• OffsetRequest

Не могли бы вы помочь мне, как реализовать с использованием в Scala.