Hi, Just noticed that SessionExpireListener#handleNewSession (of KafkaHealthcheck) prints out the INFO message to the logs [1] and does nothing afterwards.
Subscribing to %s path to watch for new topics Why? Is the INFO correct? Where does the subscription happen? [1] https://github.com/apache/kafka/blob/trunk/core/src/main/scala/kafka/server/KafkaHealthcheck.scala?utf8=%E2%9C%93#L106 Pozdrawiam, Jacek Laskowski ---- https://about.me/JacekLaskowski Spark Structured Streaming https://bit.ly/spark-structured-streaming Mastering Apache Spark 2 https://bit.ly/mastering-apache-spark Follow me at https://twitter.com/jaceklaskowski
