Created
July 21, 2015 05:42
-
-
Save yannick/730ee8baaf432ff4346e to your computer and use it in GitHub Desktop.
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| typedef struct rd_kafka_metadata { | |
| int broker_cnt; /* Number of brokers in 'brokers' */ | |
| struct rd_kafka_metadata_broker *brokers; /* Brokers */ | |
| int topic_cnt; /* Number of topics in 'topics' */ | |
| struct rd_kafka_metadata_topic *topics; /* Topics */ | |
| int32_t orig_broker_id; /* Broker originating this metadata */ | |
| char *orig_broker_name; /* Name of originating broker */ | |
| } rd_kafka_metadata_t; | |
| rd_kafka_metadata (rd_kafka_t *rk, int all_topics, | |
| rd_kafka_topic_t *only_rkt, | |
| const struct rd_kafka_metadata **metadatap, | |
| int timeout_ms); | |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment