Azure eventhub as kafka: проблема авторизации тем

Question

Я создал пространство имен концентратора событий с включенным 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\”;”
  }
}

Не могли бы вы помочь?

Спасибо

Answer 1

Мне удалось решить проблему, исправив версию kafka в pom.xml.Судя по всему, Azure поддерживает версии выше kafka 0.10.Как только я изменил зависимости, он работал нормально.

Answer 2

Я столкнулся с этой проблемой, начиная со вчерашнего дня, и добавил следующее свойство, чтобы решить эту проблему.

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

Обратите внимание, что мы используем концентратор событий Spring Cloud + Azure

Однако яЯ не могу получать сообщения от концентратора событий.