kafka consumer怎么知道有数据呢?

How do kafka consumer knows that there is data?

kafka consumer api 如何知道特定主题有可用的新数据?

目前我每5分钟调用一次消费者api来消耗数据。如果有数据,它将被消耗,否则它将 return nothing.In 这种情况下,消费者 api 被不必要地调用但我想在有新的时候调用 api kafka 中可用的数据。

没有办法知道是否有数据,但是,您可以调用 poll() 并阻塞直到累积一定数量的数据(以避免忙等待和发送太多请求)并附加超时.

查看文档了解详情:https://kafka.apache.org/documentation/#consumerconfigs

您对fetch.min.bytes

感兴趣