Change default compression to :snappy
MODIFY
config/config.exs
config/config.exs
@@ -66,7 +66,7 @@ config :kafka_ex,
keyfile: File.cwd!() <> "/ssl/key.pem"
],
- snappy_module: :snappyer,
+ snappy_module: :snappy,
# set this to the version of the kafka broker that you are using
# include only major.minor.patch versions. must be at least 0.8.0
# use "kayrock" for the new client

Change default compression to :snappy