Skip to content

Instantly share code, notes, and snippets.

@yannick
Created July 21, 2015 05:42
Show Gist options
  • Select an option

  • Save yannick/730ee8baaf432ff4346e to your computer and use it in GitHub Desktop.

Select an option

Save yannick/730ee8baaf432ff4346e to your computer and use it in GitHub Desktop.
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