スレッドで使用する実行可能なクラスを作成しようとしています。このクラスの目的は、KafkaStreamを取得し、ストリームを介して受信するすべてのメッセージに関数を適用することですが、クラスにストリームを渡そうとすると、次のコンパイラ エラーが発生します: "scala:45: class KafkaStream takes typeパラメーター"。
class streamOperator extends Runnable {
def run(f: String => Any, stream: KafkaStream) {
for (messageAndTopic <- stream) {
var message = new String(messageAndTopic.message)
f(message)
}
}
}
これがクラスです。この問題は、Scala のクラスにパラメーターを渡す方法に関係しているに違いありませんが、私はまだ Scala に慣れていません。
さらに、関数を実行可能にすることは可能ですか? クラスよりも関数に渡す方が簡単だと思います。