kiel.protocol.coordinator¶

class kiel.protocol.coordinator.GroupCoordinatorRequest(**kwargs)[source]¶

GroupCoordinatorRequest =>
  group_id => String

class kiel.protocol.coordinator.GroupCoordinatorResponse(**kwargs)[source]¶

GroupCoordinatorResponse =>
  error_code => Int16
  coordinator_id => Int32
  coordinator_host => String
  coordinator_port => Int32