Spring Cloud Stream Kafka Binder и Spring Cloud Azure EventHub-совместимая версия для Spring Boot> 1.5.20 - PullRequest
Новая
       70

Spring Cloud Stream Kafka Binder и Spring Cloud Azure EventHub-совместимая версия для Spring Boot> 1.5.20

0 голосов
/ 29 апреля 2020

Я успешно использовал Spring Cloud Stream Kafka Binder (org.springframework.cloud:spring-cloud-starter-stream-kafka:3.0.1.RELEASE) и Spring Cloud Azure Концентраторы событий (com.microsoft. azure: spring-cloud-starter- azure -eventhubs: 1.2.3) с Spring Boot 2.2.6 для Publi sh и использованием сообщений из Azure Event Hub (с включенным API Kafka).

Тем не менее, когда я пытаюсь интегрировать те же версии библиотек Spring Cloud с Spring Boot 1.5.22, я сталкиваюсь с проблемой

Когда я использовал spring-cloud-starter-stream-kafka: 1.3.4.RELEASE и com.microsoft. azure: spring-cloud-starter- azure -eventhubs: 1.1.0, я получаю zookeeper проблемы с подключением, вероятно, из-за другого набора свойств, необходимых для конфигурации 

2020-04-29 17:01:43.104  INFO 81976 --- [localhost:2181)] [org.apache.zookeeper.ClientCnxn         ] [-] [-] : Opening socket connection to server localhost/127.0.0.1:2181. Will not attempt to authenticate using SASL (unknown error)
2020-04-29 17:01:43.107  WARN 81976 --- [localhost:2181)] [org.apache.zookeeper.ClientCnxn         ] [-] [-] : Session 0x0 for server null, unexpected error, closing socket connection and attempting reconnect

    java.net.ConnectException: Connection refused
        at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
        at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
        at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361)
        at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1141)

Мой application.yaml выглядит следующим образом 

spring:
  cloud:
    azure:
      auto-create-resources: true
      credential-file-path: my.azureauth
      eventhub:
        checkpoint-storage-account: azuremigrationv2
        namespace: somenamespace
      region: Central US
      resource-group: some-rg
    stream:
      bindings:
        consumer:
          destination: event-hub-1
          group: testconsumergroup
          content-type: application/json
          nativeEncoding: true
          consumer:
            concurrency: 1
            valueSerde: JsonSerde
            requeue-rejected: true

Я хотел бы знать, какие версии библиотек я нас совместимы с Spring Boot> = 1.5.20

...