Could not initialize class org.apache.kafka.common.record.CompressionType$SnappyConstructors

[boyi]

hello:


I encountered an exception.  error info :




org.apache.kafka.common.KafkaException: java.lang.NoClassDefFoundError: Could 
not initialize class 
org.apache.kafka.common.record.CompressionType$SnappyConstructors
        at 
org.apache.kafka.common.record.CompressionType$3.wrapForOutput(CompressionType.java:83)
        at 
org.apache.kafka.common.record.MemoryRecordsBuilder.<init>(MemoryRecordsBuilder.java:128)
        at 
org.apache.kafka.common.record.MemoryRecordsBuilder.<init>(MemoryRecordsBuilder.java:164)
        at 
org.apache.kafka.common.record.MemoryRecords.builder(MemoryRecords.java:512)
        at 
org.apache.kafka.common.record.MemoryRecords.builder(MemoryRecords.java:494)
        at 
org.apache.kafka.common.record.MemoryRecords.builder(MemoryRecords.java:442)
        at 
org.apache.kafka.clients.producer.internals.RecordAccumulator.recordsBuilder(RecordAccumulator.java:245)
        at 
org.apache.kafka.clients.producer.internals.RecordAccumulator.append(RecordAccumulator.java:221)
        at 
org.apache.kafka.clients.producer.KafkaProducer.doSend(KafkaProducer.java:864)
        at 
org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:803)
        at 
org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:690)
        ....
        at java.lang.Thread.run(Thread.java:748)
Caused by: java.lang.NoClassDefFoundError: Could not initialize class 
org.apache.kafka.common.record.CompressionType$SnappyConstructors
        at 
org.apache.kafka.common.record.CompressionType$3.wrapForOutput(CompressionType.java:81)
        ... 12 more