What is the correct way of using SSL between the client and brokers if client certificates are not used? The broker (0.9.0.0) reports the following in the log
WARN SSL peer is not authenticated, returning ANONYMOUS instead as a result of this (I belive) KafkaConsumer.listTopics() returns an empty map. Does this require a custom Authenticator on the broker side? If so, are there examples on how to do that? Interestingly enough, modifying (no other changes) listeners=SSL://:9094 to listeners=PLAINTEXT://:9093,SSL://:9094 makes the listTopics() method to return the topics. If SSL is used by the consumer in both cases, I'm not sure why having the plaintext port would affect the SSL behavior. -- Best regards, Marko www.kafkatool.com
