Awesome. After adding --new-consumer and --bootstrap-server, I got it
working.
Thanks a lot.
On Fri, Sep 16, 2016 at 5:33 AM, Rajini Sivaram <
rajinisiva...@googlemail.com> wrote:
> Max,
>
> You need to use the new consumer since the old consumer does not support
> security features. For console
Max,
You need to use the new consumer since the old consumer does not support
security features. For console-consumer, you need to add the option
--new-consumer.
On Fri, Sep 16, 2016 at 10:14 AM, Max Bridgewater wrote:
> Thanks Rajini. That was the issue. Now I am facing another one. I am not
>
Thanks Rajini. That was the issue. Now I am facing another one. I am not
sure why my consumer is trying to use the topic in PLAINTEXT. The consumer
config is:
security.protocol=SASL_PLAINTEXT
sasl.mechanism=PLAIN
KAFKA_OPTS is set to /home/kafka/kafka_client_jaas.conf. I can confirm that
this fi
Max,
I think there is a typo in your configuration. You intended admin password
to be admin-secret?
KafkaServer {
org.apache.kafka.common.security.plain.PlainLoginModule required
username="admin"
password="admin-secret"
user_admin="alice-secret" *=> Change to **"admin-secret"*
use
