I have a system keep sending data to kafka continuously, and a spark streaming application reading these data from kafka every 5 minutes However, I found the kafka producer throws "TimeoutException: Batch Expired" error when sparking streaming begin to read the kafka every 5 minutes. What's the reason for this? And how to solve this problem?
Regard, Junfeng Chen