Compilation issue while building locally

[pradi0809]

The method below in the class KafkaConnectService.java fails to compile when built locally .

public Flux<String> getConnectorNames(KafkaCluster cluster, String connectName) {
    return api(cluster, connectName)
        .flux(client -> client.getConnectors(null))
        // for some reason `getConnectors` method returns the response as a single string
        .collectList().map(e -> e.get(0))
        .map(this::parseConnectorsNamesStringToList)
        .flatMapMany(Flux::fromIterable);
  }

This can be rewritten as below:

public Flux<String> getConnectorNames(KafkaCluster cluster, String connectName) {
    return api(cluster, connectName)
        .mono(client -> client.getConnectors(null))
        .flatMapMany(Flux::fromIterable)
        // for some reason `getConnectors` method returns the response as a single string
        .collectList().map(e -> e.get(0))
        .map(this::parseConnectorsNamesStringToList)
        .flatMapMany(Flux::fromIterable);
  }

By the way, to make the above code work, another change is required in the class RetryingKafkaConnectClient.java to the below method.

@Override
  public Flux<String> getConnectors(String search) throws WebClientResponseException {
    return withRetryOnConflict(super.getConnectors(search));
  }

This needs to be rewritten as below:

  @Override
  public Mono<List<String>> getConnectors(String search) throws WebClientResponseException {
    return withRetryOnConflict(super.getConnectors(search));
  }

Let me know if this is a viable option. Thnx!

[Haarolean]

Hi, this code is about 1 year old according to git blame, and it perfectly compiles both locally and in CI. If it doesn't for you, please provide exact steps to reproduce.

Replacing this with Mono makes no sense as it levels out the benefits of having a Flux.

[pradi0809]

Here is the stack I am using to compile the code from main branch.

Corretto-17.0.11.9.1
Apache Maven 3.9.6
Macbook Pro M3 chipset

Here is the command I am issuing as per the documentation:

./mvnw clean install -Dmaven.test.skip=true -Pprod

[Haarolean]

can you provide the logs/output?