Github user liu-zhaokun commented on the issue:
https://github.com/apache/spark/pull/19856
@jerryshao
I think the log can't reflect the behavior of consumer connection,because
consumer.create doesn't do any connect,it only construct a
ZookeeperConsumerConnector instance,so the right position is where zkclient
connect to zk. ReliableKafkaReceiver is not marked deprecated,so users will use
it.To avoid misleading by this log when a problem of connect to zk occur ,I
think we should fix it.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
