[
https://issues.apache.org/jira/browse/KAFKA-16699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson reassigned KAFKA-16699:
--
Assignee: Walker Carlson
> Have Streams treat InvalidPidMappingException like a Produ
[
https://issues.apache.org/jira/browse/KAFKA-16699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson updated KAFKA-16699:
---
Description:
KStreams is able to handle the ProducerFenced (among other errors) cleanly. It
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
Proj
[
https://issues.apache.org/jira/browse/KAFKA-16316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17844373#comment-17844373
]
Walker Carlson commented on KAFKA-16316:
KIP-1024 was made for this, but it has
[
https://issues.apache.org/jira/browse/KAFKA-7663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson updated KAFKA-7663:
--
Fix Version/s: 3.8.0
> Custom Processor supplied on addGlobalStore is not used when restoring s
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
P
[
https://issues.apache.org/jira/browse/KAFKA-16241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson updated KAFKA-16241:
---
Priority: Critical (was: Major)
> Kafka Streams hits IllegalStateException trying to recycl
[
https://issues.apache.org/jira/browse/KAFKA-7663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson reassigned KAFKA-7663:
-
Assignee: Walker Carlson
> Custom Processor supplied on addGlobalStore is not used when
[
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
> ---
[
https://issues.apache.org/jira/browse/KAFKA-14936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson updated KAFKA-14936:
---
Fix Version/s: 3.6.0
> Add Grace Period To Stream Table Join
> -
[
https://issues.apache.org/jira/browse/KAFKA-15379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson updated KAFKA-15379:
---
Priority: Minor (was: Major)
> Add option for Grace period Joins to disable changelog creat
[
https://issues.apache.org/jira/browse/KAFKA-15379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson updated KAFKA-15379:
---
Component/s: streams
> Add option for Grace period Joins to disable changelog creation
> --
[
https://issues.apache.org/jira/browse/KAFKA-15379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson updated KAFKA-15379:
---
Affects Version/s: 3.6.0
> Add option for Grace period Joins to disable changelog creation
[
https://issues.apache.org/jira/browse/KAFKA-15379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson updated KAFKA-15379:
---
Labels: kip (was: )
> Add option for Grace period Joins to disable changelog creation
> --
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: Improve
[
https://issues.apache.org/jira/browse/KAFKA-12699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson reassigned KAFKA-12699:
--
Assignee: Walker Carlson
> Streams no longer overrides the java default uncaught exce
[
https://issues.apache.org/jira/browse/KAFKA-12462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson updated KAFKA-12462:
---
Affects Version/s: 2.6.0
> Threads in PENDING_SHUTDOWN entering a rebalance can cause an ill
[
https://issues.apache.org/jira/browse/KAFKA-12462?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499736#comment-17499736
]
Walker Carlson commented on KAFKA-12462:
This also affects 2.6
> Threads in PEN
[
https://issues.apache.org/jira/browse/KAFKA-13681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17497502#comment-17497502
]
Walker Carlson commented on KAFKA-13681:
[~DrozD_0] Right now its only enabled w
[
https://issues.apache.org/jira/browse/KAFKA-13676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson updated KAFKA-13676:
---
Fix Version/s: 3.2.0
> When processing in ALOS, when one task encounters a task-specific exc
[
https://issues.apache.org/jira/browse/KAFKA-13676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson updated KAFKA-13676:
---
Description:
When processing in ALOS, we might as well commit progress made by other tasks
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: https://issues.apache.org/jira/browse/KAF
Walker Carlson created KAFKA-13588:
--
Summary: We should consolidate `changelogFor` methods to simplify
the generation of internal topic names
Key: KAFKA-13588
URL: https://issues.apache.org/jira/browse/KAFKA-1358
[
https://issues.apache.org/jira/browse/KAFKA-13281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17451957#comment-17451957
]
Walker Carlson commented on KAFKA-13281:
[~showuon] We haven't drafted a KIP yet
Walker Carlson created KAFKA-13246:
--
Summary:
StoreQueryIntegrationTest#shouldQueryStoresAfterAddingAndRemovingStreamThread
does not gate on stream state well
Key: KAFKA-13246
URL: https://issues.apache.org/jira
[
https://issues.apache.org/jira/browse/KAFKA-13128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson reassigned KAFKA-13128:
--
Assignee: Walker Carlson
> Flaky Test
> StoreQueryIntegrationTest.shouldQueryStoresA
[
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
> org.apache.kafka.streams.integration.TaskMetadataIntegra
[
https://issues.apache.org/jira/browse/KAFKA-13215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17403921#comment-17403921
]
Walker Carlson commented on KAFKA-13215:
[GitHub Pull Request #11083|https://git
[
https://issues.apache.org/jira/browse/KAFKA-13215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson reassigned KAFKA-13215:
--
Assignee: Walker Carlson
> Flaky test
> org.apache.kafka.streams.integration.TaskMet
[
https://issues.apache.org/jira/browse/KAFKA-13128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17396062#comment-17396062
]
Walker Carlson commented on KAFKA-13128:
I fixed the second failure in this PR a
[
https://issues.apache.org/jira/browse/KAFKA-12935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson closed KAFKA-12935.
--
> Flaky Test
> RestoreIntegrationTest.shouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNot
[
https://issues.apache.org/jira/browse/KAFKA-12935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson reassigned KAFKA-12935:
--
Assignee: Walker Carlson
> Flaky Test
> RestoreIntegrationTest.shouldRecycleStateFro
[
https://issues.apache.org/jira/browse/KAFKA-13010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17383653#comment-17383653
]
Walker Carlson commented on KAFKA-13010:
It looks like the issue only shows up b
[
https://issues.apache.org/jira/browse/KAFKA-13010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17383620#comment-17383620
]
Walker Carlson edited comment on KAFKA-13010 at 7/19/21, 10:15 PM:
---
[
https://issues.apache.org/jira/browse/KAFKA-13010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17383620#comment-17383620
]
Walker Carlson edited comment on KAFKA-13010 at 7/19/21, 10:08 PM:
---
[
https://issues.apache.org/jira/browse/KAFKA-13010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17383620#comment-17383620
]
Walker Carlson edited comment on KAFKA-13010 at 7/19/21, 10:07 PM:
---
[
https://issues.apache.org/jira/browse/KAFKA-13010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17383620#comment-17383620
]
Walker Carlson edited comment on KAFKA-13010 at 7/19/21, 10:05 PM:
---
[
https://issues.apache.org/jira/browse/KAFKA-13010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17383620#comment-17383620
]
Walker Carlson commented on KAFKA-13010:
I ran it for the commit before KIP-744
[
https://issues.apache.org/jira/browse/KAFKA-13010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17383560#comment-17383560
]
Walker Carlson commented on KAFKA-13010:
This doesn't use the StreamsMetadata so
[
https://issues.apache.org/jira/browse/KAFKA-13010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17383553#comment-17383553
]
Walker Carlson commented on KAFKA-13010:
it took about 126 runs but it still fai
[
https://issues.apache.org/jira/browse/KAFKA-13010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17383533#comment-17383533
]
Walker Carlson commented on KAFKA-13010:
That sounds likely as the ThreadMetadat
[
https://issues.apache.org/jira/browse/KAFKA-13010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17383516#comment-17383516
]
Walker Carlson commented on KAFKA-13010:
That does seem to be the case. I think
[
https://issues.apache.org/jira/browse/KAFKA-13010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17383474#comment-17383474
]
Walker Carlson commented on KAFKA-13010:
It is possible. I ran till failure (75
[
https://issues.apache.org/jira/browse/KAFKA-13010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17383474#comment-17383474
]
Walker Carlson edited comment on KAFKA-13010 at 7/19/21, 5:20 PM:
[
https://issues.apache.org/jira/browse/KAFKA-13010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson reassigned KAFKA-13010:
--
Assignee: Walker Carlson
> Flaky test
> org.apache.kafka.streams.integration.TaskMet
[
https://issues.apache.org/jira/browse/KAFKA-13010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17383431#comment-17383431
]
Walker Carlson commented on KAFKA-13010:
This failure should will effect both te
[
https://issues.apache.org/jira/browse/KAFKA-12754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson closed KAFKA-12754.
--
> TaskMetadata endOffsets does not update when the offsets are read
>
[
https://issues.apache.org/jira/browse/KAFKA-12754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17344864#comment-17344864
]
Walker Carlson commented on KAFKA-12754:
Huh, I guess I was wrong. Sorry!
> Tas
[
https://issues.apache.org/jira/browse/KAFKA-12754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson updated KAFKA-12754:
---
Affects Version/s: (was: 2.8.0)
> TaskMetadata endOffsets does not update when the offse
[
https://issues.apache.org/jira/browse/KAFKA-12754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17344857#comment-17344857
]
Walker Carlson commented on KAFKA-12754:
[~ableegoldman] I think picking back to
[
https://issues.apache.org/jira/browse/KAFKA-12754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson updated KAFKA-12754:
---
Affects Version/s: 2.8.0
> TaskMetadata endOffsets does not update when the offsets are read
[
https://issues.apache.org/jira/browse/KAFKA-12781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson updated KAFKA-12781:
---
Description: Currently `TaskMetadata#endOffsets()` returns the highest
offset seen by the ma
[
https://issues.apache.org/jira/browse/KAFKA-12781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17344205#comment-17344205
]
Walker Carlson commented on KAFKA-12781:
cc/ [~ableegoldman]
> Improve the endO
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 Ty
[
https://issues.apache.org/jira/browse/KAFKA-12774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17343624#comment-17343624
]
Walker Carlson commented on KAFKA-12774:
I looked at the code and it seems that
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
[
https://issues.apache.org/jira/browse/KAFKA-12711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson updated KAFKA-12711:
---
Description:
There should be a native option to set a back off period when replacing a
thre
[
https://issues.apache.org/jira/browse/KAFKA-12711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson updated KAFKA-12711:
---
Summary: Add a back off option to replace thread (was: Add a back off
option to Replace thr
[
https://issues.apache.org/jira/browse/KAFKA-12691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson closed KAFKA-12691.
--
> TaskMetadata timeSinceIdlingStarted not reporting correctly
> --
[
https://issues.apache.org/jira/browse/KAFKA-12711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson updated KAFKA-12711:
---
Description:
There should be a native option to set a back off period when replacing a
thre
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: Impro
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: Improv
[
https://issues.apache.org/jira/browse/KAFKA-12699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17326223#comment-17326223
]
Walker Carlson commented on KAFKA-12699:
I would not say its a bug per-say but I
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
Project
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
[
https://issues.apache.org/jira/browse/KAFKA-12565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson updated KAFKA-12565:
---
Description:
Global thread only topologies should be able to shutdown applications via the
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: https://issues.apache.org/jira/browse/K
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
[
https://issues.apache.org/jira/browse/KAFKA-12537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson updated KAFKA-12537:
---
Component/s: streams
> Single Threaded EOS applications will not work with SHUTDOWN_APPLICAT
[
https://issues.apache.org/jira/browse/KAFKA-12537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson reassigned KAFKA-12537:
--
Assignee: Walker Carlson
> Single Threaded EOS applications will not work with SHUTDO
[
https://issues.apache.org/jira/browse/KAFKA-12537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17307370#comment-17307370
]
Walker Carlson commented on KAFKA-12537:
It maybe possible to add a thread, have
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
Project:
[
https://issues.apache.org/jira/browse/KAFKA-12503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17305072#comment-17305072
]
Walker Carlson commented on KAFKA-12503:
I would also like to note that this was
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: https://issues.apache.org/jira/bro
[
https://issues.apache.org/jira/browse/KAFKA-12462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson updated KAFKA-12462:
---
Component/s: streams
> Threads in PENDING_SHUTDOWN entering a rebalance can cause an illegal
[
https://issues.apache.org/jira/browse/KAFKA-12462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson updated KAFKA-12462:
---
Affects Version/s: 2.8.0
> Threads in PENDING_SHUTDOWN entering a rebalance can cause an ill
[
https://issues.apache.org/jira/browse/KAFKA-12462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson updated KAFKA-12462:
---
Labels: streams (was: )
> Threads in PENDING_SHUTDOWN entering a rebalance can cause an ill
[
https://issues.apache.org/jira/browse/KAFKA-12462?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17300652#comment-17300652
]
Walker Carlson commented on KAFKA-12462:
If we were shutting down the whole clie
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 closed KAFKA-12347.
--
> Improve Kafka Streams ability to track progress
> --
[
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 updated KAFKA-12362:
---
Description: determine if a task is idling given the task Id. (was:
determine if a task is
[
https://issues.apache.org/jira/browse/KAFKA-12362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson closed KAFKA-12362.
--
> Determine if a Task is idling
> -
>
> Key: KAFKA-123
[
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
> -
>
>
[
https://issues.apache.org/jira/browse/KAFKA-12375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson updated KAFKA-12375:
---
Comment: was deleted
(was: there are other cases where we use `mainConsumer.enforceRebalance
[
https://issues.apache.org/jira/browse/KAFKA-12375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17291332#comment-17291332
]
Walker Carlson commented on KAFKA-12375:
there are other cases where we use `mai
[
https://issues.apache.org/jira/browse/KAFKA-10810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson closed KAFKA-10810.
--
> Add a replace thread option to the streams uncaught exception handler
> --
[
https://issues.apache.org/jira/browse/KAFKA-9331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson closed KAFKA-9331.
-
> Add option to terminate application when StreamThread(s) die
>
[
https://issues.apache.org/jira/browse/KAFKA-4748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson closed KAFKA-4748.
-
> Need a way to shutdown all workers in a Streams application at the same time
>
[
https://issues.apache.org/jira/browse/KAFKA-6943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson closed KAFKA-6943.
-
> Have option to shutdown KS cleanly if any threads crashes, or if all threads
> crash
> ---
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
[
https://issues.apache.org/jira/browse/KAFKA-12347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson updated KAFKA-12347:
---
Description:
Add methods to track records being consumed fully and to tell if tasks are
idl
[
https://issues.apache.org/jira/browse/KAFKA-12347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17287253#comment-17287253
]
Walker Carlson commented on KAFKA-12347:
KIP: https://cwiki.apache.org/confluenc
[
https://issues.apache.org/jira/browse/KAFKA-12347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson updated KAFKA-12347:
---
Description: Add metrics to track records being consumed fully and to tell
if tasks are idli
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 Typ
[
https://issues.apache.org/jira/browse/KAFKA-4640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson closed KAFKA-4640.
-
> Improve Streams unit test coverage
> --
>
> Key: KA
[
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-10555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson closed KAFKA-10555.
--
> Improve client state machine
>
>
> Key: KAFKA-10555
[
https://issues.apache.org/jira/browse/KAFKA-10015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson closed KAFKA-10015.
--
> React Smartly to Unexpected Errors on Stream Threads
> -
1 - 100 of 129 matches
Mail list logo
