Kafka RecordTooLargeException:max.request.size 与 max.message.bytes 两种原文怎么区分,默认只能发 1048489 字节,压缩不能绕过客户端检查,消费端 fetch 设 1000 字节仍读到 3 MiB 消息

  全部默认(max.request.size=1048576):
      最大能发送的 value 长度 = 1048489 字节
      客户端拒绝时的原文:RecordTooLargeException: The message is 1048577 bytes when serialized which is larger than 1048576, which is the value of the max.request.size configuration.
  topic t1 的 max.message.bytes(服务端查询):max.message.bytes=1048588 sensitive=false synonyms={DEFAULT_CONFIG:message.max.bytes=1048588}

  客户端 max.request.size=5242880,broker 与 topic 默认:
      最大能发送的 value 长度 = 1048516 字节
      服务端拒绝时的原文:RecordTooLargeException: The request included a message larger than the max message size the server will accept.

  Completed updating config for topic t1.
  topic max.message.bytes=3145728(3 MiB),客户端 max.request.size=5242880:
      最大能发送的 value 长度 = 3145654 字节
      服务端拒绝时的原文:RecordTooLargeException: The request included a message larger than the max message size the server will accept.
  Completed updating config for topic t1.
  对照:另一个没改的 topic t2,客户端 max.request.size=5242880:
      最大能发送的 value 长度 = 1048516 字节
      服务端拒绝时的原文:RecordTooLargeException: The request included a message larger than the max message size the server will accept.

  gzip + 全是字母 a,max.request.size=默认:
      最大能发送的 value 长度 = 1048489 字节
      客户端拒绝时的原文:RecordTooLargeException: The message is 1048577 bytes when serialized which is larger than 1048576, which is the value of the max.request.size configuration.
  gzip + 全是字母 a,max.request.size=8388608:
      最大能发送的 value 长度 = 8388520 字节
      客户端拒绝时的原文:RecordTooLargeException: The message is 8388609 bytes when serialized which is larger than 8388608, which is the value of the max.request.size configuration.
  不压缩 + 全是字母 a,max.request.size=8388608(对照):
      最大能发送的 value 长度 = 1048516 字节
      服务端拒绝时的原文:RecordTooLargeException: The request included a message larger than the max message size the server will accept.

  已发送 1 条 3145728 字节和 1 条 100 字节的消息
  max.partition.fetch.bytes = fetch.max.bytes = 1000 -> 读到的消息长度:[3145728, 100]
  max.partition.fetch.bytes = fetch.max.bytes = 1048576 -> 读到的消息长度:[3145728, 100]