kafka.coordinator -> new FindCoordinatorRequest/Response

Author: dpkp

kafka/coordinator/base.py

@@ -11,7 +11,7 @@
 from kafka.future import Future
 from kafka.metrics import AnonMeasurable
 from kafka.metrics.stats import Avg, Count, Max, Rate
-from kafka.protocol.find_coordinator import FindCoordinatorRequest
+from kafka.protocol.new.metadata import FindCoordinatorRequest
 from kafka.protocol.group import (
     HeartbeatRequest, JoinGroupRequest, LeaveGroupRequest, SyncGroupRequest,
     DEFAULT_GENERATION_ID, UNKNOWN_MEMBER_ID, GroupMember,