[
https://issues.apache.org/jira/browse/SPARK-30169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16995171#comment-16995171
]
Jungtaek Lim commented on SPARK-30169:
--
`poll` deprecation should be handled properly, and that's
[
https://issues.apache.org/jira/browse/SPARK-30169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991201#comment-16991201
]
Jungtaek Lim commented on SPARK-30169:
--
Replacing `poll` is duplicated of
[
https://issues.apache.org/jira/browse/SPARK-30169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991198#comment-16991198
]
Jungtaek Lim commented on SPARK-30169:
--
[~aman_omer]
Look for KIP which introduces poll(Duration).
[
https://issues.apache.org/jira/browse/SPARK-30169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991197#comment-16991197
]
Aman Omer commented on SPARK-30169:
---
{code:java}
@Deprecated
public ConsumerRecords poll(long
[
https://issues.apache.org/jira/browse/SPARK-30169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991196#comment-16991196
]
Jungtaek Lim commented on SPARK-30169:
--
Note that this is not just replacing old deprecated method
[
https://issues.apache.org/jira/browse/SPARK-30169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991048#comment-16991048
]
Aman Omer commented on SPARK-30169:
---
[~maxgekk] If you haven't started, I will take this.
> Eliminate
