KafkaTopicProvisioner - Не удалось создать темы

Question

KafkaTopicProvisioner - не удалось создать темы 2021-04-27T08:48:12.806690772Z org.apache.kafka.common.errors.PolicyViolationException: службе не удалось обработать запрос; пожалуйста, повторите операцию. Дополнительные сведения о типах исключений и правильной обработке исключений см. На странице http://go.microsoft.com/fwlink/?LinkId=761101.

Я столкнулся с вышеуказанной проблемой при работе с Spring boot, Event Hub и Kafka. Ниже приведена зависимость, за которой я следую.

                  <groupId>org.apache.kafka</groupId>
            <artifactId>kafka-clients</artifactId>
            <version>2.7.0</version>
        </dependency>


        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-stream-kafka</artifactId>
            <version>2.0.1.RELEASE</version>
            <exclusions>
            <exclusion>
                <groupId>org.apache.kafka</groupId>
                <artifactId>kafka-clients</artifactId>
            </exclusion>
            </exclusions>
        </dependency>
        <dependency>
            <groupId>com.microsoft.azure</groupId>
            <artifactId>spring-cloud-azure-starter-eventhub</artifactId>
            <version>1.0.0.M2</version>
            <exclusions>
                <exclusion>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-starter-logging</artifactId>
                </exclusion>
                <exclusion>
                    <groupId>org.slf4j</groupId>
                    <artifactId>slf4j-api</artifactId>
                </exclusion>
                <exclusion>
                    <groupId>org.slf4j</groupId>
                    <artifactId>slf4j-simple</artifactId>
                </exclusion>
            </exclusions>
        </dependency>

Answer 1

Вы можете импортировать зависимость "com.azure.spring:azure-spring-cloud-starter-eventhubs-kafka" вместо kafka-clients, spring-cloud-starter-stream-kafka и spring-cloud-starter-stream-kafka, который может ссылаться на https://docs.microsoft.com/azure/developer/java/spring-framework/configure-spring-cloud-stream-binder-java-app-kafka-azure-event-hub