[jira] [Created] (KAFKA-8216) MockConsumer's poll(Duration timeout) method doesn't wait for timeout

Kevin created KAFKA-8216: Summary: MockConsumer's poll(Duration timeout) method doesn't wait for timeout Key: KAFKA-8216 URL: https://issues.apache.org/jira/browse/KAFKA-8216 Project: Kafka Issue Ty

[jira] [Created] (KAFKA-8217) MockConsumer.poll executes pollTasks before checking wakeup flag

Kevin created KAFKA-8217: Summary: MockConsumer.poll executes pollTasks before checking wakeup flag Key: KAFKA-8217 URL: https://issues.apache.org/jira/browse/KAFKA-8217 Project: Kafka Issue Type: B

[jira] [Created] (KAFKA-8278) MockConsumer.poll and MockConsumer.wakupe are both synchronized

Kevin created KAFKA-8278: Summary: MockConsumer.poll and MockConsumer.wakupe are both synchronized Key: KAFKA-8278 URL: https://issues.apache.org/jira/browse/KAFKA-8278 Project: Kafka Issue Type: Bu

[jira] [Updated] (KAFKA-8278) MockConsumer.poll and MockConsumer.wakeup are both synchronized

[ https://issues.apache.org/jira/browse/KAFKA-8278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kevin updated KAFKA-8278: - Summary: MockConsumer.poll and MockConsumer.wakeup are both synchronized (was: MockConsumer.poll and MockConsume

[jira] [Created] (KAFKA-8279) Discrepancy around what SubscriptionState.allConsumed returns

Kevin created KAFKA-8279: Summary: Discrepancy around what SubscriptionState.allConsumed returns Key: KAFKA-8279 URL: https://issues.apache.org/jira/browse/KAFKA-8279 Project: Kafka Issue Type: Bug

[jira] [Updated] (KAFKA-8279) Discrepancy around what SubscriptionState.allConsumed returns

[ https://issues.apache.org/jira/browse/KAFKA-8279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kevin updated KAFKA-8279: - Description: Per [https://kafka.apache.org/22/javadoc/index.html?org/apache/kafka/streams/KafkaStreams.html], t