The code imports and uses Session from Kafka from package kafka.network.RequestChannel.Session. This inner class Session is no longer there in Kafka >= 3.8. It has been moved to org.apache.kafka.network.Session.
In order to support Kafka >= 3.8 the current import needs to be fixed.
Luckily Session contains no logic.
Fix by adding Session class to the repo and stop using the class from Kafka.
The code imports and uses Session from Kafka from package
kafka.network.RequestChannel.Session
. This inner class Session is no longer there in Kafka >= 3.8. It has been moved to org.apache.kafka.network.Session.In order to support Kafka >= 3.8 the current import needs to be fixed.
Luckily
Session
contains no logic.Fix by adding
Session
class to the repo and stop using the class from Kafka.