Exception in thread main org.apache.kafka.common.errors.TopicAuthorizationE



Exception in thread “main” org.apache.kafka.common.errors.TopicAuthorizationException: Not authorized to access topics: [demo1] 原因是该消费者组没有消费主题的权限,即 ACL 操作,当然换成 admin 是不存在这个问题的