Как реализовать Java-интерфейс для Kafka (ConsumerRebalanceListener) в Scala?

Question

Есть интерфейс Java для Кафки:

public interface ConsumerRebalanceListener

Как реализовать этот интерфейс в Scala, когда триггер для использования слушателя ребалансировки: subscribing to a topic?

Спасибо.

Answer 1

Вы можете сделать это так:

class ImplemetedClass extends ConsumerRebalanceListener{
  // Your implemenatation
}