apache kafka - Validate request body in Nginx -

i using nginx producer receives requests , sends them kafka.

for purpose found ngx_kafka_module nginx.

is possible validate request body in nginx? because ngx_kafka_module puts in request body kafka. want remove fields don't exist in scheme.