我创建了一个启用kafka的eventhub命名空间，并创建了一个访问策略为“manage，send和listen”的eventhub。我可以生成此消息，但得到错误“org.apache.kafka.common.errors.topicauthorizationexception:无权访问主题：”。
我的akka consumer中的参数是：

akka.kafka.consumer {
  #Akka Kafka consumer properties defined here
  wakeup-timeout=60s

  # Properties defined by org.apache.kafka.clients.consumer.ConsumerConfig
  # defined in this configuration section.
  kafka-clients {
    request.timeout.ms=60000
    group.id=$Default

    bootstrap.servers=“<EventbusDomain>:9093"
    sasl.mechanism=PLAIN
    security.protocol=SASL_SSL
    sasl.jaas.config="org.apache.kafka.common.security.plain.PlainLoginModule required username=\"$ConnectionString\" password=\”<Connection String\”;”
  }
}

你能帮忙吗？
谢谢