Kafka之消费与激情
throw new IllegalStateException("Consumer is not subscribed to any topics or assigned any partitions"); } // poll for new data until the timeout expires long elapsedTime = 0L; do { client.maybeTriggerWakeup(); final long metadataEnd; if (includeMetadataInTimeout) { final long metadataStart = time.milliseconds(); if (!updateAssignmentMetadataIfNeeded(remainingTimeAtLeastZero(timeoutMs, elapsedTime))) { return ConsumerRecords.empty(); } metadataEnd = time.milliseconds(); elapsedTime += metadataEnd - metadataStart; } else { while (!updateAssignmentMetadataIfNeeded(Long.MAX_VALUE)) { log.warn("Still waiting for metadata"); } metadataEnd = time.milliseconds(); } final Map<TopicPartition, List<ConsumerRecord<K, V>>> records = pollForFetches(remainingTimeAtLeastZero(timeoutMs, elapsedTime)); if (!records.isEmpty()) { // before returning the fetched records, we can send off the next round of fetches (编辑:辽源站长网) 【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容! |
- linux – 当我在shell脚本中使用cat命令时,如何在文件末尾保
- 酷狗音乐怎么设置一键强音 手机酷狗音乐一键强音设置方法
- linux – 如何使用automake检查操作系统
- qq好莱坞会员怎么转至微信 qq好莱坞会员转微信账号方法
- 极品飞车17最高通缉修改金钱99999999 无需钛备份和存档
- 罪恶都市十周年即将登入android ios 最新劲爆视频
- nginx的The page you are looking for is temporarily unav
- ireader怎么看本地的书 iReader如何导入本地图书
- CES 2019种草一大波,XESS新品不走寻常路
- linux – 有没有办法一次设置多个ZFS文件系统属性?