美文网首页
max.request.size出错;RecordTooLarg

max.request.size出错;RecordTooLarg

作者: MGary | 来源:发表于2019-07-24 17:59 被阅读0次

解决步骤

1.Kafka者配置文件 server.properties中添加

message.max.bytes=100000000(100M)
replica.fetch.max.bytes=100000000(100M)每个分区试图获取的消息字节数。要大于等于message.max.bytes
  1. 生产者配置文件producer.properties中添加
max.request.size = 100000000(100M)请求的最大大小为字节。要小于 message.max.bytes
  1. 消费者配置文件consumer.properties中添加
fetch.message.max.bytes=100000000(100M)每个提取请求中为每个主题分区提取的消息字节数。要大于等于message.max.bytes
  1. Springboot 配置
 kafka:
    bootstrap-servers: localhost:9092
    producer:
      properties:
        max.request.size: 100000000
  1. 修改成功项目生产者启动答应打印
ProducerConfig values: 
    acks = 1
    batch.size = 100000000
    bootstrap.servers = [127.0.0.1:9092]
    buffer.memory = 100000000
    client.id = 
    compression.type = none
    connections.max.idle.ms = 540000
    enable.idempotence = false
    interceptor.classes = null
    key.serializer = class org.apache.kafka.common.serialization.StringSerializer
    linger.ms = 0
    max.block.ms = 60000
    max.in.flight.requests.per.connection = 5
    max.request.size = 100000000
    metadata.max.age.ms = 300000

相关文章

  • max.request.size出错;RecordTooLarg

    解决步骤 1.Kafka者配置文件 server.properties中添加 生产者配置文件producer.pr...

  • Kafka producer消息大小参数配置

    问题: 假如 max.request.size 大于 batch.size,那么该条消息会不会分多个 batch ...

  • Android万能音频播放器08-添加播放器出错回调

    如果出错,要把出错信息传给应用层,告诉开发者出错信息,然后做相应处理,出错回调: 在出错回调里面回收资源,并添加变...

  • 出错

    刚到健身房,领导打电话说有个证明没有装到标书里。我肯定扫描了,并且插入了电子文档里,但是最后排版不是我排的,我也记...

  • 出错

    话说多了惹祸,事做多了出错。

  • 出错

    人生在世,难免出错。出错让人失去信心,让人心烦意乱,所有人都讨厌它。 想起“出错”,我第一时间就联想到了外...

  • 出错

    第一次坐火车停错站了,本该义乌站停,却停在了诸暨。列车站里没有诸暨站,他停在了诸暨,列车员也没注意看时间,站牌,按...

  • 出错

    里约奥运会将我国国旗搞出错了,我就想絮叨一下“出错”这个问题。 出错是再常见不过的事情了,我们可能每天都会出现各种...

  • 出错

    Day 9.21 终于下决心买了bb的passport,因为想体验下不同系统的思路。但我忘记21号是CFA第一阶段...

  • 出错

    这是个关于“出错”的故事。主角虽然是我,细节却是我爸几年后告诉我的。 在我还没上小学的时候,周末经常和老爸一起去少...

网友评论

      本文标题:max.request.size出错;RecordTooLarg

      本文链接:https://www.haomeiwen.com/subject/wmsfrctx.html