KafkaEx.Protocol.ConsumerMetadata.Response

Summary

broker_for_consumer_group(brokers, consumer_group_metadata)

Types

t :: %KafkaEx.Protocol.ConsumerMetadata.Response{coordinator_id: integer, coordinator_host: binary, coordinator_port: 0 .. 65535, error_code: integer}

Functions

broker_for_consumer_group(brokers, consumer_group_metadata)