Details
-
Bug
-
Status: Open
-
Major
-
Resolution: Unresolved
-
None
-
None
-
None
-
None
Description
Migrate samza to use the latest kafka libraries. We found out a bunch of backwards-incompatible API changes when moving to the latest version of Kafka.
This will entail changing some of the samza unit tests (that rely on kafka test classes like MockProducer, EmbeddedZookeeper, Utils, and libraries for port assignment in unit tests).