Skip to content

Instantly share code, notes, and snippets.

@edenhill
Created June 23, 2016 10:07
Show Gist options
  • Save edenhill/85636fda15317b97d66f1e9ce5d90b0b to your computer and use it in GitHub Desktop.
Save edenhill/85636fda15317b97d66f1e9ce5d90b0b to your computer and use it in GitHub Desktop.
change this
{
rd_ts_t r = 1234;
if (rkb->rkb_rk->rk_conf.api_version_request &&
(r = rd_interval(&rkb->rkb_ApiVersion_fail_intvl, 0, 0)) > 0) {
/* Use ApiVersion to query broker for supported API versions. */
rd_rkb_dbg(rkb, PROTOCOL, "X", "Enabling ApiVersion");
rd_kafka_broker_feature_enable(rkb, RD_KAFKA_FEATURE_APIVERSION);
} else {
rd_rkb_dbg(rkb, PROTOCOL, "X", "Not enabling: %"PRId64, r);
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment