Details
-
Bug
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
None
-
None
-
None
-
None
Description
Currently it uses kafka.admin.AdminClient, whis is old and soon to be deprecated version.
We need to move to org.apache.kafka.clients.admin.AdminClient (which uses Java).
Among other things, it should give us a callback facility to synchnorize some async operations (like create and clear streams). After that we can rewrite create/clear stream for SamzaKafkaAdmin.
Attachments
Issue Links
- is related to
-
SAMZA-1793 Upgrade to recent API for kafka consumer / producer.
- Resolved
- links to