KafkaEx.Protocol.Metadata.Response

Summary

broker_for_topic(metadata, brokers, topic, partition)

Functions

broker_for_topic(metadata, brokers, topic, partition)