如何在 Scala 中为 Kafka (ConsumerRebalanceListener) 实现 Java 接口？答案

【问题标题】：How to implement Java Interface for Kafka (ConsumerRebalanceListener) in Scala?如何在 Scala 中为 Kafka (ConsumerRebalanceListener) 实现 Java 接口？
【发布时间】：2018-04-30 12:59:23
【问题描述】：

Kafka有一个Java接口：

public interface ConsumerRebalanceListener

当触发使用重新平衡侦听器时，如何在 Scala 中实现该接口：subscribing to a topic？

谢谢。

【问题讨论】：

extends ConsumerRebalanceListener...你试过了吗？

标签： java scala apache-kafka

【解决方案1】：

你可以这样做：

class ImplemetedClass extends ConsumerRebalanceListener{
  // Your implemenatation
}

【讨论】：