[jira] [Commented] (SPARK-32151) Kafka does not allow Partition Rebalance Handling

2020-07-16 Thread Ed Mitchell (Jira)
[ https://issues.apache.org/jira/browse/SPARK-32151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17159330#comment-17159330 ] Ed Mitchell commented on SPARK-32151: - Yeah - I think you're right. It's going to be in the write

[jira] [Commented] (SPARK-32151) Kafka does not allow Partition Rebalance Handling

2020-07-16 Thread Gabor Somogyi (Jira)
[ https://issues.apache.org/jira/browse/SPARK-32151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17159322#comment-17159322 ] Gabor Somogyi commented on SPARK-32151: --- I see, this case Structured Streaming is not affected. >

[jira] [Commented] (SPARK-32151) Kafka does not allow Partition Rebalance Handling

2020-07-16 Thread Ed Mitchell (Jira)
[ https://issues.apache.org/jira/browse/SPARK-32151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17159294#comment-17159294 ] Ed Mitchell commented on SPARK-32151: - I could do that if I wanted to start back at the beginning or

[jira] [Commented] (SPARK-32151) Kafka does not allow Partition Rebalance Handling

2020-07-16 Thread Gabor Somogyi (Jira)
[ https://issues.apache.org/jira/browse/SPARK-32151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17159278#comment-17159278 ] Gabor Somogyi commented on SPARK-32151: --- Have you set `auto.offset.reset`? > Kafka does not allow