ijuma commented on code in PR #14470:
URL: https://github.com/apache/kafka/pull/14470#discussion_r1345292439
##
core/src/main/scala/kafka/log/UnifiedLog.scala:
##
@@ -768,10 +768,10 @@ class UnifiedLog(@volatile var logStartOffset: Long,
// This will ensure that any log dat
ijuma commented on code in PR #14470:
URL: https://github.com/apache/kafka/pull/14470#discussion_r1345296313
##
core/src/main/scala/kafka/raft/KafkaMetadataLog.scala:
##
@@ -96,10 +96,10 @@ final class KafkaMetadataLog private (
}
private def handleAndConvertLogAppendInf
soarez commented on code in PR #14290:
URL: https://github.com/apache/kafka/pull/14290#discussion_r1345336375
##
generator/src/main/java/org/apache/kafka/message/FieldSpec.java:
##
@@ -157,11 +157,6 @@ private void checkTagInvariants() {
this.taggedVersions
divijvaidya commented on PR #14480:
URL: https://github.com/apache/kafka/pull/14480#issuecomment-1746315640
> If we don't already report the AddPartitionsToTxn request metrics in this
file, it doesn't make sense to add the verification variant. (As well as all
the other APIs we report)
W
divijvaidya commented on code in PR #14480:
URL: https://github.com/apache/kafka/pull/14480#discussion_r1345351170
##
docs/ops.html:
##
@@ -1789,6 +1789,16 @@
divijvaidya commented on code in PR #14482:
URL: https://github.com/apache/kafka/pull/14482#discussion_r1345355926
##
core/src/test/scala/unit/kafka/log/remote/RemoteIndexCacheTest.scala:
##
@@ -541,6 +541,126 @@ class RemoteIndexCacheTest {
verifyFetchIndexInvocation(count
raboof commented on PR #14474:
URL: https://github.com/apache/kafka/pull/14474#issuecomment-1746368814
This fix was also in #14475 which has been merged
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to
raboof closed pull request #14474: KAFKA-14593: fix gradle build
URL: https://github.com/apache/kafka/pull/14474
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe,
iit2009060 commented on code in PR #14482:
URL: https://github.com/apache/kafka/pull/14482#discussion_r1345392660
##
core/src/test/scala/unit/kafka/log/remote/RemoteIndexCacheTest.scala:
##
@@ -541,6 +541,126 @@ class RemoteIndexCacheTest {
verifyFetchIndexInvocation(count
iit2009060 commented on code in PR #14482:
URL: https://github.com/apache/kafka/pull/14482#discussion_r1345403872
##
core/src/test/scala/unit/kafka/log/remote/RemoteIndexCacheTest.scala:
##
@@ -541,6 +541,126 @@ class RemoteIndexCacheTest {
verifyFetchIndexInvocation(count
iit2009060 commented on code in PR #14482:
URL: https://github.com/apache/kafka/pull/14482#discussion_r1345403872
##
core/src/test/scala/unit/kafka/log/remote/RemoteIndexCacheTest.scala:
##
@@ -541,6 +541,126 @@ class RemoteIndexCacheTest {
verifyFetchIndexInvocation(count
iit2009060 commented on code in PR #14482:
URL: https://github.com/apache/kafka/pull/14482#discussion_r1345438999
##
core/src/test/scala/unit/kafka/log/remote/RemoteIndexCacheTest.scala:
##
@@ -541,6 +541,126 @@ class RemoteIndexCacheTest {
verifyFetchIndexInvocation(count
vamossagar12 commented on PR #14463:
URL: https://github.com/apache/kafka/pull/14463#issuecomment-1746423437
Thanks @kirktrue , LGTM (I had already approved).
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL abo
iit2009060 commented on code in PR #14482:
URL: https://github.com/apache/kafka/pull/14482#discussion_r1345392660
##
core/src/test/scala/unit/kafka/log/remote/RemoteIndexCacheTest.scala:
##
@@ -541,6 +541,126 @@ class RemoteIndexCacheTest {
verifyFetchIndexInvocation(count
iit2009060 commented on code in PR #14482:
URL: https://github.com/apache/kafka/pull/14482#discussion_r1345403872
##
core/src/test/scala/unit/kafka/log/remote/RemoteIndexCacheTest.scala:
##
@@ -541,6 +541,126 @@ class RemoteIndexCacheTest {
verifyFetchIndexInvocation(count
vamossagar12 commented on code in PR #14432:
URL: https://github.com/apache/kafka/pull/14432#discussion_r1345450086
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java:
##
@@ -593,6 +609,9 @@ private void throwIfConsumerGroupHeartbeatR
vamossagar12 commented on PR #14423:
URL: https://github.com/apache/kafka/pull/14423#issuecomment-1746443694
Thanks for the PR @sangyongchoi. Couple of thoughts =>
1. If there are other instances of such lines which are meaningless, could
you also add them.
2. Can you add `[MINOR]` in
vamossagar12 commented on PR #14327:
URL: https://github.com/apache/kafka/pull/14327#issuecomment-1746457140
@JimmyWang6 , In the PR title, you have mentioned `KAFKA-14048` which is the
uber ticket for KIP-848. Please change it to `KAFKA-14517` instead.
--
This is an automated message fro
[
https://issues.apache.org/jira/browse/KAFKA-15535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya updated KAFKA-15535:
-
Labels: tiered-storage (was: )
> Add documentation of "remote.log.index.file.cache.total.size.b
[
https://issues.apache.org/jira/browse/KAFKA-15481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeel Jotaniya reassigned KAFKA-15481:
-
Assignee: Jeel Jotaniya
> Concurrency bug in RemoteIndexCache leads to IOException
> --
dajac merged PR #14408:
URL: https://github.com/apache/kafka/pull/14408
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.or
tledkov commented on code in PR #13247:
URL: https://github.com/apache/kafka/pull/13247#discussion_r1345514076
##
tools/src/main/java/org/apache/kafka/tools/reassign/Tuple2.java:
##
@@ -0,0 +1,48 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * c
dajac commented on code in PR #14462:
URL: https://github.com/apache/kafka/pull/14462#discussion_r1345506634
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java:
##
@@ -8686,6 +8695,88 @@ public void testListGroups() {
ass
nizhikov commented on PR #13247:
URL: https://github.com/apache/kafka/pull/13247#issuecomment-1746528192
@tledkov
> `ReplicationQuotasTestRig` no longer needed?
This class not used through current codebase.
But it has dependency on `ReassignPartitionCommand`.
So, for
nizhikov commented on code in PR #13247:
URL: https://github.com/apache/kafka/pull/13247#discussion_r1345524979
##
tools/src/main/java/org/apache/kafka/tools/reassign/Tuple2.java:
##
@@ -0,0 +1,48 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ *
iit2009060 commented on code in PR #14482:
URL: https://github.com/apache/kafka/pull/14482#discussion_r1345526187
##
core/src/test/scala/unit/kafka/log/remote/RemoteIndexCacheTest.scala:
##
@@ -541,6 +541,126 @@ class RemoteIndexCacheTest {
verifyFetchIndexInvocation(count
iit2009060 commented on code in PR #14482:
URL: https://github.com/apache/kafka/pull/14482#discussion_r1345526998
##
core/src/test/scala/unit/kafka/log/remote/RemoteIndexCacheTest.scala:
##
@@ -541,6 +541,126 @@ class RemoteIndexCacheTest {
verifyFetchIndexInvocation(count
tledkov commented on code in PR #13247:
URL: https://github.com/apache/kafka/pull/13247#discussion_r1345531820
##
tools/src/main/java/org/apache/kafka/tools/reassign/ReassignPartitionsCommand.java:
##
@@ -0,0 +1,1501 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) un
iit2009060 commented on code in PR #14482:
URL: https://github.com/apache/kafka/pull/14482#discussion_r1345533167
##
core/src/test/scala/unit/kafka/log/remote/RemoteIndexCacheTest.scala:
##
@@ -541,6 +541,126 @@ class RemoteIndexCacheTest {
verifyFetchIndexInvocation(count
dajac commented on code in PR #14467:
URL: https://github.com/apache/kafka/pull/14467#discussion_r1345534442
##
core/src/main/scala/kafka/coordinator/group/CoordinatorPartitionWriter.scala:
##
@@ -123,50 +124,79 @@ class CoordinatorPartitionWriter[T](
val maxBatchSize =
jeel2420 opened a new pull request, #14483:
URL: https://github.com/apache/kafka/pull/14483
This PR fixes the concurrency bug in RemoteIndexCache.
(From Jira description)
RemoteIndexCache has a concurrency bug which leads to IOException while
fetching data from remote tier.
dajac commented on code in PR #14467:
URL: https://github.com/apache/kafka/pull/14467#discussion_r1345541333
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/OffsetMetadataManager.java:
##
@@ -539,26 +564,59 @@ public OffsetFetchResponseData.OffsetFetchRespo
dajac merged PR #14463:
URL: https://github.com/apache/kafka/pull/14463
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.or
jeel2420 commented on code in PR #14483:
URL: https://github.com/apache/kafka/pull/14483#discussion_r1345548349
##
core/src/test/scala/unit/kafka/log/remote/RemoteIndexCacheTest.scala:
##
@@ -132,7 +133,7 @@ class RemoteIndexCacheTest {
// this call should have invoked fetc
nizhikov commented on code in PR #13247:
URL: https://github.com/apache/kafka/pull/13247#discussion_r1345590444
##
tools/src/main/java/org/apache/kafka/tools/reassign/ReassignPartitionsCommand.java:
##
@@ -0,0 +1,1501 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) u
msn-tldr commented on code in PR #14384:
URL: https://github.com/apache/kafka/pull/14384#discussion_r1345590803
##
clients/src/main/java/org/apache/kafka/clients/producer/internals/ProducerBatch.java:
##
@@ -94,9 +100,40 @@ public ProducerBatch(TopicPartition tp,
MemoryRecordsB
msn-tldr commented on code in PR #14384:
URL: https://github.com/apache/kafka/pull/14384#discussion_r1345592537
##
clients/src/test/java/org/apache/kafka/clients/producer/internals/SenderTest.java:
##
@@ -156,6 +157,8 @@ public class SenderTest {
private SenderMetricsRegist
tledkov commented on code in PR #13247:
URL: https://github.com/apache/kafka/pull/13247#discussion_r1345629562
##
tools/src/main/java/org/apache/kafka/tools/reassign/ReassignPartitionsCommand.java:
##
@@ -0,0 +1,1501 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) un
tledkov commented on code in PR #13247:
URL: https://github.com/apache/kafka/pull/13247#discussion_r1345633642
##
tools/src/main/java/org/apache/kafka/tools/reassign/ReassignPartitionsCommand.java:
##
@@ -0,0 +1,1501 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) un
tledkov commented on code in PR #13247:
URL: https://github.com/apache/kafka/pull/13247#discussion_r1345633642
##
tools/src/main/java/org/apache/kafka/tools/reassign/ReassignPartitionsCommand.java:
##
@@ -0,0 +1,1501 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) un
tledkov commented on code in PR #13247:
URL: https://github.com/apache/kafka/pull/13247#discussion_r1345633642
##
tools/src/main/java/org/apache/kafka/tools/reassign/ReassignPartitionsCommand.java:
##
@@ -0,0 +1,1501 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) un
tledkov commented on code in PR #13247:
URL: https://github.com/apache/kafka/pull/13247#discussion_r1345642089
##
tools/src/main/java/org/apache/kafka/tools/reassign/ReassignPartitionsCommand.java:
##
@@ -0,0 +1,1501 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) un
nizhikov commented on code in PR #13247:
URL: https://github.com/apache/kafka/pull/13247#discussion_r1345647289
##
tools/src/main/java/org/apache/kafka/tools/reassign/ReassignPartitionsCommand.java:
##
@@ -0,0 +1,1501 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) u
nizhikov commented on code in PR #13247:
URL: https://github.com/apache/kafka/pull/13247#discussion_r1345648074
##
tools/src/main/java/org/apache/kafka/tools/reassign/ReassignPartitionsCommand.java:
##
@@ -0,0 +1,1501 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) u
nizhikov commented on code in PR #13247:
URL: https://github.com/apache/kafka/pull/13247#discussion_r1345657229
##
tools/src/main/java/org/apache/kafka/tools/reassign/ReassignPartitionsCommand.java:
##
@@ -0,0 +1,1501 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) u
tledkov commented on code in PR #13247:
URL: https://github.com/apache/kafka/pull/13247#discussion_r1345673613
##
tools/src/main/java/org/apache/kafka/tools/reassign/ReassignPartitionsCommand.java:
##
@@ -0,0 +1,1501 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) un
tledkov commented on code in PR #13247:
URL: https://github.com/apache/kafka/pull/13247#discussion_r1345673613
##
tools/src/main/java/org/apache/kafka/tools/reassign/ReassignPartitionsCommand.java:
##
@@ -0,0 +1,1501 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) un
cadonna merged PR #13927:
URL: https://github.com/apache/kafka/pull/13927
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.
[
https://issues.apache.org/jira/browse/KAFKA-10199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna resolved KAFKA-10199.
---
Resolution: Done
> Separate state restoration into separate threads
> --
[
https://issues.apache.org/jira/browse/KAFKA-10199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna updated KAFKA-10199:
--
Fix Version/s: 3.7.0
> Separate state restoration into separate threads
>
nizhikov commented on code in PR #13247:
URL: https://github.com/apache/kafka/pull/13247#discussion_r1345691324
##
tools/src/main/java/org/apache/kafka/tools/reassign/ReassignPartitionsCommand.java:
##
@@ -0,0 +1,1501 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) u
Federico Valeri created KAFKA-15537:
---
Summary: Unsafe metadata.version downgrade is not supported
Key: KAFKA-15537
URL: https://issues.apache.org/jira/browse/KAFKA-15537
Project: Kafka
Issu
[
https://issues.apache.org/jira/browse/KAFKA-15537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Federico Valeri updated KAFKA-15537:
Description:
In KIP-778 we introduced the "unsafe" downgrade functionality in case one of
[
https://issues.apache.org/jira/browse/KAFKA-15537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Federico Valeri updated KAFKA-15537:
Description:
In KIP-778 we introduced the "unsafe" downgrade functionality in case one of
[
https://issues.apache.org/jira/browse/KAFKA-15537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Federico Valeri updated KAFKA-15537:
Description:
In KIP-778 we introduced the "unsafe" downgrade functionality in case one of
[
https://issues.apache.org/jira/browse/KAFKA-15537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17771842#comment-17771842
]
Luke Chen commented on KAFKA-15537:
---
[~fvaleri], thanks for raising this issue. Since
iit2009060 commented on code in PR #14482:
URL: https://github.com/apache/kafka/pull/14482#discussion_r1345533167
##
core/src/test/scala/unit/kafka/log/remote/RemoteIndexCacheTest.scala:
##
@@ -541,6 +541,126 @@ class RemoteIndexCacheTest {
verifyFetchIndexInvocation(count
[
https://issues.apache.org/jira/browse/KAFKA-15537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Federico Valeri updated KAFKA-15537:
Description:
In KIP-778 we introduced the "unsafe" downgrade in case one of the metadata
fvaleri opened a new pull request, #14484:
URL: https://github.com/apache/kafka/pull/14484
In KIP-778 we introduced the "unsafe" downgrade in case one of the metadata
versions between target and current have changes, as defined in
MetadataVersion. This is a lossy downgrade where each node r
[
https://issues.apache.org/jira/browse/KAFKA-15537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17771844#comment-17771844
]
Federico Valeri commented on KAFKA-15537:
-
Sure. I already opened a PR to fix th
[
https://issues.apache.org/jira/browse/KAFKA-15537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Federico Valeri updated KAFKA-15537:
Component/s: documentation
> Unsafe metadata.version downgrade is not supported
>
[
https://issues.apache.org/jira/browse/KAFKA-15537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Federico Valeri updated KAFKA-15537:
Description:
In KIP-778 we introduced the "unsafe" downgrade in case one of the metadata
[
https://issues.apache.org/jira/browse/KAFKA-15537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Federico Valeri updated KAFKA-15537:
Affects Version/s: 3.5.1
> Unsafe metadata.version downgrade is not supported
> --
dajac commented on PR #14364:
URL: https://github.com/apache/kafka/pull/14364#issuecomment-1746844528
> @dajac @lianetm Thanks for the feedback. I addressed more of your
comments. I wanted to point out that I filed 3 follow-up tickets to close some
of the gaps. These are:
>
> * Propa
mumrah commented on PR #14478:
URL: https://github.com/apache/kafka/pull/14478#issuecomment-1746847899
Changes look good, but there are some failing tests.
https://github.com/apache/kafka/assets/55116/411b8ee4-fb1c-4537-a578-56550618d1aa";>
--
This is an automated message from t
[
https://issues.apache.org/jira/browse/KAFKA-15537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Federico Valeri updated KAFKA-15537:
Description:
In KIP-778 we introduced the "unsafe" downgrade in case one of the metadata
[
https://issues.apache.org/jira/browse/KAFKA-15537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Federico Valeri reassigned KAFKA-15537:
---
Assignee: Federico Valeri
> Unsafe metadata.version downgrade is not supported
> --
[
https://issues.apache.org/jira/browse/KAFKA-15537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17771844#comment-17771844
]
Federico Valeri edited comment on KAFKA-15537 at 10/4/23 1:10 PM:
[
https://issues.apache.org/jira/browse/KAFKA-15483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17771848#comment-17771848
]
ASF GitHub Bot commented on KAFKA-15483:
mumrah merged PR #548:
URL: https://git
Lianet Magrans created KAFKA-15538:
--
Summary: Resolve regex on client side when using java regex in new
consumer
Key: KAFKA-15538
URL: https://issues.apache.org/jira/browse/KAFKA-15538
Project: Kafk
Lianet Magrans created KAFKA-15539:
--
Summary: Stop fetching while partitions being revoked
Key: KAFKA-15539
URL: https://issues.apache.org/jira/browse/KAFKA-15539
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-15537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Federico Valeri updated KAFKA-15537:
Description:
In KIP-778 we introduced the "unsafe" downgrade in case metadata has changes
splett2 opened a new pull request, #14485:
URL: https://github.com/apache/kafka/pull/14485
### What
Addressing feedback left post-merge on #14470
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI b
splett2 commented on code in PR #14485:
URL: https://github.com/apache/kafka/pull/14485#discussion_r1345806386
##
core/src/main/scala/kafka/log/UnifiedLog.scala:
##
@@ -770,8 +770,8 @@ class UnifiedLog(@volatile var logStartOffset: Long,
val appendInfo = analyzeAndValidat
splett2 commented on code in PR #14485:
URL: https://github.com/apache/kafka/pull/14485#discussion_r1345807911
##
core/src/main/scala/kafka/raft/KafkaMetadataLog.scala:
##
@@ -96,7 +96,7 @@ final class KafkaMetadataLog private (
}
private def handleAndConvertLogAppendInf
splett2 commented on code in PR #14485:
URL: https://github.com/apache/kafka/pull/14485#discussion_r1345807911
##
core/src/main/scala/kafka/raft/KafkaMetadataLog.scala:
##
@@ -96,7 +96,7 @@ final class KafkaMetadataLog private (
}
private def handleAndConvertLogAppendInf
iit2009060 commented on code in PR #14482:
URL: https://github.com/apache/kafka/pull/14482#discussion_r1345403872
##
core/src/test/scala/unit/kafka/log/remote/RemoteIndexCacheTest.scala:
##
@@ -541,6 +541,126 @@ class RemoteIndexCacheTest {
verifyFetchIndexInvocation(count
iit2009060 commented on code in PR #14482:
URL: https://github.com/apache/kafka/pull/14482#discussion_r1345533167
##
core/src/test/scala/unit/kafka/log/remote/RemoteIndexCacheTest.scala:
##
@@ -541,6 +541,126 @@ class RemoteIndexCacheTest {
verifyFetchIndexInvocation(count
splett2 commented on PR #14470:
URL: https://github.com/apache/kafka/pull/14470#issuecomment-1746898555
thanks for the feedback @ijuma
I opened up https://github.com/apache/kafka/pull/14485 to address the
comments.
--
This is an automated message from the Apache Git Service.
To respon
Lianet Magrans created KAFKA-15540:
--
Summary: Handle heartbeat and assignment release when consumer
leaves group
Key: KAFKA-15540
URL: https://issues.apache.org/jira/browse/KAFKA-15540
Project: Kafka
yashmayya opened a new pull request, #14486:
URL: https://github.com/apache/kafka/pull/14486
- The collaborators list was initially added in
https://github.com/apache/kafka/pull/13713 (following the policy specified here
- https://github.com/apache/kafka-site/pull/510).
- The list is cur
[
https://issues.apache.org/jira/browse/KAFKA-15164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans resolved KAFKA-15164.
Resolution: Fixed
Included in PR https://github.com/apache/kafka/pull/14346
> Extract reu
[
https://issues.apache.org/jira/browse/KAFKA-15540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans updated KAFKA-15540:
---
Parent: KAFKA-14048
Issue Type: Sub-task (was: Task)
> Handle heartbeat and assignm
Nicholas Telford created KAFKA-15541:
Summary: RocksDB Iterator Metrics
Key: KAFKA-15541
URL: https://issues.apache.org/jira/browse/KAFKA-15541
Project: Kafka
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/KAFKA-15538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans updated KAFKA-15538:
---
Parent: KAFKA-14048
Issue Type: Sub-task (was: Task)
> Resolve regex on client side
[
https://issues.apache.org/jira/browse/KAFKA-15539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans updated KAFKA-15539:
---
Parent: KAFKA-14048
Issue Type: Sub-task (was: Task)
> Stop fetching while partitio
[
https://issues.apache.org/jira/browse/KAFKA-15539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans updated KAFKA-15539:
---
Labels: kip-848-client-support (was: )
> Stop fetching while partitions being revoked
> ---
[
https://issues.apache.org/jira/browse/KAFKA-15538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans updated KAFKA-15538:
---
Labels: kip-848 kip-848-client-support (was: )
> Resolve regex on client side when using ja
[
https://issues.apache.org/jira/browse/KAFKA-15539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans updated KAFKA-15539:
---
Labels: kip-848 kip-848-client-support (was: kip-848-client-support)
> Stop fetching while
[
https://issues.apache.org/jira/browse/KAFKA-15540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans updated KAFKA-15540:
---
Labels: kip-848 kip-848-client-support (was: )
> Handle heartbeat and assignment release wh
[
https://issues.apache.org/jira/browse/KAFKA-15438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17771869#comment-17771869
]
Lianet Magrans commented on KAFKA-15438:
Leaving as it is for now, given that it
[
https://issues.apache.org/jira/browse/KAFKA-15327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans updated KAFKA-15327:
---
Parent: KAFKA-14048
Issue Type: Sub-task (was: Bug)
> Async consumer should commit
[
https://issues.apache.org/jira/browse/KAFKA-15438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans resolved KAFKA-15438.
Resolution: Fixed
> Review exception caching logic used for reset/validate positions in as
Lianet Magrans created KAFKA-15542:
--
Summary: Release member assignments on errors
Key: KAFKA-15542
URL: https://issues.apache.org/jira/browse/KAFKA-15542
Project: Kafka
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/KAFKA-15539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans updated KAFKA-15539:
---
Summary: Client should stop fetching while partitions being revoked (was:
Stop fetching whi
[
https://issues.apache.org/jira/browse/KAFKA-15327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans updated KAFKA-15327:
---
Summary: Client consumer should commit offsets on close (was: Async
consumer should commit
mimaison commented on PR #12306:
URL: https://github.com/apache/kafka/pull/12306#issuecomment-1746974383
@vamossagar12 Are you still planning to complete this item?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
U
Lianet Magrans created KAFKA-15543:
--
Summary: Send HB request right after reconciliation completes
Key: KAFKA-15543
URL: https://issues.apache.org/jira/browse/KAFKA-15543
Project: Kafka
Issu
[
https://issues.apache.org/jira/browse/KAFKA-15533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans updated KAFKA-15533:
---
Parent: KAFKA-14048
Issue Type: Sub-task (was: Bug)
> Ensure HeartbeatRequestManage
[
https://issues.apache.org/jira/browse/KAFKA-15531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans updated KAFKA-15531:
---
Labels: kip-848-client-support (was: )
> Ensure coordinator node is removed upon disconnect
1 - 100 of 263 matches
Mail list logo
