scala - 如何检查 Kafka 是否与 ReactiveKafka 连接？

Question

我正在编写一个在 Scala 中使用 reactive-kafka 模块的代码。我的代码使用以下行：

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

我有两个问题：

1. 我看到我的代码导入了包 com.softwaremill.react.kafka。你能给我一个详细文档的链接吗？到目前为止我发现的所有信息都太简洁了。

2. 我想检查服务器是否仍然连接到 Kafka。如何使用 com.softwaremill.react.kafka 包来做到这一点？