[
https://issues.apache.org/jira/browse/BEAM-3093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16268168#comment-16268168
]
Raghu Angadi commented on BEAM-3093:
[~mingmxu], assigning this to you. Let me know
[
https://issues.apache.org/jira/browse/BEAM-3093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16217318#comment-16217318
]
Raghu Angadi commented on BEAM-3093:
Yes. withStartReadTime().
> add an option
[
https://issues.apache.org/jira/browse/BEAM-3093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16217240#comment-16217240
]
Raghu Angadi commented on BEAM-3093:
Did you check out `withStartReadOffset()' in KafkaIO? This might
[
https://issues.apache.org/jira/browse/BEAM-3093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16216282#comment-16216282
]
Xu Mingmin commented on BEAM-3093:
--
Mostly it's about case (1) and (2), but I think it's more clear if we
[
https://issues.apache.org/jira/browse/BEAM-3093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16216107#comment-16216107
]
Raghu Angadi commented on BEAM-3093:
(3) is same as setting "auto.offset.reset" Kafka consumer config
