[jira] [Created] (KAFKA-9808) Refactor State Store Hierarchy

Richard Yu created KAFKA-9808: - Summary: Refactor State Store Hierarchy Key: KAFKA-9808 URL: https://issues.apache.org/jira/browse/KAFKA-9808 Project: Kafka Issue Type: Improvement Comp

[jira] [Created] (KAFKA-9733) Consider addition to Kafka's replication model

Richard Yu created KAFKA-9733: - Summary: Consider addition to Kafka's replication model Key: KAFKA-9733 URL: https://issues.apache.org/jira/browse/KAFKA-9733 Project: Kafka Issue Type: New Featur

[jira] [Resolved] (KAFKA-9285) Implement failed message topic to account for processing lag during failure

[ https://issues.apache.org/jira/browse/KAFKA-9285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Richard Yu resolved KAFKA-9285. --- Resolution: Fixed Already resolved by Kafka Connect. > Implement failed message topic to account for

[jira] [Created] (KAFKA-9285) Implement failed message topic to account for processing lag during failure

Richard Yu created KAFKA-9285: - Summary: Implement failed message topic to account for processing lag during failure Key: KAFKA-9285 URL: https://issues.apache.org/jira/browse/KAFKA-9285 Project: Kafka

[jira] [Created] (KAFKA-8516) Consider allowing all replicas to have read/write permissions

Richard Yu created KAFKA-8516: - Summary: Consider allowing all replicas to have read/write permissions Key: KAFKA-8516 URL: https://issues.apache.org/jira/browse/KAFKA-8516 Project: Kafka Issue

[jira] [Created] (KAFKA-8438) Add API to allow user to define end behavior of consumer failure

Richard Yu created KAFKA-8438: - Summary: Add API to allow user to define end behavior of consumer failure Key: KAFKA-8438 URL: https://issues.apache.org/jira/browse/KAFKA-8438 Project: Kafka Iss

[jira] [Resolved] (KAFKA-8434) Make global stream time consistent over all stream tasks

[ https://issues.apache.org/jira/browse/KAFKA-8434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Richard Yu resolved KAFKA-8434. --- Resolution: Fixed > Make global stream time consistent over all stream tasks > --

[jira] [Created] (KAFKA-8434) Make global stream time consistent over all stream tasks

Richard Yu created KAFKA-8434: - Summary: Make global stream time consistent over all stream tasks Key: KAFKA-8434 URL: https://issues.apache.org/jira/browse/KAFKA-8434 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-8431) Add a onTimeoutExpired callback to Kafka Consumer

Richard Yu created KAFKA-8431: - Summary: Add a onTimeoutExpired callback to Kafka Consumer Key: KAFKA-8431 URL: https://issues.apache.org/jira/browse/KAFKA-8431 Project: Kafka Issue Type: Improve

[jira] [Created] (KAFKA-8388) Add methods to query for entries in KTable using timestamp

Richard Yu created KAFKA-8388: - Summary: Add methods to query for entries in KTable using timestamp Key: KAFKA-8388 URL: https://issues.apache.org/jira/browse/KAFKA-8388 Project: Kafka Issue Type

[jira] [Created] (KAFKA-8020) Consider making ThreadCache a time-aware LRU Cache

Richard Yu created KAFKA-8020: - Summary: Consider making ThreadCache a time-aware LRU Cache Key: KAFKA-8020 URL: https://issues.apache.org/jira/browse/KAFKA-8020 Project: Kafka Issue Type: Improv

[jira] [Created] (KAFKA-7850) Remove deprecated KStreamTestDriver

Richard Yu created KAFKA-7850: - Summary: Remove deprecated KStreamTestDriver Key: KAFKA-7850 URL: https://issues.apache.org/jira/browse/KAFKA-7850 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-7132) Consider adding multithreaded form of recovery

Richard Yu created KAFKA-7132: - Summary: Consider adding multithreaded form of recovery Key: KAFKA-7132 URL: https://issues.apache.org/jira/browse/KAFKA-7132 Project: Kafka Issue Type: Improvemen

[jira] [Created] (KAFKA-7127) Add asynchronous support for methods in KafkaConsumer

Richard Yu created KAFKA-7127: - Summary: Add asynchronous support for methods in KafkaConsumer Key: KAFKA-7127 URL: https://issues.apache.org/jira/browse/KAFKA-7127 Project: Kafka Issue Type: Wis

[jira] [Created] (KAFKA-7118) Currently, it was discovered that KafkaConsumer's close() method might not be multi-thread safe when multiple cores are calling the same consumer.

Richard Yu created KAFKA-7118: - Summary: Currently, it was discovered that KafkaConsumer's close() method might not be multi-thread safe when multiple cores are calling the same consumer. Key: KAFKA-7118 URL: https:

[jira] [Created] (KAFKA-6608) Add timeout parameter to methods which fetches and resets offsets

Richard Yu created KAFKA-6608: - Summary: Add timeout parameter to methods which fetches and resets offsets Key: KAFKA-6608 URL: https://issues.apache.org/jira/browse/KAFKA-6608 Project: Kafka Is

[jira] [Created] (KAFKA-6583) Metadata should include number of state stores for task

Richard Yu created KAFKA-6583: - Summary: Metadata should include number of state stores for task Key: KAFKA-6583 URL: https://issues.apache.org/jira/browse/KAFKA-6583 Project: Kafka Issue Type: I