how to resolve java.lang.ClassNotFoundException org.xerial.snappy.SnappyInputStream during upgrade

You are using snappy-java as compression type and receive the following exception during your upgrade to CDC Replication Engine for Kafka  11.4.2_5125 or later subversion agent.

Caused by: java.lang.ClassNotFoundException org.xerial.snappy.SnappyInputStream| at java.lang.Class.forNameImpl(Native Method)|  at java.lang.Class.forName(Class.java:333)|  at org.apache.kafka.common.record.CompressionType.findConstructor(CompressionType.java:195)|  at org.apache.kafka.common.record.CompressionType.access$100(CompressionType.java:37)|  at org.apache.kafka.common.record.CompressionType$SnappyConstructors.<clinit>(CompressionType.java:187)|  at org.apache.kafka.common.record.CompressionType$3.wrapForInput(CompressionType.java:90)|  at org.apache.kafka.common.record.DefaultRecordBatch.compressedIterator(DefaultRecordBatch.java:257)|  at org.apache.kafka.common.record.DefaultRecordBatch.streamingIterator(DefaultRecordBatch.java:335)|  at org.apache.kafka.clients.consumer.internals.Fetcher$PartitionRecords.nextFetchedRecord(Fetcher.java:1102)|  at org.apache.kafka.clients.consumer.internals.Fetcher$PartitionRecords.fetchRecords(Fetcher.java:1139)|  at org.apache.kafka.clients.consumer.internals.Fetcher$PartitionRecords.access$1400(Fetcher.java:993)|  at org.apache.kafka.clients.consumer.internals.Fetcher.fetchRecords(Fetcher.java:527)|  at org.apache.kafka.clients.consumer.internals.Fetcher.fetchedRecords(Fetcher.java:488)|  at org.apache.kafka.clients.consumer.KafkaConsumer.pollOnce(KafkaConsumer.java:1185)|  at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1115)|  at com.datamirror.ts.target.publication.KafkaTargetPublisherProxy.computeCsnBaseRecordUsingProgressStreamConsumer(KafkaTargetPublisherProxy.java:838)