Выяснилось, что существует проблема с клиентом kafka на стороне производителя (https://issues.apache.org/jira/browse/KAFKA-4169), где проверка несжатого сообщения выполняется по max.request.size вместо сжатого сообщения. Исправлена ли эта проблема с новой версией Кафки? Каковы альтернативные варианты? Я думаю о сжатии полезной нагрузки сообщения для сообщений больше, чем 1 МБ в коде приложения. Это будет дополнительные издержки, следовательно, поиск вариантов.