From f27e078f0ce7544c6f190b53422471b062bbc4dd Mon Sep 17 00:00:00 2001 From: "Troy D. Hanson" Date: Thu, 31 Mar 2016 22:51:14 -0400 Subject: [PATCH] fix --- utils/kvsp-kpub.c | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/utils/kvsp-kpub.c b/utils/kvsp-kpub.c index ad9586f..d180b55 100644 --- a/utils/kvsp-kpub.c +++ b/utils/kvsp-kpub.c @@ -100,7 +100,7 @@ int main(int argc, char *argv[]) { goto done; } - if (++ticks % 1000) rd_kafka_poll(k, 10); // FIXME handle delivery reports + if ((++ticks % 1000) == 0) rd_kafka_poll(k, 10); } rc = 0;