Details
-
Bug
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
0.7
-
None
-
None
-
None
Description
The obvious thing fails:
CompressionCodec.getCompressionCodec(1) results in cannot find symbol
symbol : method getCompressionCodec(int)
location: interface kafka.message.CompressionCodec
Writing a switch statement with kafka.message.NoCompressionCodec$.MODULE$ and duplicating the logic in CompressionCodec.getCompressionCodec is no fun, nor is creating a Hashtable just to call Utils.getCompressionCodec. I'm not sure if there is a magic keyword to make it easy for javac to understand which CompressionCodec I'm referring to.