@Override
        public boolean equals(Object o) {
            if (this == o) return true;
            if (!(o instanceof LeaderState)) return false;
            LeaderState that = (LeaderState) o;
            return Objects.equals(allMembers, that.allMembers)
                    && Objects.equals(connectorOwners, that.connectorOwners)
                    && Objects.equals(taskOwners, that.taskOwners);
        }
Get the version of the connect protocol that is currently active in the group of workers.

@return the current connect protocol version
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/WorkerCoordinator.java