Update to Kafka 3.0.0

[scholzj]

trafficstars

Kafka 3.0.0 is a major release and as such it does some breaking changes such as removes some old methods which were deprecated before and adds new methods etc. This PR updates the tracing support for Kafka clients to use Kafka 3.0.

Apart form removing some removed methods and adding some new, the Embedded Kafka cluster from Spring does not support Kafka 3.0.0 yet. So I replaced it with the Embedded Kafka Cluster which is part of Apache Kafka itself. This should make the tests less dependent on Spring Kafka.

It would be great if this could get reviewed and if we can have a new release to use with Kafka 3.0.0.

[scholzj]

Any chance someone can look at this?

[hsargsyan]

Any updates on this?

[jondey]

Interested in this PR too. Any timescales for new version?

[moustafa-zein]

To support Kafka 3.2.x you need to add a new methods in TracingKafkaConsumer ad make a new PR.

  @Override
  public void enforceRebalance(String s) {

  }
  

[solo-seven]

I was able to get this working in my fork with the Kafka 3.2.1 client, and I have tested it with Jaeger and Confluent Platform 7.2.1. The work is here: https://github.com/bashburn/java-kafka-client which I forked from this fork. Let me know, and I can try to add it here, or create a new PR if needed.

[kdsundhiya]

Can this be merged ?

[solo-seven]

I created a new PR based on my update to the libraries. It is PR #101 if we want to close this one and look at that one.