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 Typ
[
https://issues.apache.org/jira/browse/KAFKA-9298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson updated KAFKA-9298:
--
Description:
Can be found with in the KStreamKStreamJoinTest.java
@Test
public void opt
[
https://issues.apache.org/jira/browse/KAFKA-9298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson updated KAFKA-9298:
--
Description:
Can be found with in the KStreamKStreamJoinTest.java
@Test
public void opt
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
Components
[
https://issues.apache.org/jira/browse/KAFKA-9298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16995970#comment-16995970
]
Walker Carlson commented on KAFKA-9298:
---
We solved a similar bug for cogoup in
ht
[
https://issues.apache.org/jira/browse/KAFKA-9331?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17194449#comment-17194449
]
Walker Carlson commented on KAFKA-9331:
---
[https://cwiki.apache.org/confluence/displ
[
https://issues.apache.org/jira/browse/KAFKA-10555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17205754#comment-17205754
]
Walker Carlson commented on KAFKA-10555:
I agree [~ableegoldman] ERROR does not
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
[
https://issues.apache.org/jira/browse/KAFKA-10500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson reassigned KAFKA-10500:
--
Assignee: Walker Carlson
> Add API to Start and Stop Stream Threads
> ---
[
https://issues.apache.org/jira/browse/KAFKA-9331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson reassigned KAFKA-9331:
-
Assignee: Walker Carlson
> Add option to terminate application when StreamThread(s) die
[
https://issues.apache.org/jira/browse/KAFKA-6943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson reassigned KAFKA-6943:
-
Assignee: Walker Carlson
> Have option to shutdown KS cleanly if any threads crashes, or
[
https://issues.apache.org/jira/browse/KAFKA-4748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson reassigned KAFKA-4748:
-
Assignee: Walker Carlson
> Need a way to shutdown all workers in a Streams application a
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
[
https://issues.apache.org/jira/browse/KAFKA-10705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson updated KAFKA-10705:
---
Labels: streams (was: )
> Avoid World Readable RocksDB
>
>
>
[
https://issues.apache.org/jira/browse/KAFKA-10705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson reassigned KAFKA-10705:
--
Assignee: Leah Thomas
> Avoid World Readable RocksDB
>
>
[
https://issues.apache.org/jira/browse/KAFKA-10555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson reassigned KAFKA-10555:
--
Assignee: Walker Carlson
> Improve client state machine
> ---
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:
[
https://issues.apache.org/jira/browse/KAFKA-9638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17246252#comment-17246252
]
Walker Carlson commented on KAFKA-9638:
---
There is a kip that might effect how this
[
https://issues.apache.org/jira/browse/KAFKA-6520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17246254#comment-17246254
]
Walker Carlson commented on KAFKA-6520:
---
[https://cwiki.apache.org/confluence/x/lCv
[
https://issues.apache.org/jira/browse/KAFKA-10555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17246257#comment-17246257
]
Walker Carlson commented on KAFKA-10555:
[https://cwiki.apache.org/confluence/x/
[
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-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=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: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=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=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=17383560#comment-17383560
]
Walker Carlson commented on KAFKA-13010:
This doesn't use the StreamsMetadata so
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
[
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
[
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-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-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-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-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=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 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: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:15 PM:
---
[
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-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-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-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-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-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 resolved KAFKA-13215.
Resolution: Fixed
> Flaky test
> org.apache.kafka.streams.integration.TaskMetadataIntegra
[
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
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-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
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-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
[
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:all-tabpanel
]
Walker Carlson updated KAFKA-12537:
---
Component/s: streams
> Single Threaded EOS applications will not work with SHUTDOWN_APPLICAT
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-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
[
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-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-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
[
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-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
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
[
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-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:
---
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-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-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-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-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-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
[
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-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:all-tabpanel
]
Walker Carlson closed KAFKA-12754.
--
> TaskMetadata endOffsets does not update when the offsets are read
>
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: https://issues.apache.org/jira/
[
https://issues.apache.org/jira/browse/KAFKA-12184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17263758#comment-17263758
]
Walker Carlson commented on KAFKA-12184:
[~cadonna] This is just a reminder for
[
https://issues.apache.org/jira/browse/KAFKA-12184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson updated KAFKA-12184:
---
Fix Version/s: 3.0.0
> Once the Error Classification is better update the default streams un
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
[
https://issues.apache.org/jira/browse/KAFKA-12247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17273837#comment-17273837
]
Walker Carlson commented on KAFKA-12247:
[~ableegoldman] and [~cadonna] I made a
[
https://issues.apache.org/jira/browse/KAFKA-12247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson closed KAFKA-12247.
--
> Make removeStreamThread work better with static membership
> ---
[
https://issues.apache.org/jira/browse/KAFKA-10500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson closed KAFKA-10500.
--
> Add API to Start and Stop Stream Threads
>
>
>
[
https://issues.apache.org/jira/browse/KAFKA-10015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson reassigned KAFKA-10015:
--
Assignee: Walker Carlson (was: Bruno Cadonna)
> React Smartly to Unexpected Errors o
[
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
> ---
[
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
> -
[
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-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
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-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
[
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-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-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
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-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-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
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-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
[
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:
---
Component/s: streams
> Add option for Grace period Joins to disable changelog creation
> --
1 - 100 of 129 matches
Mail list logo
