The kafka topic is consumer as "UNKNOWN_TOPIC_OR_PARTITION" using the storm job, but the ranger has authorized the user to consume the topic. Kafka has kerberos turned on; Storm does not turn on kerberos, and Storm does not enable the ranger plugin.
I tried to use kafka-topics.sh to consume topic, ranger authorized to pass, consumer success.
Kinit authentication has been used before both operations.
Where is the problem? Please help me. Thank you very much.