[jira] [Comment Edited] (KAFKA-7417) Some topics lost / cannot recover their ISR status following broker crash

2018-11-25 Thread Desmond Sindatry (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16698170#comment-16698170 ] Desmond Sindatry edited comment on KAFKA-7417 at 11/25/18 1:26 PM:

[jira] [Commented] (KAFKA-7417) Some topics lost / cannot recover their ISR status following broker crash

2018-11-25 Thread Desmond Sindatry (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16698170#comment-16698170 ] Desmond Sindatry commented on KAFKA-7417: - I am seeing the same issue and its not

[jira] [Comment Edited] (KAFKA-7417) Some topics lost / cannot recover their ISR status following broker crash

2018-11-25 Thread Desmond Sindatry (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16698170#comment-16698170 ] Desmond Sindatry edited comment on KAFKA-7417 at 11/25/18 1:27 PM:

[jira] [Comment Edited] (KAFKA-7417) Some topics lost / cannot recover their ISR status following broker crash

2018-11-25 Thread Desmond Sindatry (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16698170#comment-16698170 ] Desmond Sindatry edited comment on KAFKA-7417 at 11/25/18 5:46 PM:

[jira] [Comment Edited] (KAFKA-7653) Streams-Scala: Add type level differentiation for Key and Value serdes.

2018-11-25 Thread Mark Tranter (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16698355#comment-16698355 ] Mark Tranter edited comment on KAFKA-7653 at 11/25/18 11:31 PM: ---

[jira] [Comment Edited] (KAFKA-7653) Streams-Scala: Add type level differentiation for Key and Value serdes.

2018-11-25 Thread Mark Tranter (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16698355#comment-16698355 ] Mark Tranter edited comment on KAFKA-7653 at 11/25/18 11:35 PM: ---

[jira] [Commented] (KAFKA-7653) Streams-Scala: Add type level differentiation for Key and Value serdes.

2018-11-25 Thread Mark Tranter (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16698355#comment-16698355 ] Mark Tranter commented on KAFKA-7653: - {quote}Are you saying that implicits reuse the

[jira] [Created] (KAFKA-7671) A KStream/GlobalKTable join shouldn't reset the repartition flag

2018-11-25 Thread Andy Bryant (JIRA)
Andy Bryant created KAFKA-7671: -- Summary: A KStream/GlobalKTable join shouldn't reset the repartition flag Key: KAFKA-7671 URL: https://issues.apache.org/jira/browse/KAFKA-7671 Project: Kafka I

[jira] [Assigned] (KAFKA-7610) Detect consumer failures in initial JoinGroup

2018-11-25 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-7610: -- Assignee: Boyang Chen > Detect consumer failures in initial JoinGroup > --

[jira] [Updated] (KAFKA-7672) The local state not fully restored after KafkaStream rebalanced, resulting in data loss

2018-11-25 Thread linyue li (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] linyue li updated KAFKA-7672: - Description: Normally, when a task is mitigated to a new thread and no checkpoint file was found under i

[jira] [Created] (KAFKA-7672) The local state not fully restored after KafkaStream rebalanced, resulting in data loss

2018-11-25 Thread linyue li (JIRA)
linyue li created KAFKA-7672: Summary: The local state not fully restored after KafkaStream rebalanced, resulting in data loss Key: KAFKA-7672 URL: https://issues.apache.org/jira/browse/KAFKA-7672 Project

[jira] [Updated] (KAFKA-7672) The local state not fully restored after KafkaStream rebalanced, resulting in data loss

2018-11-25 Thread linyue li (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] linyue li updated KAFKA-7672: - Description: Normally, when a task is mitigated to a new thread and no checkpoint file was found under i

[jira] [Updated] (KAFKA-7672) The local state not fully restored after KafkaStream rebalanced, resulting in data loss

2018-11-25 Thread linyue li (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] linyue li updated KAFKA-7672: - Description: Normally, when a task is mitigated to a new thread and no checkpoint file was found under i

[jira] [Updated] (KAFKA-7672) The local state not fully restored after KafkaStream rebalanced, resulting in data loss

2018-11-25 Thread linyue li (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] linyue li updated KAFKA-7672: - Description: Normally, when a task is mitigated to a new thread and no checkpoint file was found under i

[jira] [Commented] (KAFKA-7671) A KStream/GlobalKTable join shouldn't reset the repartition flag

2018-11-25 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16698498#comment-16698498 ] Matthias J. Sax commented on KAFKA-7671: Thanks for reporting this! I guess, tha

[jira] [Commented] (KAFKA-7672) The local state not fully restored after KafkaStream rebalanced, resulting in data loss

2018-11-25 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16698502#comment-16698502 ] Matthias J. Sax commented on KAFKA-7672: Thanks for reporting this and for the de

[jira] [Commented] (KAFKA-7653) Streams-Scala: Add type level differentiation for Key and Value serdes.

2018-11-25 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16698503#comment-16698503 ] Matthias J. Sax commented on KAFKA-7653: If an implicit can be written in a way s

[jira] [Commented] (KAFKA-7653) Streams-Scala: Add type level differentiation for Key and Value serdes.

2018-11-25 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16698519#comment-16698519 ] Matthias J. Sax commented on KAFKA-7653: Btw: I just rediscovered: https://issues

[jira] [Updated] (KAFKA-7672) The local state not fully restored after KafkaStream rebalanced, resulting in data loss

2018-11-25 Thread linyue li (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] linyue li updated KAFKA-7672: - Description: Normally, when a task is mitigated to a new thread and no checkpoint file was found under i

[jira] [Updated] (KAFKA-7672) The local state not fully restored after KafkaStream rebalanced, resulting in data loss

2018-11-25 Thread linyue li (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] linyue li updated KAFKA-7672: - Description: Normally, when a task is mitigated to a new thread and no checkpoint file was found under i

[jira] [Updated] (KAFKA-7672) The local state not fully restored after KafkaStream rebalanced, resulting in data loss

2018-11-25 Thread linyue li (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] linyue li updated KAFKA-7672: - Description: Normally, when a task is mitigated to a new thread and no checkpoint file was found under i

[jira] [Updated] (KAFKA-7672) The local state not fully restored after KafkaStream rebalanced, resulting in data loss

2018-11-25 Thread linyue li (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] linyue li updated KAFKA-7672: - Description: Normally, when a task is mitigated to a new thread and no checkpoint file was found under i

[jira] [Updated] (KAFKA-7672) The local state not fully restored after KafkaStream rebalanced, resulting in data loss

2018-11-25 Thread linyue li (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] linyue li updated KAFKA-7672: - Description: Normally, when a task is mitigated to a new thread and no checkpoint file was found under i

[jira] [Updated] (KAFKA-7672) The local state not fully restored after KafkaStream rebalanced, resulting in data loss

2018-11-25 Thread linyue li (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] linyue li updated KAFKA-7672: - Description: Normally, when a task is mitigated to a new thread and no checkpoint file was found under i

[jira] [Updated] (KAFKA-7672) The local state not fully restored after KafkaStream rebalanced, resulting in data loss

2018-11-25 Thread linyue li (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] linyue li updated KAFKA-7672: - Description: Normally, when a task is mitigated to a new thread and no checkpoint file was found under i

[jira] [Updated] (KAFKA-7672) The local state not fully restored after KafkaStream rebalanced, resulting in data loss

2018-11-25 Thread linyue li (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] linyue li updated KAFKA-7672: - Flags: Patch,Important Reviewer: John Roesler > The local state not fully restored after KafkaStre

[jira] [Updated] (KAFKA-7672) The local state not fully restored after KafkaStream rebalanced, resulting in data loss

2018-11-25 Thread linyue li (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] linyue li updated KAFKA-7672: - Description: Normally, when a task is mitigated to a new thread and no checkpoint file was found under i

[jira] [Updated] (KAFKA-7672) The local state not fully restored after KafkaStream rebalanced, resulting in data loss

2018-11-25 Thread linyue li (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] linyue li updated KAFKA-7672: - Description: Normally, when a task is mitigated to a new thread and no checkpoint file was found under i