HeartSaVioR commented on issue #26845: [SPARK-21869][SS] Revise Kafka producer pool to implement 'expire' correctly URL: https://github.com/apache/spark/pull/26845#issuecomment-564382948 Similarly I feel it would be ideal to move the files regarding consumer pool to `consumer` package, and adjust visibility if necessary. Even without adjusting visibility, moving these files would help determining the files regarding consumer pool easily. What do you think? If it makes sense I'll craft another PR for this. Thanks!
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected] With regards, Apache Git Services --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
