[ https://issues.apache.org/jira/browse/KAFKA-6542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16963970#comment-16963970 ]
Chad Preisler commented on KAFKA-6542: -------------------------------------- [~mjsax] Thank you for the clarification. I was looking at the issue only from the perspective of bootstrapping the kTables on startup. The code appears to only get to a State.Running when all kTable partitions have been restored. It also looks like the partitions are only "restored" when they reach the endOffsets that were set when the application started. > Tables should trigger joins too, not just streams > ------------------------------------------------- > > Key: KAFKA-6542 > URL: https://issues.apache.org/jira/browse/KAFKA-6542 > Project: Kafka > Issue Type: Improvement > Components: streams > Affects Versions: 1.1.0 > Reporter: Antony Stubbs > Priority: Major > > At the moment it's quite possible to have a race condition when joining a > stream with a table, if the stream event arrives first, before the table > event, in which case the join will fail. > This is also related to bootstrapping KTables (which is what a GKTable does). > Related to: KAFKA-4113 Allow KTable bootstrap -- This message was sent by Atlassian Jira (v8.3.4#803005)