JHUAPL/kvspool
1
0
Fork 0
mirror of https://github.com/JHUAPL/kvspool.git synced 2026-01-07 23:04:14 -05:00
Code Issues Packages Projects Releases Wiki Activity

compatibility

Browse Source
This commit is contained in:
Troy D. Hanson
2016-06-26 11:59:41 -04:00
parent 4456e62bda
commit 6209f304d0
2 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
bindings/README.md Normal file
View File

@@ -0,0 +1 @@
Currently deprecated

2
utils/kvsp-kkpub.c
View File

@@ -250,7 +250,7 @@ void *kaf_worker(void *thread_id) {
/* set up global options */
conf = rd_kafka_conf_new();
rd_kafka_conf_set_error_cb(conf, err_cb);
rd_kafka_conf_set_throttle_cb(conf, throttle_cb);
//rd_kafka_conf_set_throttle_cb(conf, throttle_cb);
rd_kafka_conf_set_stats_cb(conf, stats_cb);
kr = rd_kafka_conf_set(conf, "statistics.interval.ms", "60000", errstr, sizeof(errstr));
if (kr != RD_KAFKA_CONF_OK) {