CompressionFactory imports snappy jar in a pattern match. The purpose of importing it this way seems to be avoiding the import unless snappy compression is actually required. However, kafka throws a ClassNotFoundException if snappy jar is removed at runtime from lib_managed.
This exception can be easily seen by producing some data with the console producer.
|Field||Original Value||New Value|
|Priority||Blocker [ 1 ]||Major [ 3 ]|
|Fix Version/s||0.8.2 [ 12326167 ]|
|Fix Version/s||0.8.1 [ 12322960 ]|