scala - Kafka が ReactiveKafka と接続されていることを確認するには?

翻译自：https://stackoverflow.com/questions/39066117 2016-08-21T15:58:58.100

315 次

Scalaでreactive-kafkaモジュールを使用するコードに取り組んでいます。私のコードは次のような行を使用します。

val kafka = new ReactiveKafka()
kafka.consume(ConsumerProprties(...).readFromEndOfStream())
kafka.publish(ProducerProperties(...))

2 つの質問があります。

私のコードがパッケージ com.softwaremill.react.kafka をインポートしていることがわかります。詳細なドキュメントへのリンクを教えてもらえますか? これまでに見つけたすべての情報は、あまりにも良心的です。
サーバーがまだ Kafka に接続されていることを確認したい。com.softwaremill.react.kafka パッケージを使用してどうすればよいですか?

0 に答える 0