小编Nic*_*ick的帖子

I\xc2\xa0 有一个主题，价值 1 GB 消息。A. Kafka 消费者决定消费这些消息。我该怎么做才能禁止消费者一次消费所有消息？我尝试设置

fetch.max.bytes在经纪人上

更改为 30 MB，以便每次轮询中仅允许 30 MB 的消息。代理似乎不尊重这一点，并尝试立即向消费者提供所有消息，导致消费者内存不足错误。我该如何解决这个问题？