Artem Bilan

Answer “yes” for all your questions. Since it is a sample and it has to be an independent project everything is totally fine. We chose Maven because back in days...

@PPrydorozhnyi , that is not possible if your `template` is a singleton bean in the application context. The logic there is like this: ``` public void afterSingletonsInstantiated() { if (this.observationEnabled...

``` o.a.k.clients.admin.AdminClientConfig : AdminClientConfig values: ``` But that's correct, because `AdminClient` is not a `KafkaAdmin`. We talk about different object. Yes, `KafkaAdmin` uses `AdminClient` and does that this way: ```...

@PPrydorozhnyi , can you update your sample project, please, with build tool ? Not clear what dependencies you use there. According to README it supposed to be Gradle, so just...

@PPrydorozhnyi , I see what is going on. That `KafkaTemplate.clusterId()` is really guilty. When we call `send()` with observation concurrently, all those threads are meeting a `this.clusterId == null` condition....

See the fix: https://github.com/spring-projects/spring-kafka/pull/2944

Looks like it fails here: ``` SaslClient retvalSaslClient = Sasl.createSaslClient(mechs, clientPrincipalName, servicePrincipal, host, configs, callbackHandler); if (retvalSaslClient == null) { throw new SaslAuthenticationException("Failed to create SaslClient with mechanism " +...

Here is some old discussion as well: https://github.com/spring-projects-experimental/spring-native/issues/1416. Doesn't look in the end that there is a solution...

This article says something promising: https://jeqo.github.io/posts/2022-03-18-kafka-clients-graalvm/#sasl-authentication ``` -H:AdditionalSecurityProviders=com.sun.security.sasl.Provider --initialize-at-run-time=org.apache.kafka.common.security.authenticator.SaslClientAuthenticator ``` Just give it a try, please!

The Event Hubs is a messaging broker. It is essentially not Apache Kafka. It is nice of Azure that they provide a compatibility with Kafka client, so there is not...