我在编写一个使用scala中的React式kafka模块的代码。我的代码使用以下行:
val kafka = new ReactiveKafka()
kafka.consume(ConsumerProprties(...).readFromEndOfStream())
kafka.publish(ProducerProperties(...))
我有两个问题:
我看到我的代码导入了com.softwaremill.react.kafka包。你能给我一个详细文档的链接吗?到目前为止我找到的所有信息都太过谨慎了。
我想检查服务器是否仍然连接到Kafka。如何使用com.softwaremill.react.kafka包完成?
暂无答案!
目前还没有任何答案,快来回答吧!