I keep getting this error message:
*The message is 1169350 bytes when serialized which is larger than the maximum request size you have configured with the max.request.size configuration.* As indicated in other posts, I am trying to set the “max.request.size” configuration in the Producer as follows: --------------------- .writeStream .format(*"kafka"*) .option( *"kafka.bootstrap.servers"*, conig.outputBootstrapServer ) .option(ProducerConfig.MAX_REQUEST_SIZE_CONFIG, *"10000000"*) --------------------- But this is not working. Am I setting this correctly? Is there a different way to set this property under Spark Structured Streaming? Please help. Thanks.