Hi Team, I am running a streaming application in performance environment. The source is Kafka and sink is also Kafka but the sink Kafka is secured by kerberos. Message size is 102kb and source parallelism is 16 process parallelism is 80 and sink parallelism is 12. I am using process function to remove few fields from json and mask some fields. When we send the data with around 100 TPS the application goes into backpressure. Please let me know how to fix the issue.
Regards, Md Aamir Iqubal +918409561989
