kafka-connect-client
kafka-connect-client copied to clipboard
ConnectorStatus.getConnector() should return type-safe object instead of map
Current implementation of ConnectorStatus.getConnector() returns a Map with "state" and "worker_id". It would be handy to get Object with state as enum and worker_id as String. See also TaskStatus
that seems reasonable. I'm guessing the structure of that response hasn't really changed much if at all in the connect api.