Hi folks,
I appreciate this is not stated as being supported, and so there is no
failing on pekko's side here. Just bringing it up for your awareness.
The current 1.0.0 of pekko-connectors-kafka is not compatible with
kafka_clients 3.7.0
Error => org.apache.kafka.clients.consumer.KafkaConsumer with message
Cannot locate field named groupId for class
org.apache.kafka.clients.consumer.KafkaConsumer. Class loader:
jdk.internal.loader.ClassLoaders$AppClassLoader@251a69d7:
java.lang.IllegalStateException: Cannot locate field named groupId for
class org.apache.kafka.clients.consumer.KafkaConsumer
[java] at
kanela.agent.libs.net.bytebuddy.asm.Advice$OffsetMapping$ForField$Unresolved.resolve(Advice.java:2556)
[java] at
kanela.agent.libs.net.bytebuddy.asm.Advice$OffsetMapping$ForField.resolve(Advice.java:2481)
[java] at
kanela.agent.libs.net.bytebuddy.asm.Advice$Dispatcher$Inlining$Resolved$ForMethodExit.doApply(Advice.java:9868)
[java] Apr 10, 2024 10:16:19 AM
com.hazelcast.internal.partition.impl.PartitionStateManager at
kanela.agent.libs.net.bytebuddy.asm.Advice$Dispatcher$Inlining$Resolved$ForMethodExit.apply(Advice.java:9826)
[java] INFO: [10.69.28.36]:5701 [dev] [5.3.6] Initializing
cluster partition table arrangement...
[java]
[java] at
kanela.agent.libs.net.bytebuddy.asm.Advice$Dispatcher$Inlining$Resolved$AdviceMethodInliner.visitMethod(Advice.java:9232)
[java] at
kanela.agent.libs.net.bytebuddy.jar.asm.ClassReader.readMethod(ClassReader.java:1353)
[java] at
kanela.agent.libs.net.bytebuddy.jar.asm.ClassReader.accept(ClassReader.java:744)
[java] at
kanela.agent.libs.net.bytebuddy.jar.asm.ClassReader.accept(ClassReader.java:424)
[java] at
kanela.agent.libs.net.bytebuddy.asm.Advice$Dispatcher$Inlining$Resolved$AdviceMethodInliner.apply(Advice.java:9225)
[java] at
kanela.agent.libs.net.bytebuddy.asm.Advice$AdviceVisitor$WithExitAdvice.onUserEnd(Advice.java:11770)
[java] at
kanela.agent.libs.net.bytebuddy.asm.Advice$AdviceVisitor.visitMaxs(Advice.java:11549)
[java] at
kanela.agent.libs.net.bytebuddy.jar.asm.ClassReader.readCode(ClassReader.java:2666)
[java] at
kanela.agent.libs.net.bytebuddy.jar.asm.ClassReader.readMethod(ClassReader.java:1514)
[java] at
kanela.agent.libs.net.bytebuddy.jar.asm.ClassReader.accept(ClassReader.java:744)
[java] at
kanela.agent.libs.net.bytebuddy.jar.asm.ClassReader.accept(ClassReader.java:424)
[java] at
kanela.agent.libs.net.bytebuddy.dynamic.scaffold.TypeWriter$Default$ForInlining.create(TypeWriter.java:4014)
[java] at
kanela.agent.libs.net.bytebuddy.dynamic.scaffold.TypeWriter$Default.make(TypeWriter.java:2224)
[java] at
kanela.agent.libs.net.bytebuddy.dynamic.DynamicType$Builder$AbstractBase$UsingTypeWriter.make(DynamicType.java:4057)
[java] at
kanela.agent.libs.net.bytebuddy.agent.builder.AgentBuilder$Default$ExecutingTransformer.doTransform(AgentBuilder.java:12225)
[java] at
kanela.agent.libs.net.bytebuddy.agent.builder.AgentBuilder$Default$ExecutingTransformer.transform(AgentBuilder.java:12160)
[java] at
kanela.agent.libs.net.bytebuddy.agent.builder.AgentBuilder$Default$ExecutingTransformer.access$1800(AgentBuilder.java:11869)
[java] at
kanela.agent.libs.net.bytebuddy.agent.builder.AgentBuilder$Default$ExecutingTransformer$Java9CapableVmDispatcher.run(AgentBuilder.java:12647)
[java] at
kanela.agent.libs.net.bytebuddy.agent.builder.AgentBuilder$Default$ExecutingTransformer$Java9CapableVmDispatcher.run(AgentBuilder.java:12579)
[java] at
java.base/java.security.AccessController.doPrivileged(AccessController.java:399)
[java] at
kanela.agent.libs.net.bytebuddy.agent.builder.AgentBuilder$Default$ExecutingTransformer.doPrivileged(AgentBuilder.java)
[java] at
kanela.agent.libs.net.bytebuddy.agent.builder.AgentBuilder$Default$ExecutingTransformer.transform(AgentBuilder.java:12103)
[java] at
kanela.agent.libs.net.bytebuddy.agent.builder.AgentBuilder$Default$ExecutingTransformer$ByteBuddy$ModuleSupport.transform(Unknown
Source)
[java] at
java.instrument/sun.instrument.TransformerManager.transform(TransformerManager.java:188)
[java] at
java.instrument/sun.instrument.InstrumentationImpl.transform(InstrumentationImpl.java:541)
[java] at java.base/java.lang.ClassLoader.defineClass1(Native Method)
[java] at
java.base/java.lang.ClassLoader.defineClass(ClassLoader.java:1012)
[java] at
java.base/java.security.SecureClassLoader.defineClass(SecureClassLoader.java:150)
[java] at
java.base/jdk.internal.loader.BuiltinClassLoader.defineClass(BuiltinClassLoader.java:862)
[java] at
java.base/jdk.internal.loader.BuiltinClassLoader.findClassOnClassPathOrNull(BuiltinClassLoader.java:760)
[java] at
java.base/jdk.internal.loader.BuiltinClassLoader.loadClassOrNull(BuiltinClassLoader.java:681)
[java] at
java.base/jdk.internal.loader.BuiltinClassLoader.loadClass(BuiltinClassLoader.java:639)
[java] at
java.base/jdk.internal.loader.ClassLoaders$AppClassLoader.loadClass(ClassLoaders.java:188)
[java] at java.base/java.lang.ClassLoader.loadClass(ClassLoader.java:520)
[java] at
org.apache.pekko.kafka.ConsumerSettings$.createKafkaConsumer(ConsumerSettings.scala:233)
[java] at
org.apache.pekko.kafka.ConsumerSettings$.$anonfun$apply$3(ConsumerSettings.scala:118)
[java] at
org.apache.pekko.kafka.internal.KafkaConsumerActor.org$apache$pekko$kafka$internal$KafkaConsumerActor$$applySettings(KafkaConsumerActor.scala:432)
[java] at
org.apache.pekko.kafka.internal.KafkaConsumerActor.preStart(KafkaConsumerActor.scala:407)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
