При запуске Kafka возникает ошибка Invalid receive (size = 369295617 larger than 104857600)...
Полный текст ошибки
| 1 2 3 4 5 6 7 8 9 10 11 | kafka-server-start.sh[27304]: org.apache.kafka.common.network.InvalidReceiveException: Invalid receive (size = 369295617 larger than 104857600) kafka-server-start.sh[27304]: at org.apache.kafka.common.network.NetworkReceive.readFrom(NetworkReceive.java:105) kafka-server-start.sh[27304]: at org.apache.kafka.common.network.KafkaChannel.receive(KafkaChannel.java:447) kafka-server-start.sh[27304]: at org.apache.kafka.common.network.KafkaChannel.read(KafkaChannel.java:397) kafka-server-start.sh[27304]: at org.apache.kafka.common.network.Selector.attemptRead(Selector.java:674) kafka-server-start.sh[27304]: at org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:576) kafka-server-start.sh[27304]: at org.apache.kafka.common.network.Selector.poll(Selector.java:481) kafka-server-start.sh[27304]: at kafka.network.Processor.poll(SocketServer.scala:923) kafka-server-start.sh[27304]: at kafka.network.Processor.run(SocketServer.scala:826) kafka-server-start.sh[27304]: at java.base/java.lang.Thread.run(Thread.java:829) |
Скорее всего вы пытаетесь получить слишком большой запрос. Максимальный размер - это размер по умолчанию для socket.request.max.bytes, который составляет 100MB. Поэтому если у вас есть сообщение размером более 100 МБ, попробуйте увеличить значение этой переменной в server.properties и обязательно перезапустите кластер перед повторной попыткой.
К примеру
| 1 | socket.request.max.bytes=104857600 |
После этого перезапускаем kafka
| 1 | systemctl restart kafka |