Open datto-aparrill opened 5 years ago
The current client is several major versions old and uses deprecated functionality (zookeeper offsets) that doesn't play nice with other clients.
This PR changes the project to use the new kafka consumer API.
Note that existing configurations are incompatible, since the new kafka client does not use the same config names as the old one.
This looks great. Is it worth documenting the updating the config documentation in the readme, too?
The current client is several major versions old and uses deprecated functionality (zookeeper offsets) that doesn't play nice with other clients.
This PR changes the project to use the new kafka consumer API.
Note that existing configurations are incompatible, since the new kafka client does not use the same config names as the old one.