Как проверить, что Кафка связана с ReactiveKafka?

Я работаю над кодом, который использует модуль реактивной кафки в Scala. Мой код использует такие строки, как:

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

У меня есть два вопроса:

  1. Я вижу, что мой код импортирует пакет com.softwaremill.react.kafka. Можете ли вы дать мне ссылку на подробную документацию? Вся информация, которую я нашел до сих пор, слишком сложная.

  2. Я хочу проверить, что сервер все еще подключен к Kafka. Как я могу сделать это с помощью пакета com.softwaremill.react.kafka?

Источник

0 ответов

Другие вопросы по тегам