props.put("value.deserializer", props.put("max.poll.records它可能与max.poll.records有关吗？如果10条记录的大小大于默认的1MB，那么它会导致使用者挂起吗？
浏览 3提问于2018-07-09得票数 0
我没有覆盖作为默认值max.poll.records的500。然而，在运行我的星火作业时，我在日志中发现：我的所有作业都显示相同的值，即使它们有不同的批处理间隔。
那么，这个价值的来源是什么呢？
浏览 2提问于2018-09-12得票数 1
回答已采纳
我看到在我的申请上不断地重新平衡。我的应用程序是在批处理模式下开发的，下面是已添加的配置属性。myapp.changefeed.topic= test_topicmyapp.enable.auto.commit=falsemyapp.max.poll.records= 20000myapp.concurrency
浏览 8提问于2021-06-24得票数 0
回答已采纳
为了防止卡夫卡再平衡，我想增加max.poll.interval.ms，减少max.poll.records。此外，我理解默认情况下配置为：max.poll.interval.ms = 300000
我不确定的是如何在卡夫卡消费者的现有实例上检查这些配置。
浏览 11提问于2022-05-11得票数 1
回答已采纳
2回答
多处理kafka消息
、、、
我们正面临着我们应该为max.poll.records赋予多少价值的问题。为了处理这条消息中的每条消息，我们有3个rest调用。我所做的是使用并行流以列表和处理的形式获取消息。实例有2 2GB内存空间，max.poll.records为8。因此，现在如果我增加max.poll.records，消息处理时间会增加，当max.poll.records为4时性能最佳。
浏览 5提问于2019-01-28得票数 1
我需要从Kafka主题中读取记录，一旦读取了50条记录，就调用一个在单个请求中接受50条记录的API。我能够阅读Kafka主题中的记录，寻找有关如何将记录排入队列直到计数达到50的建议。
浏览 16提问于2020-03-30得票数 0
这是否意味着春库将max.poll.records设置为1，还是每次轮询500个(默认值)，并且该方法一个接一个地接收。
这个问题的原因是，我们经常在prod中看到下面的错误。increasing max.poll.interval.ms or by reducing the maximum size of batches returned in poll() with max.poll.records
浏览 22提问于2022-05-19得票数 0
我写了一个卡夫卡消费者使用spring库(spring启动器-家长2.3.4.RELEASE)。我的代码中有下面的使用者配置 * configuration for kafka consumers at container level * @return @Bean kafkaListenerContainerFactory(
浏览 23提问于2022-06-05得票数 2
回答已采纳
我遇到了一个参数--> max.poll.records
假设max.poll.records的值为5，这意味着什么？
浏览 1提问于2019-05-29得票数 0
回答已采纳
application/*+avro batch-mode: true partitioned: true consumer: concurrency: 1 max.poll.records: 10
configuration.i
浏览 9提问于2022-08-05得票数 0
基于文档，据我所知，当消费者监听多个分区时，肯定会返回多条记录.但是，它还能从轮询()方法中的同一个分区返回多条记录吗？
浏览 1提问于2022-08-28得票数 1
回答已采纳
因此，我设置了max.poll.records值，但它不起作用。星星之火中的消费者数量是卡夫卡中的分区数?那么火花流中记录的最大数量是max.poll.records*consumers？
浏览 1提问于2018-09-27得票数 2
1回答
我添加了这两个额外的消费者属性，但仍然没有帮助：max.poll.records=500kafkaConsumer.commitAsync
浏览 9提问于2017-07-07得票数 0
auto.offset.reset = earliestmax.poll.interval.ms = 300000
max.poll.records
浏览 9提问于2020-08-11得票数 0
2回答
我在文件/etc/kafka/consumer.properties中设置了值max.poll.records=1，如下所示：max.poll.records
浏览 8提问于2019-10-31得票数 4
我用的是kafka 1.1.0。kafka流始终抛出此异常(尽管具有不同的消息)。
WARN o.a.k.s.p.i.RecordCollectorImpl@onCompletion:166 - task [0_0] Error sending record (key KEY value VALUE timestamp TIMESTAMP) to topic OUTPUT_TOPIC due to Producer attempted an operation with an old epoch. Either there is a newer producer with the same t
浏览 1提问于2018-05-08得票数 2
回答已采纳
1回答
我使用@KafkaListener作为道具
max.poll.records到50。我不知道为什么消费者不像max.poll.records支持的那样轮询记录，实际上，当应用程序启动或msg由生产者发布时，它的所有500 msg都会被投票。
浏览 2提问于2021-05-28得票数 0
回答已采纳
1回答
在查看了线程和文档之后，我发现了"max.poll.records“属性，但是作为设置此属性的位置，建议相互矛盾。: 30 # ConsumerConfig ignores this configuarion: binder: max.poll.r
浏览 0提问于2019-02-28得票数 3
回答已采纳
max.poll.records诉batch.max.rows kafka。这两种属性有什么区别？
我使用卡夫卡水槽任务来阅读卡夫卡主题的记录。
浏览 3提问于2020-01-28得票数 0
云服务器
ICP备案
对象存储
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号