search

FrankChen021 / bithon

An observability platform mainly for Java
Apache License 2.0
15 stars 4 forks source link

java.lang.NoClassDefFoundError from kafka plugin #641

Closed FrankChen021 closed 10 months ago

FrankChen021 commented 10 months ago 
java.lang.NoClassDefFoundError: org/apache/kafka/clients/ClientResponse
    at org.bithon.agent.plugin.apache.kafka.producer.interceptor.Sender$HandleProduceResponse.before(Sender$HandleProduceResponse.java:37) ~[?:?]
    at org.apache.kafka.clients.producer.internals.Sender.handleProduceResponse(Sender.java:549) ~[kafka-clients-2.8.0.jar:?]
    at org.apache.kafka.clients.producer.internals.Sender.lambda$sendProduceRequest$3(Sender.java:793) ~[kafka-clients-2.8.0.jar:?]
    at org.apache.kafka.clients.ClientResponse.onComplete(ClientResponse.java:109) [kafka-clients-2.8.0.jar:?]
    at org.apache.kafka.clients.NetworkClient.completeResponses(NetworkClient.java:584) [kafka-clients-2.8.0.jar:?]
    at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:576) [kafka-clients-2.8.0.jar:?]
    at org.apache.kafka.clients.producer.internals.Sender.runOnce(Sender.java:327) [kafka-clients-2.8.0.jar:?]
    at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:242) [kafka-clients-2.8.0.jar:?]
    at java.lang.Thread.run(Thread.java:748) [?:1.8.0_275]
FrankChen021 commented 10 months ago 
java.lang.NoClassDefFoundError: org/apache/kafka/common/TopicPartition
    at org.bithon.agent.plugin.apache.kafka.producer.interceptor.SenderMetrics$UpdateProduceRequestMetrics.after(SenderMetrics$UpdateProduceRequestMetrics.java:84) ~[?:?]
    at org.apache.kafka.clients.producer.internals.Sender$SenderMetrics.updateProduceRequestMetrics(Sender.java:944) [kafka-clients-2.8.0.jar:?]
    at org.apache.kafka.clients.producer.internals.Sender.sendProducerData(Sender.java:389) [kafka-clients-2.8.0.jar:?]
    at org.apache.kafka.clients.producer.internals.Sender.runOnce(Sender.java:326) [kafka-clients-2.8.0.jar:?]
    at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:242) [kafka-clients-2.8.0.jar:?]
    at java.lang.Thread.run(Thread.java:748) [?:1.8.0_275]
FrankChen021 commented 10 months ago

ocurred when kafka-emitter in druid is enabled

FrankChen021 commented 10 months ago

The loader that works in other projects:

image

The loader that does not work in above case:

image image image