I have specified 3 bootstrap servers and when I checked from Kafdrop web console, there are 12 brokers.
I managed to serve Kafdrop in my local PC. When I click a certain topic, an exception named ClusterAuthorizationException occurred, but I can see the topic description and it's contents.
Error message:
Caused by: org.apache.kafka.common.errors.ClusterAuthorizationException: Request Request(processor=5, connectionId=10.117.148.62:11498-10.99.179.97:56717-2951640, session=Session(User:abc-1,10.99.179.97/10.99.177.97), listenerName=ListenerName(SASL_SSL), securityProtocol=SASL_SSL, buffer=null) is not authorized.
I successfully ran bin/kafka-console-consumer.sh to consume message from my Kafka server.
I have specified 3 bootstrap servers and when I checked from Kafdrop web console, there are 12 brokers.
I managed to serve Kafdrop in my local PC. When I click a certain topic, an exception named
ClusterAuthorizationException
occurred, but I can see the topic description and it's contents.Error message:
I successfully ran
bin/kafka-console-consumer.sh
to consume message from my Kafka server.Kafka config:
.env: KAFKA_BROKERCONNECT="10.117.148.62:11498,10.117.148.61:11498,10.117.148.63:11498" KAFKA_PROPERTIES="BASE64 of my config file" JVM_OPTS="-Xms16M -Xmx48M -Xss180K -XX:-TieredCompilation -XX:+UseStringDeduplication -noverify -Dcom.sun.net.ssl.checkRevocation=false" SERVER_SERVELET_CONTEXTPATH="/"
It takes time, but I can get the messages from the console: