When my kafka executor reads data from kafka, sometimes it throws the error "java.lang.AssertionError: assertion failed: Failed to get records for **** after polling for 180000" , which after 3 minutes of executing. The data waiting for read is not so huge, which is about 1GB. And other partitions read by other tasks are very fast, the error always occurs on some specific executor..
Regard, Junfeng Chen
