[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] [Created] (KAFKA-7443) OffsetOutOfRangeException in restoring state store from changelog topic when start offset of local checkpoint is smaller than that of changelog topic

2018-09-26 Thread linyue li (JIRA)
linyue li created KAFKA-7443: Summary: OffsetOutOfRangeException in restoring state store from changelog topic when start offset of local checkpoint is smaller than that of changelog topic Key: KAFKA-7443 URL: https: