See KafkaHealthcheck#register() I think it means registration for the zookeeper path.
On Fri, Sep 22, 2017 at 12:38 PM, Jacek Laskowski <ja...@japila.pl> wrote: > 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 >
