如何检查Kafka与ReactKafka的联系?

yrdbyhpb  于 2021-06-08  发布在  Kafka
关注(0)|答案(0)|浏览(270)

我在编写一个使用scala中的React式kafka模块的代码。我的代码使用以下行:

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

我有两个问题:
我看到我的代码导入了com.softwaremill.react.kafka包。你能给我一个详细文档的链接吗?到目前为止我找到的所有信息都太过谨慎了。
我想检查服务器是否仍然连接到Kafka。如何使用com.softwaremill.react.kafka包完成?

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题