Walker Carlson created KAFKA-16699:
--
Summary: Have Streams treat InvalidPidMappingException like a
ProducerFencedException
Key: KAFKA-16699
URL: https://issues.apache.org/jira/browse/KAFKA-16699
Walker Carlson created KAFKA-16316:
--
Summary: Make the restore behavior of GlobalKTables with custom
processors configureable
Key: KAFKA-16316
URL: https://issues.apache.org/jira/browse/KAFKA-16316
[
https://issues.apache.org/jira/browse/KAFKA-14936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson resolved KAFKA-14936.
Resolution: Done
> Add Grace Period To Stream Table Join
>
Walker Carlson created KAFKA-15379:
--
Summary: Add option for Grace period Joins to disable changelog
creation
Key: KAFKA-15379
URL: https://issues.apache.org/jira/browse/KAFKA-15379
Project: Kafka
Walker Carlson created KAFKA-14936:
--
Summary: Add Grace Period To Stream Table Join
Key: KAFKA-14936
URL: https://issues.apache.org/jira/browse/KAFKA-14936
Project: Kafka
Issue Type:
Walker Carlson created KAFKA-13676:
--
Summary: When processing in ALOS we might as well commit progress
made other tasks on a task specific exception
Key: KAFKA-13676
URL:
Walker Carlson created KAFKA-13588:
--
Summary: We should consolidate `changelogFor` methods to simplify
the generation of internal topic names
Key: KAFKA-13588
URL:
Walker Carlson created KAFKA-13246:
--
Summary:
StoreQueryIntegrationTest#shouldQueryStoresAfterAddingAndRemovingStreamThread
does not gate on stream state well
Key: KAFKA-13246
URL:
[
https://issues.apache.org/jira/browse/KAFKA-13215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson resolved KAFKA-13215.
Resolution: Fixed
> Flaky test
>
Walker Carlson created KAFKA-12781:
--
Summary: Improve the endOffsets accuracy in TaskMetadata
Key: KAFKA-12781
URL: https://issues.apache.org/jira/browse/KAFKA-12781
Project: Kafka
Issue
Walker Carlson created KAFKA-12754:
--
Summary: TaskMetadata endOffsets does not update when the offsets
are read
Key: KAFKA-12754
URL: https://issues.apache.org/jira/browse/KAFKA-12754
Project: Kafka
Walker Carlson created KAFKA-12711:
--
Summary: Add a back off option to Replace thread
Key: KAFKA-12711
URL: https://issues.apache.org/jira/browse/KAFKA-12711
Project: Kafka
Issue Type:
Walker Carlson created KAFKA-12705:
--
Summary: Task idling is not sufficiently tested
Key: KAFKA-12705
URL: https://issues.apache.org/jira/browse/KAFKA-12705
Project: Kafka
Issue Type:
Walker Carlson created KAFKA-12699:
--
Summary: Streams no longer overrides the java default uncaught
exception handler
Key: KAFKA-12699
URL: https://issues.apache.org/jira/browse/KAFKA-12699
Walker Carlson created KAFKA-12691:
--
Summary: TaskMetadata timeSinceIdlingStarted not reporting
correctly
Key: KAFKA-12691
URL: https://issues.apache.org/jira/browse/KAFKA-12691
Project: Kafka
Walker Carlson created KAFKA-12565:
--
Summary: Global thread only topologies should be able to shutdown
applications via the uncaught exception handler
Key: KAFKA-12565
URL:
Walker Carlson created KAFKA-12538:
--
Summary: Global Threads should be able to be replaced like stream
threads
Key: KAFKA-12538
URL: https://issues.apache.org/jira/browse/KAFKA-12538
Project: Kafka
Walker Carlson created KAFKA-12537:
--
Summary: Single Threaded EOS applications will not work with
SHUTDOWN_APPLICATION
Key: KAFKA-12537
URL: https://issues.apache.org/jira/browse/KAFKA-12537
Walker Carlson created KAFKA-12503:
--
Summary: Resizing the thread cache in a non thread safe way can
cause records to be redirected throughout the topology
Key: KAFKA-12503
URL:
Walker Carlson created KAFKA-12462:
--
Summary: Threads in PENDING_SHUTDOWN entering a rebalance can
cause an illegal state exception
Key: KAFKA-12462
URL: https://issues.apache.org/jira/browse/KAFKA-12462
[
https://issues.apache.org/jira/browse/KAFKA-12347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson reopened KAFKA-12347:
> Improve Kafka Streams ability to track progress
>
[
https://issues.apache.org/jira/browse/KAFKA-12362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson resolved KAFKA-12362.
Resolution: Abandoned
> Determine if a Task is idling
> -
>
>
Walker Carlson created KAFKA-12362:
--
Summary: Determine if a Task is idling
Key: KAFKA-12362
URL: https://issues.apache.org/jira/browse/KAFKA-12362
Project: Kafka
Issue Type: Improvement
Walker Carlson created KAFKA-12347:
--
Summary: Improve Kafka Streams ability to track progress
Key: KAFKA-12347
URL: https://issues.apache.org/jira/browse/KAFKA-12347
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-4640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson resolved KAFKA-4640.
---
Resolution: Fixed
> Improve Streams unit test coverage
> --
[
https://issues.apache.org/jira/browse/KAFKA-10015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson resolved KAFKA-10015.
Resolution: Fixed
> React Smartly to Unexpected Errors on Stream Threads
>
Walker Carlson created KAFKA-12247:
--
Summary: Make removeStreamThread work better with static membership
Key: KAFKA-12247
URL: https://issues.apache.org/jira/browse/KAFKA-12247
Project: Kafka
Walker Carlson created KAFKA-12184:
--
Summary: Once the Error Classification is better update the
default streams uncaught exception handler to replace threads
Key: KAFKA-12184
URL:
Walker Carlson created KAFKA-10810:
--
Summary: Add a replace thread option to the streams uncaught
exception handler
Key: KAFKA-10810
URL: https://issues.apache.org/jira/browse/KAFKA-10810
Project:
Walker Carlson created KAFKA-10705:
--
Summary: Avoid World Readable RocksDB
Key: KAFKA-10705
URL: https://issues.apache.org/jira/browse/KAFKA-10705
Project: Kafka
Issue Type: Bug
Walker Carlson created KAFKA-9299:
-
Summary: Over eager optimization
Key: KAFKA-9299
URL: https://issues.apache.org/jira/browse/KAFKA-9299
Project: Kafka
Issue Type: Task
Walker Carlson created KAFKA-9298:
-
Summary: Reuse of a mapped stream causes an Invalid Topology
Key: KAFKA-9298
URL: https://issues.apache.org/jira/browse/KAFKA-9298
Project: Kafka
Issue
Walker Carlson created KAFKA-9243:
-
Summary: Update the javadocs from KeyValueStore to
TimestampKeyValueStore
Key: KAFKA-9243
URL: https://issues.apache.org/jira/browse/KAFKA-9243
Project: Kafka
33 matches
Mail list logo