[
https://issues.apache.org/jira/browse/KAFKA-4300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy updated KAFKA-4300:
--
Status: Patch Available (was: In Progress)
> NamedCache throws an NPE when evict is called and
Damian Guy created KAFKA-4311:
-
Summary: Exception in NamedCache.flush - Key found in dirty key
set, but entry is null
Key: KAFKA-4311
URL: https://issues.apache.org/jira/browse/KAFKA-4311
Project
[
https://issues.apache.org/jira/browse/KAFKA-4311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15585914#comment-15585914
]
Damian Guy commented on KAFKA-4311:
---
[~flyaruu]
by merge do you mean join? I
[
https://issues.apache.org/jira/browse/KAFKA-4311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15588096#comment-15588096
]
Damian Guy commented on KAFKA-4311:
---
[~flyaruu]
We are unable to reproduce or find
[
https://issues.apache.org/jira/browse/KAFKA-4311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15589089#comment-15589089
]
Damian Guy commented on KAFKA-4311:
---
Thanks - i'll take a look at it
[
https://issues.apache.org/jira/browse/KAFKA-4311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15591271#comment-15591271
]
Damian Guy commented on KAFKA-4311:
---
[~flyaruu]
Thanks for the sample code. I'
[
https://issues.apache.org/jira/browse/KAFKA-4311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15591478#comment-15591478
]
Damian Guy commented on KAFKA-4311:
---
Can you commit it to the github
[
https://issues.apache.org/jira/browse/KAFKA-4311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15591605#comment-15591605
]
Damian Guy commented on KAFKA-4311:
---
thanks - i'll take a look
>
[
https://issues.apache.org/jira/browse/KAFKA-4311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15591675#comment-15591675
]
Damian Guy commented on KAFKA-4311:
---
Unfortunately that isn't working. We prob
[
https://issues.apache.org/jira/browse/KAFKA-4311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15591872#comment-15591872
]
Damian Guy commented on KAFKA-4311:
---
Ok - i've been to reproduce the issue
[
https://issues.apache.org/jira/browse/KAFKA-4311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15592060#comment-15592060
]
Damian Guy commented on KAFKA-4311:
---
when you are running it are you running a si
[
https://issues.apache.org/jira/browse/KAFKA-4311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15594852#comment-15594852
]
Damian Guy commented on KAFKA-4311:
---
Hi Frank,
if you have the time, would you
[
https://issues.apache.org/jira/browse/KAFKA-4311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy updated KAFKA-4311:
--
Summary: Mutli layer cache eviction causes forwarding to incorrect
Processor Node (was: Exception in
[
https://issues.apache.org/jira/browse/KAFKA-4311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy updated KAFKA-4311:
--
Summary: Multi layer cache eviction causes forwarding to incorrect
Processor Node (was: Mutli layer
[
https://issues.apache.org/jira/browse/KAFKA-4311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy updated KAFKA-4311:
--
Description:
The two exceptions below were reported by Frank on the dev mailing list. After
[
https://issues.apache.org/jira/browse/KAFKA-4311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy updated KAFKA-4311:
--
Description:
The two exceptions below were reported by Frank on the dev mailing list. After
[
https://issues.apache.org/jira/browse/KAFKA-4311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy updated KAFKA-4311:
--
Summary: Multi layer cache eviction causes forwarding to incorrect
ProcessorNode (was: Multi layer
[
https://issues.apache.org/jira/browse/KAFKA-4311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15597385#comment-15597385
]
Damian Guy commented on KAFKA-4311:
---
Frank, thanks for testing this for me. I
[
https://issues.apache.org/jira/browse/KAFKA-4311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15621909#comment-15621909
]
Damian Guy commented on KAFKA-4311:
---
Thanks for confirming
> Multi laye
[
https://issues.apache.org/jira/browse/KAFKA-4311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy updated KAFKA-4311:
--
Status: Patch Available (was: Open)
> Multi layer cache eviction causes forwarding to incorr
[
https://issues.apache.org/jira/browse/KAFKA-4366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy reassigned KAFKA-4366:
-
Assignee: Damian Guy (was: Guozhang Wang)
> KafkaStreams.close() blocks indefinit
[
https://issues.apache.org/jira/browse/KAFKA-4366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-4366 started by Damian Guy.
-
> KafkaStreams.close() blocks indefinit
[
https://issues.apache.org/jira/browse/KAFKA-4593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15982470#comment-15982470
]
Damian Guy commented on KAFKA-4593:
---
Is this even possible? I.e, thread A would
Damian Guy created KAFKA-5128:
-
Summary: TransactionCoordinator - Check inter broker protocol and
message format and raise errors if incompatible
Key: KAFKA-5128
URL: https://issues.apache.org/jira/browse/KAFKA-5128
Damian Guy created KAFKA-5129:
-
Summary: TransactionCoordinator - Add ACL check for each request
Key: KAFKA-5129
URL: https://issues.apache.org/jira/browse/KAFKA-5129
Project: Kafka
Issue Type
[
https://issues.apache.org/jira/browse/KAFKA-5128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy updated KAFKA-5128:
--
Issue Type: Sub-task (was: Bug)
Parent: KAFKA-5059
> TransactionCoordinator - Check in
Damian Guy created KAFKA-5130:
-
Summary: Change InterBrokerSendThread to use a Queue per broker
Key: KAFKA-5130
URL: https://issues.apache.org/jira/browse/KAFKA-5130
Project: Kafka
Issue Type
[
https://issues.apache.org/jira/browse/KAFKA-5129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy updated KAFKA-5129:
--
Issue Type: Sub-task (was: Bug)
Parent: KAFKA-5059
> TransactionCoordinator - Add ACL ch
Damian Guy created KAFKA-5131:
-
Summary: WriteTxnMarkers and complete commit/abort on partition
immigration
Key: KAFKA-5131
URL: https://issues.apache.org/jira/browse/KAFKA-5131
Project: Kafka
Damian Guy created KAFKA-5132:
-
Summary: Abort long running transactions
Key: KAFKA-5132
URL: https://issues.apache.org/jira/browse/KAFKA-5132
Project: Kafka
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/KAFKA-5132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15986183#comment-15986183
]
Damian Guy commented on KAFKA-5132:
---
Hi [~umesh9...@gmail.com] thanks for offerin
[
https://issues.apache.org/jira/browse/KAFKA-5132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy reassigned KAFKA-5132:
-
Assignee: Damian Guy
> Abort long running transacti
Damian Guy created KAFKA-5136:
-
Summary: Move coordinatorEpoch from WriteTxnMarkerRequest to
TxnMarkerEntry
Key: KAFKA-5136
URL: https://issues.apache.org/jira/browse/KAFKA-5136
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-5136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-5136 started by Damian Guy.
-
> Move coordinatorEpoch from WriteTxnMarkerRequest to TxnMarkerEn
[
https://issues.apache.org/jira/browse/KAFKA-5131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy reassigned KAFKA-5131:
-
Assignee: Damian Guy
> WriteTxnMarkers and complete commit/abort on partition immigrat
[
https://issues.apache.org/jira/browse/KAFKA-5132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy updated KAFKA-5132:
--
Status: Patch Available (was: Open)
> Abort long running transacti
[
https://issues.apache.org/jira/browse/KAFKA-5131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy updated KAFKA-5131:
--
Status: Patch Available (was: Open)
> WriteTxnMarkers and complete commit/abort on partit
Damian Guy created KAFKA-5168:
-
Summary: Cleanup delayed produce purgatory during partition
emmigration
Key: KAFKA-5168
URL: https://issues.apache.org/jira/browse/KAFKA-5168
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-5059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy updated KAFKA-5059:
--
Fix Version/s: 0.11.0.0
> Implement Transactional Coordina
[
https://issues.apache.org/jira/browse/KAFKA-5168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy updated KAFKA-5168:
--
Status: Patch Available (was: Open)
> Cleanup delayed produce purgatory during partition emmigrat
[
https://issues.apache.org/jira/browse/KAFKA-5168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy updated KAFKA-5168:
--
Resolution: Not A Problem
Status: Resolved (was: Patch Available)
This is already handled
[
https://issues.apache.org/jira/browse/KAFKA-5129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy reassigned KAFKA-5129:
-
Assignee: Damian Guy
> TransactionCoordinator - Add ACL check for each requ
Damian Guy created KAFKA-5219:
-
Summary: Move transaction expiration logic and scheduling to the
Transaction Manager
Key: KAFKA-5219
URL: https://issues.apache.org/jira/browse/KAFKA-5219
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-5241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16012270#comment-16012270
]
Damian Guy commented on KAFKA-5241:
---
[~twbecker] Probably worth filing another JIRA
[
https://issues.apache.org/jira/browse/KAFKA-5154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy updated KAFKA-5154:
--
Attachment: 5154_problem.log
> Kafka Streams throws NPE during rebala
[
https://issues.apache.org/jira/browse/KAFKA-5154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16015615#comment-16015615
]
Damian Guy commented on KAFKA-5154:
---
[~Lukas Gemela] Thanks for attaching the full
[
https://issues.apache.org/jira/browse/KAFKA-5256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16015805#comment-16015805
]
Damian Guy commented on KAFKA-5256:
---
>From 0.11.0 onwards we will always
[
https://issues.apache.org/jira/browse/KAFKA-5063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16017058#comment-16017058
]
Damian Guy commented on KAFKA-5063:
---
Another instance of this failure:
{nofo
[
https://issues.apache.org/jira/browse/KAFKA-5063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy reopened KAFKA-5063:
---
> Flaky
> ResetIntegrationTest.testReprocessingFromScratchAfterResetWithIntermediateUse
Damian Guy created KAFKA-5288:
-
Summary: Failure in
org.apache.kafka.streams.integration.ResetIntegrationTest.testReprocessingFromScratchAfterResetWithoutIntermediateUserTopic
Key: KAFKA-5288
URL: https
[
https://issues.apache.org/jira/browse/KAFKA-5154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy reassigned KAFKA-5154:
-
Assignee: Damian Guy (was: Matthias J. Sax)
> Kafka Streams throws NPE during rebala
[
https://issues.apache.org/jira/browse/KAFKA-5279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy updated KAFKA-5279:
--
Status: Patch Available (was: Open)
> TransactionCoordinator must expire transactional
[
https://issues.apache.org/jira/browse/KAFKA-5260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy updated KAFKA-5260:
--
Status: Patch Available (was: Open)
> Producer should not send AbortTxn unless transaction
[
https://issues.apache.org/jira/browse/KAFKA-5308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy reassigned KAFKA-5308:
-
Assignee: Damian Guy
> TC should handle UNSUPPORTED_FOR_MESSAGE_FORMAT in WriteTxnMar
[
https://issues.apache.org/jira/browse/KAFKA-5308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16021295#comment-16021295
]
Damian Guy commented on KAFKA-5308:
---
[~hachikuji] i think this may not be possible
[
https://issues.apache.org/jira/browse/KAFKA-5154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16024889#comment-16024889
]
Damian Guy commented on KAFKA-5154:
---
[~Lukas Gemela] if it happens again can you pl
[
https://issues.apache.org/jira/browse/KAFKA-5308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy updated KAFKA-5308:
--
Status: Patch Available (was: Open)
> TC should handle UNSUPPORTED_FOR_MESSAGE_FORMAT
[
https://issues.apache.org/jira/browse/KAFKA-4270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy resolved KAFKA-4270.
---
Resolution: Cannot Reproduce
Closing this as haven't been able to reproduce and no fu
[
https://issues.apache.org/jira/browse/KAFKA-4953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy resolved KAFKA-4953.
---
Resolution: Fixed
fixed by KAFKA-5045
> Global Store: cast exception when initialising with
[
https://issues.apache.org/jira/browse/KAFKA-5357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy reassigned KAFKA-5357:
-
Assignee: Damian Guy
> StackOverFlow error in transaction coordina
[
https://issues.apache.org/jira/browse/KAFKA-5357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-5357 started by Damian Guy.
-
> StackOverFlow error in transaction coordina
[
https://issues.apache.org/jira/browse/KAFKA-4913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-4913 stopped by Damian Guy.
-
> creating a window store with one segment throws division by zero er
[
https://issues.apache.org/jira/browse/KAFKA-4913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy updated KAFKA-4913:
--
Status: In Progress (was: Patch Available)
> creating a window store with one segment throws divis
[
https://issues.apache.org/jira/browse/KAFKA-3741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy reassigned KAFKA-3741:
-
Assignee: Damian Guy
> KStream config for changelog min.in.sync.repli
[
https://issues.apache.org/jira/browse/KAFKA-3741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy updated KAFKA-3741:
--
Status: Patch Available (was: Open)
> KStream config for changelog min.in.sync.repli
701 - 765 of 765 matches
Mail list logo
