[
https://issues.apache.org/jira/browse/KAFKA-6577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy resolved KAFKA-6577.
---
Resolution: Fixed
Fix Version/s: 1.2.0
Issue resolved by pull request 4610
[https://github.com/
[
https://issues.apache.org/jira/browse/KAFKA-6378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy resolved KAFKA-6378.
---
Resolution: Fixed
Fix Version/s: 1.1.0
Issue resolved by pull request 4424
[https://github.com/
[
https://issues.apache.org/jira/browse/KAFKA-6412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy resolved KAFKA-6412.
---
Resolution: Fixed
Fix Version/s: 1.1.0
Issue resolved by pull request 4372
[https://github.com/
Damian Guy created KAFKA-6360:
-
Summary: RocksDB segments not removed when store is closed causes
re-initialization to fail
Key: KAFKA-6360
URL: https://issues.apache.org/jira/browse/KAFKA-6360
Project: K
Damian Guy created KAFKA-6349:
-
Summary: ConcurrentModificationException during streams state
restoration
Key: KAFKA-6349
URL: https://issues.apache.org/jira/browse/KAFKA-6349
Project: Kafka
Iss
Damian Guy created KAFKA-6259:
-
Summary: Make KafkaStreams.cleanup() clean global state directory
Key: KAFKA-6259
URL: https://issues.apache.org/jira/browse/KAFKA-6259
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-6186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy resolved KAFKA-6186.
---
Resolution: Duplicate
> RocksDB based WindowStore fail to create db file on Windows OS
> -
[
https://issues.apache.org/jira/browse/KAFKA-6069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy resolved KAFKA-6069.
---
Resolution: Fixed
Fix Version/s: 1.0.1
1.1.0
Issue resolved by pull request
[
https://issues.apache.org/jira/browse/KAFKA-6023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy resolved KAFKA-6023.
---
Resolution: Fixed
Fix Version/s: 1.1.0
Issue resolved by pull request 4041
[https://github.com/
[
https://issues.apache.org/jira/browse/KAFKA-4890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy resolved KAFKA-4890.
---
Resolution: Duplicate
> State directory being deleted when another thread holds the lock
> ---
[
https://issues.apache.org/jira/browse/KAFKA-5985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy resolved KAFKA-5985.
---
Resolution: Fixed
Issue resolved by pull request 3994
[https://github.com/apache/kafka/pull/3994]
> M
Damian Guy created KAFKA-6001:
-
Summary: Remove from usages of Materialized in
Streams
Key: KAFKA-6001
URL: https://issues.apache.org/jira/browse/KAFKA-6001
Project: Kafka
Issue Type: Bug
Damian Guy created KAFKA-5986:
-
Summary: Streams State Restoration never completes when logging is
disabled
Key: KAFKA-5986
URL: https://issues.apache.org/jira/browse/KAFKA-5986
Project: Kafka
I
[
https://issues.apache.org/jira/browse/KAFKA-5765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy resolved KAFKA-5765.
---
Resolution: Fixed
Fix Version/s: (was: 1.1.0)
1.0.0
Issue resolved by pu
[
https://issues.apache.org/jira/browse/KAFKA-5489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy resolved KAFKA-5489.
---
Resolution: Cannot Reproduce
Closing this as i haven't seen it fail in a while and i'm unable to repro
[
https://issues.apache.org/jira/browse/KAFKA-5956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy resolved KAFKA-5956.
---
Resolution: Fixed
Issue resolved by pull request 3936
[https://github.com/apache/kafka/pull/3936]
> S
Damian Guy created KAFKA-5956:
-
Summary: StreamBuilder#table and StreamsBuilder#globalTable should
use serdes from Materialized
Key: KAFKA-5956
URL: https://issues.apache.org/jira/browse/KAFKA-5956
Projec
[
https://issues.apache.org/jira/browse/KAFKA-5931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy resolved KAFKA-5931.
---
Resolution: Fixed
Issue resolved by pull request 3903
[https://github.com/apache/kafka/pull/3903]
> D
Damian Guy created KAFKA-5939:
-
Summary: Add a dryrun option to release.py
Key: KAFKA-5939
URL: https://issues.apache.org/jira/browse/KAFKA-5939
Project: Kafka
Issue Type: Bug
Component
Damian Guy created KAFKA-5931:
-
Summary: Deprecate KTable#to and KTable#through
Key: KAFKA-5931
URL: https://issues.apache.org/jira/browse/KAFKA-5931
Project: Kafka
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/KAFKA-5873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy resolved KAFKA-5873.
---
Resolution: Fixed
Fix Version/s: 1.0.0
Issue resolved by pull request 3837
[https://github.com/
Damian Guy created KAFKA-5922:
-
Summary: Add SessionWindowedKStream
Key: KAFKA-5922
URL: https://issues.apache.org/jira/browse/KAFKA-5922
Project: Kafka
Issue Type: Sub-task
Components:
Damian Guy created KAFKA-5921:
-
Summary: Add Materialized overloads to WindowedKStream
Key: KAFKA-5921
URL: https://issues.apache.org/jira/browse/KAFKA-5921
Project: Kafka
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/KAFKA-5754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy resolved KAFKA-5754.
---
Resolution: Fixed
Fix Version/s: 1.0.0
Issue resolved by pull request 3727
[https://github.com/
[
https://issues.apache.org/jira/browse/KAFKA-5908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy resolved KAFKA-5908.
---
Resolution: Fixed
Issue resolved by pull request 3868
[https://github.com/apache/kafka/pull/3868]
> C
Damian Guy created KAFKA-5908:
-
Summary: CompositeReadOnlyWindowStore range fetch doesn't return
all values when fetching with different start and end times
Key: KAFKA-5908
URL: https://issues.apache.org/jira/browse/K
[
https://issues.apache.org/jira/browse/KAFKA-5655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy resolved KAFKA-5655.
---
Resolution: Fixed
Fix Version/s: 1.0.0
Issue resolved by pull request 3829
[https://github.com/
Damian Guy created KAFKA-5873:
-
Summary: Add Materialized overloads to StreamBuilder
Key: KAFKA-5873
URL: https://issues.apache.org/jira/browse/KAFKA-5873
Project: Kafka
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/KAFKA-5853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy resolved KAFKA-5853.
---
Resolution: Fixed
Fix Version/s: 1.0.0
Issue resolved by pull request 3809
[https://github.com/
[
https://issues.apache.org/jira/browse/KAFKA-5832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy resolved KAFKA-5832.
---
Resolution: Fixed
Issue resolved by pull request 3784
[https://github.com/apache/kafka/pull/3784]
> A
Damian Guy created KAFKA-5853:
-
Summary: Add WindowedKStream interface and implemenation
Key: KAFKA-5853
URL: https://issues.apache.org/jira/browse/KAFKA-5853
Project: Kafka
Issue Type: Sub-task
Damian Guy created KAFKA-5852:
-
Summary: Add filter, filterNot, mapValues and Materialized to
KTable
Key: KAFKA-5852
URL: https://issues.apache.org/jira/browse/KAFKA-5852
Project: Kafka
Issue Ty
[
https://issues.apache.org/jira/browse/KAFKA-5844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy resolved KAFKA-5844.
---
Resolution: Fixed
Issue resolved by pull request 3802
[https://github.com/apache/kafka/pull/3802]
> A
Damian Guy created KAFKA-5844:
-
Summary: Add groupBy(KeyValueMapper, Serialized) to KTable
Key: KAFKA-5844
URL: https://issues.apache.org/jira/browse/KAFKA-5844
Project: Kafka
Issue Type: Sub-tas
Damian Guy created KAFKA-5832:
-
Summary: Add Consumed class and overloads to StreamBuilder
Key: KAFKA-5832
URL: https://issues.apache.org/jira/browse/KAFKA-5832
Project: Kafka
Issue Type: Sub-tas
Damian Guy created KAFKA-5819:
-
Summary: Add Joined class and relevant KStream join overloads
Key: KAFKA-5819
URL: https://issues.apache.org/jira/browse/KAFKA-5819
Project: Kafka
Issue Type: Sub-
Damian Guy created KAFKA-5817:
-
Summary: Add Serialized class and KStream groupBy and groupByKey
overloads
Key: KAFKA-5817
URL: https://issues.apache.org/jira/browse/KAFKA-5817
Project: Kafka
Is
Damian Guy created KAFKA-5816:
-
Summary: Add Produced class and new to and through overloads to
KStream
Key: KAFKA-5816
URL: https://issues.apache.org/jira/browse/KAFKA-5816
Project: Kafka
Issue
Damian Guy created KAFKA-5815:
-
Summary: Add Printed class and KStream#print(Printed)
Key: KAFKA-5815
URL: https://issues.apache.org/jira/browse/KAFKA-5815
Project: Kafka
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/KAFKA-5769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy resolved KAFKA-5769.
---
Resolution: Duplicate
> Transient test failure
> org.apache.kafka.streams.integration.KStreamRepartit
[
https://issues.apache.org/jira/browse/KAFKA-4835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy resolved KAFKA-4835.
---
Resolution: Duplicate
> Allow users control over repartitioning
>
[
https://issues.apache.org/jira/browse/KAFKA-4835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy reopened KAFKA-4835:
---
> Allow users control over repartitioning
> ---
>
> Ke
[
https://issues.apache.org/jira/browse/KAFKA-5804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy resolved KAFKA-5804.
---
Resolution: Fixed
Issue resolved by pull request 3754
[https://github.com/apache/kafka/pull/3754]
> C
Damian Guy created KAFKA-5804:
-
Summary: ChangeLoggingWindowBytesStore needs to retain duplicates
when writing to the log
Key: KAFKA-5804
URL: https://issues.apache.org/jira/browse/KAFKA-5804
Project: Kaf
[
https://issues.apache.org/jira/browse/KAFKA-5771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy resolved KAFKA-5771.
---
Resolution: Fixed
Fix Version/s: 0.11.0.1
1.0.0
Issue resolved by pull reque
Damian Guy created KAFKA-5787:
-
Summary: StoreChangeLogReader needs to restore partitions that
were added post initialization
Key: KAFKA-5787
URL: https://issues.apache.org/jira/browse/KAFKA-5787
Project:
Damian Guy created KAFKA-5769:
-
Summary: Transient test failure
org.apache.kafka.streams.integration.KStreamRepartitionJoinTest.shouldCorrectlyRepartitionOnJoinOperationsWithZeroSizedCache
Key: KAFKA-5769
URL: https:/
[
https://issues.apache.org/jira/browse/KAFKA-5689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy resolved KAFKA-5689.
---
Resolution: Fixed
Fix Version/s: 1.0.0
Issue resolved by pull request 3692
[https://github.com/
[
https://issues.apache.org/jira/browse/KAFKA-5725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy resolved KAFKA-5725.
---
Resolution: Fixed
> Additional failure testing for streams with bouncing brokers
> ---
Damian Guy created KAFKA-5749:
-
Summary: Refactor SessionStore hierarchy
Key: KAFKA-5749
URL: https://issues.apache.org/jira/browse/KAFKA-5749
Project: Kafka
Issue Type: Sub-task
Compon
[
https://issues.apache.org/jira/browse/KAFKA-5242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy resolved KAFKA-5242.
---
Resolution: Won't Do
This has been fixed by KAFKA-5152 which has already been merged to 0.11.0.1
alre
[
https://issues.apache.org/jira/browse/KAFKA-5440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy resolved KAFKA-5440.
---
Resolution: Duplicate
> Kafka Streams report state RUNNING even if all threads are dead
>
[
https://issues.apache.org/jira/browse/KAFKA-4643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy resolved KAFKA-4643.
---
Resolution: Fixed
Fix Version/s: 1.0.0
Issue resolved by pull request 3663
[https://github.com/
[
https://issues.apache.org/jira/browse/KAFKA-5717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy resolved KAFKA-5717.
---
Resolution: Fixed
Fix Version/s: 0.11.0.1
1.0.0
Issue resolved by pull reque
Damian Guy created KAFKA-5702:
-
Summary: Refactor StreamThread to separate concerns and enable
better testability
Key: KAFKA-5702
URL: https://issues.apache.org/jira/browse/KAFKA-5702
Project: Kafka
Damian Guy created KAFKA-5689:
-
Summary: Refactor WindowStore hierarchy so that Metered Store is
the outermost store
Key: KAFKA-5689
URL: https://issues.apache.org/jira/browse/KAFKA-5689
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-5154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy resolved KAFKA-5154.
---
Resolution: Fixed
> Kafka Streams throws NPE during rebalance
> --
Damian Guy created KAFKA-5680:
-
Summary: Don't materliaze physical state stores in KTable
filter/map etc operations
Key: KAFKA-5680
URL: https://issues.apache.org/jira/browse/KAFKA-5680
Project: Kafka
Damian Guy created KAFKA-5673:
-
Summary: Refactor KeyValueStore hierarchy so that
MeteredKeyValueStore is the outermost store
Key: KAFKA-5673
URL: https://issues.apache.org/jira/browse/KAFKA-5673
Project:
Damian Guy created KAFKA-5672:
-
Summary: Move measureLatencyNs from StreamsMetricsImpl to
StreamsMetrics
Key: KAFKA-5672
URL: https://issues.apache.org/jira/browse/KAFKA-5672
Project: Kafka
Iss
[
https://issues.apache.org/jira/browse/KAFKA-5549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy resolved KAFKA-5549.
---
Resolution: Fixed
Fix Version/s: 1.0.0
Issue resolved by pull request 3544
[https://github.com/
Damian Guy created KAFKA-5655:
-
Summary: Add new API methods to KGroupedTable
Key: KAFKA-5655
URL: https://issues.apache.org/jira/browse/KAFKA-5655
Project: Kafka
Issue Type: Sub-task
Damian Guy created KAFKA-5653:
-
Summary: Add new API methods to KTable
Key: KAFKA-5653
URL: https://issues.apache.org/jira/browse/KAFKA-5653
Project: Kafka
Issue Type: Sub-task
Report
Damian Guy created KAFKA-5654:
-
Summary: Add new API methods to KGroupedStream
Key: KAFKA-5654
URL: https://issues.apache.org/jira/browse/KAFKA-5654
Project: Kafka
Issue Type: Sub-task
Damian Guy created KAFKA-5652:
-
Summary: Add new api methods to KStream
Key: KAFKA-5652
URL: https://issues.apache.org/jira/browse/KAFKA-5652
Project: Kafka
Issue Type: Sub-task
Repor
Damian Guy created KAFKA-5651:
-
Summary: KIP-182: Reduce Streams DSL overloads and allow easier
use of custom storage engines
Key: KAFKA-5651
URL: https://issues.apache.org/jira/browse/KAFKA-5651
Project:
Damian Guy created KAFKA-5650:
-
Summary: Provide a simple way for custom storage engines to use
streams wrapped stores (KIP-182)
Key: KAFKA-5650
URL: https://issues.apache.org/jira/browse/KAFKA-5650
Proje
[
https://issues.apache.org/jira/browse/KAFKA-3741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy resolved KAFKA-3741.
---
Resolution: Fixed
Fix Version/s: 0.11.1.0
Issue resolved by pull request 3459
[https://github.c
[
https://issues.apache.org/jira/browse/KAFKA-5157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy resolved KAFKA-5157.
---
Resolution: Fixed
Issue resolved by pull request 3423
[https://github.com/apache/kafka/pull/3423]
> O
Damian Guy created KAFKA-5578:
-
Summary: Streams Task Assignor should consider the staleness of
state directories when allocating tasks
Key: KAFKA-5578
URL: https://issues.apache.org/jira/browse/KAFKA-5578
[
https://issues.apache.org/jira/browse/KAFKA-5566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy resolved KAFKA-5566.
---
Resolution: Fixed
Fix Version/s: 0.11.0.1
0.11.1.0
Issue resolved by pull re
Damian Guy created KAFKA-5562:
-
Summary: Do streams state directory cleanup on a single thread
Key: KAFKA-5562
URL: https://issues.apache.org/jira/browse/KAFKA-5562
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-5508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy resolved KAFKA-5508.
---
Resolution: Fixed
Fix Version/s: 0.11.0.1
0.11.1.0
Issue resolved by pull re
Damian Guy created KAFKA-5556:
-
Summary: KafkaConsumer throws: java.lang.IllegalStateException: >
Attempt to retrieve exception from future which hasn't failed
Key: KAFKA-5556
URL: https://issues.apache.org/jira/brows
[
https://issues.apache.org/jira/browse/KAFKA-5487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy resolved KAFKA-5487.
---
Resolution: Fixed
Fix Version/s: (was: 0.11.0.1)
0.11.1.0
Issue resolved
[
https://issues.apache.org/jira/browse/KAFKA-4913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy resolved KAFKA-4913.
---
Resolution: Fixed
Fix Version/s: (was: 0.11.0.1)
0.11.1.0
Issue resolved
[
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.replicas
> -
[
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.replicas
> --
[
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 division b
[
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 error
>
[
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 coordinator
>
[
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 coordinator
> -
[
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 in-memory
[
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 further information
[
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 in WriteTxnMarker
[
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 please
[
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 once
[
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 WriteTxnMarker response
[
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 has actually
[
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 transactionalIds
> ---
[
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 rebalance
> --
Damian Guy created KAFKA-5288:
-
Summary: Failure in
org.apache.kafka.streams.integration.ResetIntegrationTest.testReprocessingFromScratchAfterResetWithoutIntermediateUserTopic
Key: KAFKA-5288
URL: https://issues.apach
[
https://issues.apache.org/jira/browse/KAFKA-5063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy reopened KAFKA-5063:
---
> Flaky
> ResetIntegrationTest.testReprocessingFromScratchAfterResetWithIntermediateUserTopic
> -
[
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:
{noformat}
java.l
[
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 have a checkpoi
[
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 logs.
[
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 rebalance
> -
[
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 for
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-5129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy reassigned KAFKA-5129:
-
Assignee: Damian Guy
> TransactionCoordinator - Add ACL check for each request
>
1 - 100 of 391 matches
Mail list logo
