Hi Ted, That's exactly the method I've been looking at to understand the INFO message better and don't see how they relate. I don't see how it could help. Care to shed more light on it? Thanks.
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 On Fri, Sep 22, 2017 at 10:16 PM, Ted Yu <yuzhih...@gmail.com> wrote: > 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 > > >
