Azure eventthub as kafka：主题授权问题答案

【问题标题】：Azure eventhub as kafka : Topic Authorization issueAzure eventthub as kafka：主题授权问题
【发布时间】：2018-10-09 18:18:34
【问题描述】：

我创建了一个启用了 kafka 的事件中心命名空间，并创建了一个具有“管理、发送和侦听”访问策略的事件中心。我能够生成此消息，但收到错误“org.apache.kafka.common.errors.TopicAuthorizationException：未授权访问主题：”。

我的 Akka 消费者中的参数是：

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\”;”
  }
}

您能帮忙吗？

谢谢

【问题讨论】：

标签： apache-kafka azure-eventhub

【解决方案1】：

我能够通过修复 pom.xml 中的 kafka 版本来解决该问题。显然，Azure 仅支持 kafka 0.10 以上的版本。一旦我更改了依赖项，它就可以正常工作了。

【讨论】：

【解决方案2】：

我从昨天开始就面临这个问题，并添加了下面的属性来解决这个问题。

spring.cloud.stream.kafka.binder.autoCreateTopics=false

请注意，我们使用的是 spring cloud + azure event hub

但是，我无法从事件中心接收消息。

【讨论】：