Bump kafka-clients to 3.9.1 and Testcontainers Kafka module

[chemicL]

Upon community request, this PR upgrades the kafka-clients dependency to 3.9.1.

Resolves #409

[chemicL]

@mxcross, @maksimlikharevau, would you be so kind to validate if this upgrade works fine in your setup? If that's the case, I'd be happy to merge and release this.

[maksimlikharevau]

the only question would be,

public Uuid clientInstanceId(Duration timeout) {
        throw new UnsupportedOperationException("clientInstanceId not supported");
    }

maybe throw IllegalStateException, to be in line with API contract, other than that it looks good.

[chemicL]

public Uuid clientInstanceId(Duration timeout) {
        throw new UnsupportedOperationException("clientInstanceId not supported");
    }

maybe throw IllegalStateException, to be in line with API contract, other than that it looks good.

Actually, this code is in a supporting test class (reactor.kafka.mock.MockProducer) and the UnsupportedOperationException was inspired by the code in kafka-clients library itself in org.apache.kafka.clients.producer.MockProducer#clientInstanceId:

        if (telemetryDisabled) {
            throw new IllegalStateException();
        }
        if (clientInstanceId == null) {
            throw new UnsupportedOperationException("clientInstanceId not set");
        }
        // ...

[chemicL]

Let's gather some community feedback if this is actually desired. The simple solution is to simply specify the kafka-clients dependency explicitly using your build tool.

[maksimlikharevau]

I honestly have no strong opinion, my comment was simply due to the list of exceptions thrown from the method in the API doc, UnsupportedOperationException would work as well.