This commit is contained in:
Troy D. Hanson
2016-03-31 22:51:14 -04:00
parent 2fe9d71f3d
commit f27e078f0c

View File

@@ -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;