Sushant Mahajan created KAFKA-19344:
---
Summary: Move assignable share partition method from describer to
group spec.
Key: KAFKA-19344
URL: https://issues.apache.org/jira/browse/KAFKA-19344
Project: K
AndrewJSchofield commented on code in PR #19826:
URL: https://github.com/apache/kafka/pull/19826#discussion_r2111042578
##
core/src/test/scala/integration/kafka/api/AuthorizerIntegrationTest.scala:
##
@@ -288,7 +290,8 @@ class AuthorizerIntegrationTest extends
AbstractAuthorize
johnny94 opened a new pull request, #19835:
URL: https://github.com/apache/kafka/pull/19835
`JsonNode.fields()` method has been deprecated by
- https://github.com/FasterXML/jackson-databind/issues/4863
- https://github.com/FasterXML/jackson-databind/pull/4871
So modified accordi
AndrewJSchofield merged PR #19829:
URL: https://github.com/apache/kafka/pull/19829
--
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...@kafk
showuon opened a new pull request, #19834:
URL: https://github.com/apache/kafka/pull/19834
Delete this text and replace it with a detailed description of your change.
The
PR title and body will become the squashed commit message.
If you would like to tag individuals, add some comm
showuon closed pull request #19833: [WIP] MINOR: bump dependency test
URL: https://github.com/apache/kafka/pull/19833
--
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 unsubsc
frankvicky commented on code in PR #19793:
URL: https://github.com/apache/kafka/pull/19793#discussion_r2110852699
##
server/src/main/java/org/apache/kafka/server/DelayedProduce.java:
##
@@ -0,0 +1,235 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
johnny94 commented on code in PR #19793:
URL: https://github.com/apache/kafka/pull/19793#discussion_r2110841393
##
server/src/main/java/org/apache/kafka/server/DelayedProduce.java:
##
@@ -0,0 +1,235 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+
frankvicky commented on code in PR #19810:
URL: https://github.com/apache/kafka/pull/19810#discussion_r2110833847
##
clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/consumer/ConsumerWithLegacyMessageFormatIntegrationTest.java:
##
@@ -0,0 +1,226 @@
+/*
+
showuon closed pull request #19833: [WIP] MINOR: bump dependency test
URL: https://github.com/apache/kafka/pull/19833
--
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 unsubsc
github-actions[bot] commented on PR #18991:
URL: https://github.com/apache/kafka/pull/18991#issuecomment-2914804432
This PR is being marked as stale since it has not had any activity in 90
days. If you
would like to keep this PR alive, please leave a comment asking for a
review. If the P
github-actions[bot] closed pull request #18332: KAFKA-18337: KafkaProducer
Memory Leak in JmxReporter Class
URL: https://github.com/apache/kafka/pull/18332
--
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
github-actions[bot] commented on PR #18332:
URL: https://github.com/apache/kafka/pull/18332#issuecomment-2914804287
This PR has been closed since it has not had any activity in 120 days. If
you feel like this
was a mistake, or you would like to continue working on it, please feel free
to
github-actions[bot] commented on PR #19754:
URL: https://github.com/apache/kafka/pull/19754#issuecomment-2914778454
A label of 'needs-attention' was automatically added to this PR in order to
raise the
attention of the committers. Once this issue has been triaged, the `triage`
label
s
frankvicky merged PR #19825:
URL: https://github.com/apache/kafka/pull/19825
--
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.apac
frankvicky merged PR #19510:
URL: https://github.com/apache/kafka/pull/19510
--
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.apac
DL1231 commented on code in PR #19826:
URL: https://github.com/apache/kafka/pull/19826#discussion_r2110675097
##
core/src/test/scala/integration/kafka/api/AuthorizerIntegrationTest.scala:
##
@@ -288,7 +290,8 @@ class AuthorizerIntegrationTest extends
AbstractAuthorizerIntegrati
artemlivshits commented on code in PR #19751:
URL: https://github.com/apache/kafka/pull/19751#discussion_r2110652240
##
core/src/main/scala/kafka/coordinator/transaction/TransactionCoordinator.scala:
##
@@ -135,10 +136,10 @@ class TransactionCoordinator(txnConfig: TransactionCon
showuon opened a new pull request, #19833:
URL: https://github.com/apache/kafka/pull/19833
Delete this text and replace it with a detailed description of your change.
The
PR title and body will become the squashed commit message.
If you would like to tag individuals, add some comm
artemlivshits commented on code in PR #19714:
URL: https://github.com/apache/kafka/pull/19714#discussion_r2110441628
##
clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java:
##
@@ -884,6 +884,50 @@ public void abortTransaction() throws
ProducerFencedExcept
cmccabe merged PR #19692:
URL: https://github.com/apache/kafka/pull/19692
--
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.
cmccabe commented on PR #19692:
URL: https://github.com/apache/kafka/pull/19692#issuecomment-2914348549
For failures, I see these, which appear to be unrelated:
```
[2025-05-12T23:40:32.246Z] Gradle Test Run :core:test > Gradle Test Executor
70 > UserClientIdQuotaTest > testProducerCon
cmccabe merged PR #19690:
URL: https://github.com/apache/kafka/pull/19690
--
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.
cmccabe merged PR #19689:
URL: https://github.com/apache/kafka/pull/19689
--
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.
mjsax opened a new pull request, #19832:
URL: https://github.com/apache/kafka/pull/19832
To allow intercepting the internal subscribe call to the async-consumer, we
need to extend ConsumerWrapper interface accordingly, instead of returning the
wrapped async-consumer back to the KS runtime.
jolshan merged PR #19801:
URL: https://github.com/apache/kafka/pull/19801
--
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-19335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-19335:
Component/s: streams
> Streams group heartbeat sometimes fails with INVALID_REQUEST
>
mumrah commented on code in PR #19371:
URL: https://github.com/apache/kafka/pull/19371#discussion_r2109579630
##
core/src/main/scala/kafka/raft/KafkaMetadataLog.scala:
##
@@ -639,12 +637,6 @@ object KafkaMetadataLog extends Logging {
nodeId
)
-// Print a warnin
MahsaSeifikar commented on code in PR #19742:
URL: https://github.com/apache/kafka/pull/19742#discussion_r2110082036
##
core/src/main/scala/kafka/server/ClientQuotaManager.scala:
##
@@ -451,6 +451,37 @@ class ClientQuotaManager(private val config:
ClientQuotaManagerConfig,
josefk31 commented on code in PR #19742:
URL: https://github.com/apache/kafka/pull/19742#discussion_r2110071531
##
core/src/main/scala/kafka/server/ClientQuotaManager.scala:
##
@@ -451,6 +451,37 @@ class ClientQuotaManager(private val config:
ClientQuotaManagerConfig,
}
[
https://issues.apache.org/jira/browse/KAFKA-19266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Abhinav Dixit resolved KAFKA-19266.
---
Resolution: Not A Problem
> Eliminate flakiness in test
> SharePartitionTest.testAcquisitio
[
https://issues.apache.org/jira/browse/KAFKA-19266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17954406#comment-17954406
]
Abhinav Dixit commented on KAFKA-19266:
---
The develocity link posted in description
apoorvmittal10 commented on PR #19823:
URL: https://github.com/apache/kafka/pull/19823#issuecomment-2913786625
> @apoorvmittal10 , the tests in `DelayedShareFetchTest` should only test
whether the functionalities of `DelayedShareFetch` are working. Considering
that, the changed functions on
adixitconfluent commented on PR #19823:
URL: https://github.com/apache/kafka/pull/19823#issuecomment-2913779258
> The exception is because of the call `RecordBatch firstOverlapBatch =
iterator.next();` in ShareFetchUtils when MemoryRecords is Empty. In the actual
runs this scenario cannot h
adixitconfluent commented on PR #19823:
URL: https://github.com/apache/kafka/pull/19823#issuecomment-2913794461
> > @apoorvmittal10 , the tests in `DelayedShareFetchTest` should only test
whether the functionalities of `DelayedShareFetch` are working. Considering
that, the changed functions
MahsaSeifikar commented on code in PR #19742:
URL: https://github.com/apache/kafka/pull/19742#discussion_r2110041979
##
core/src/main/scala/kafka/server/ClientQuotaManager.scala:
##
@@ -155,6 +155,7 @@ class ClientQuotaManager(private val config:
ClientQuotaManagerConfig,
[
https://issues.apache.org/jira/browse/KAFKA-19259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17954402#comment-17954402
]
Lianet Magrans commented on KAFKA-19259:
Hey [~goyarpit], sorry I've been away b
[
https://issues.apache.org/jira/browse/KAFKA-19259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans updated KAFKA-19259:
---
Attachment: console-consumer-classic-vs-consumer.mov
> Async consumer fetch intermittent del
MahsaSeifikar commented on code in PR #19742:
URL: https://github.com/apache/kafka/pull/19742#discussion_r2109905205
##
core/src/test/scala/unit/kafka/server/ClientQuotaManagerTest.scala:
##
@@ -17,16 +17,21 @@
package kafka.server
import kafka.server.ClientQuotaManager.Base
AndrewJSchofield commented on code in PR #19818:
URL: https://github.com/apache/kafka/pull/19818#discussion_r2108744389
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ShareMembershipManager.java:
##
@@ -137,16 +137,23 @@ public void
onHeartbeatSuccess(Shar
MahsaSeifikar commented on code in PR #19742:
URL: https://github.com/apache/kafka/pull/19742#discussion_r2109950623
##
core/src/main/scala/kafka/server/ClientQuotaManager.scala:
##
@@ -155,6 +155,7 @@ class ClientQuotaManager(private val config:
ClientQuotaManagerConfig,
MahsaSeifikar commented on code in PR #19742:
URL: https://github.com/apache/kafka/pull/19742#discussion_r2109950623
##
core/src/main/scala/kafka/server/ClientQuotaManager.scala:
##
@@ -155,6 +155,7 @@ class ClientQuotaManager(private val config:
ClientQuotaManagerConfig,
MahsaSeifikar commented on code in PR #19742:
URL: https://github.com/apache/kafka/pull/19742#discussion_r2109927773
##
core/src/main/scala/kafka/server/ClientQuotaManager.scala:
##
@@ -451,6 +451,37 @@ class ClientQuotaManager(private val config:
ClientQuotaManagerConfig,
MahsaSeifikar commented on code in PR #19742:
URL: https://github.com/apache/kafka/pull/19742#discussion_r2109894483
##
core/src/test/scala/unit/kafka/server/ClientQuotaManagerTest.scala:
##
@@ -17,16 +17,21 @@
package kafka.server
import kafka.server.ClientQuotaManager.Base
MahsaSeifikar commented on code in PR #19742:
URL: https://github.com/apache/kafka/pull/19742#discussion_r2109894197
##
core/src/main/scala/kafka/server/ClientQuotaManager.scala:
##
@@ -155,6 +155,7 @@ class ClientQuotaManager(private val config:
ClientQuotaManagerConfig,
MahsaSeifikar commented on code in PR #19742:
URL: https://github.com/apache/kafka/pull/19742#discussion_r2109905205
##
core/src/test/scala/unit/kafka/server/ClientQuotaManagerTest.scala:
##
@@ -17,16 +17,21 @@
package kafka.server
import kafka.server.ClientQuotaManager.Base
MahsaSeifikar commented on code in PR #19742:
URL: https://github.com/apache/kafka/pull/19742#discussion_r2109889445
##
core/src/main/scala/kafka/server/ClientQuotaManager.scala:
##
@@ -155,6 +155,7 @@ class ClientQuotaManager(private val config:
ClientQuotaManagerConfig,
lucasbru commented on code in PR #19818:
URL: https://github.com/apache/kafka/pull/19818#discussion_r2109724048
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ShareMembershipManager.java:
##
@@ -137,16 +137,23 @@ public void
onHeartbeatSuccess(ShareGroupHe
kevin-wu24 commented on PR #19668:
URL: https://github.com/apache/kafka/pull/19668#issuecomment-2913325616
A note about `KafkaRaftClient#maybeSendRequest` and the `RequestManager`,
stemming sort of off of the redundancy mentioned for FETCH
[here](https://github.com/apache/kafka/pull/19668#d
lucasbru commented on PR #19818:
URL: https://github.com/apache/kafka/pull/19818#issuecomment-2913320474
@ShivsundarR @lianetm ready for re-review
--
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
lucasbru commented on code in PR #19818:
URL: https://github.com/apache/kafka/pull/19818#discussion_r2109726136
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/ShareMembershipManagerTest.java:
##
@@ -561,10 +568,42 @@ public void
testIgnoreHeartbeatResponse
José Armando García Sancio created KAFKA-19343:
--
Summary: Misconfigured broker listeners causes unrecoverable
controller error
Key: KAFKA-19343
URL: https://issues.apache.org/jira/browse/KAFKA-19343
ahuang98 commented on code in PR #19742:
URL: https://github.com/apache/kafka/pull/19742#discussion_r2109645774
##
core/src/main/scala/kafka/server/ClientQuotaManager.scala:
##
@@ -155,6 +155,7 @@ class ClientQuotaManager(private val config:
ClientQuotaManagerConfig,
case
josefk31 commented on code in PR #19742:
URL: https://github.com/apache/kafka/pull/19742#discussion_r2109435789
##
core/src/test/scala/unit/kafka/server/ClientQuotaManagerTest.scala:
##
@@ -17,16 +17,21 @@
package kafka.server
import kafka.server.ClientQuotaManager.BaseUserE
[
https://issues.apache.org/jira/browse/KAFKA-14895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Justine Olshan reassigned KAFKA-14895:
--
Assignee: Kuan Po Tseng (was: Justine Olshan)
> Move AddPartitionsToTxnManager files
AndrewJSchofield opened a new pull request, #19831:
URL: https://github.com/apache/kafka/pull/19831
This PR sets `SV_1` as the latest-production share version. This means for
AK 4.1 it will be a preview feature, not enabled by default, but can be enabled
without turning on unstable features
chia7712 commented on PR #19371:
URL: https://github.com/apache/kafka/pull/19371#issuecomment-2913172227
@mumrah thanks for your reviews. We will file a minor later
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
U
[
https://issues.apache.org/jira/browse/KAFKA-14895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17954375#comment-17954375
]
Justine Olshan commented on KAFKA-14895:
[~brandboat] please take it. thanks!
>
mingyen066 commented on code in PR #19741:
URL: https://github.com/apache/kafka/pull/19741#discussion_r2109523667
##
server/src/test/java/org/apache/kafka/api/EndToEndClusterIdTest.java:
##
@@ -0,0 +1,230 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or m
ShivsundarR commented on PR #19789:
URL: https://github.com/apache/kafka/pull/19789#issuecomment-2912377957
I noticed @adixitconfluent 's PR
[here](https://github.com/apache/kafka/pull/19824) which adds a `future.get()`
to `produceAbortedTransaction()`. This could explain the flakiness in
chia7712 commented on code in PR #19741:
URL: https://github.com/apache/kafka/pull/19741#discussion_r2109448024
##
server/src/test/java/org/apache/kafka/api/EndToEndClusterIdTest.java:
##
@@ -0,0 +1,230 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or mor
AndrewJSchofield opened a new pull request, #19826:
URL: https://github.com/apache/kafka/pull/19826
Add integration tests for alter share group offsets API.
--
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
AndrewJSchofield opened a new pull request, #19830:
URL: https://github.com/apache/kafka/pull/19830
This PR makes some very small improvements to the record schemas for the
share coordinator.
* It removes the health warnings about incompatible changes. All changes are
compatible now.
AndrewJSchofield opened a new pull request, #19829:
URL: https://github.com/apache/kafka/pull/19829
This PR makes some trivial improvements to the output formatting of the
tools that are used to delete consumer groups and share groups.
* In general, group IDs are enclosed in single qu
Rancho-7 commented on code in PR #19810:
URL: https://github.com/apache/kafka/pull/19810#discussion_r2109104806
##
clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/consumer/ConsumerWithLegacyMessageFormatIntegrationTest.java:
##
@@ -0,0 +1,226 @@
+/*
+ *
kevin-wu24 commented on code in PR #19828:
URL: https://github.com/apache/kafka/pull/19828#discussion_r2109394645
##
metadata/src/main/java/org/apache/kafka/controller/metrics/QuorumControllerMetrics.java:
##
@@ -267,7 +267,11 @@ public long newActiveControllers() {
}
brandboat commented on code in PR #19828:
URL: https://github.com/apache/kafka/pull/19828#discussion_r2109362637
##
metadata/src/main/java/org/apache/kafka/controller/metrics/QuorumControllerMetrics.java:
##
@@ -267,7 +267,11 @@ public long newActiveControllers() {
}
brandboat commented on code in PR #19828:
URL: https://github.com/apache/kafka/pull/19828#discussion_r2109362637
##
metadata/src/main/java/org/apache/kafka/controller/metrics/QuorumControllerMetrics.java:
##
@@ -267,7 +267,11 @@ public long newActiveControllers() {
}
kevin-wu24 opened a new pull request, #19828:
URL: https://github.com/apache/kafka/pull/19828
Fix `updateBrokerContactTime` so that existing brokers still have their
contact time updated when they are already tracked. Also, update the unit test
to test this case.
--
This is an automa
[
https://issues.apache.org/jira/browse/KAFKA-19154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot resolved KAFKA-19154.
-
Fix Version/s: 4.1.0
Resolution: Fixed
> Return INVALID_OFFSET if requested topic id does
dajac merged PR #19744:
URL: https://github.com/apache/kafka/pull/19744
--
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
[
https://issues.apache.org/jira/browse/KAFKA-18823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai resolved KAFKA-18823.
Resolution: Duplicate
see https://github.com/apache/kafka/pull/18844
> native docker don'
m1a2st opened a new pull request, #19827:
URL: https://github.com/apache/kafka/pull/19827
Use Java to rewrite PlaintextConsumerSubscriptionTest by new test infra and
move it to client-integration-tests module.
--
This is an automated message from the Apache Git Service.
To respond to
lucasbru commented on code in PR #19646:
URL: https://github.com/apache/kafka/pull/19646#discussion_r2108855809
##
tools/src/main/java/org/apache/kafka/tools/streams/StreamsGroupCommand.java:
##
@@ -330,13 +403,433 @@ Map
getOffsets(StreamsGroupDescription description)
Patrik Kleindl created KAFKA-19341:
--
Summary: Execution of HighWatermarkUpdate failed
Key: KAFKA-19341
URL: https://issues.apache.org/jira/browse/KAFKA-19341
Project: Kafka
Issue Type: Bug
Sushant Mahajan created KAFKA-19338:
---
Summary: Share coordinator read state and write state should
return error, if the share partition is not initialized.
Key: KAFKA-19338
URL: https://issues.apache.org/jira/br
[
https://issues.apache.org/jira/browse/KAFKA-19341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Patrik Kleindl updated KAFKA-19341:
---
Description:
We got the following Exception multiple times in our logs when a client showed
Andrew Schofield created KAFKA-19342:
Summary: Add AuthorizerIntegrationTest for alter share group
offsets
Key: KAFKA-19342
URL: https://issues.apache.org/jira/browse/KAFKA-19342
Project: Kafka
Rancho-7 commented on PR #19685:
URL: https://github.com/apache/kafka/pull/19685#issuecomment-2912306275
fixed it. @chia7712
--
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.
[
https://issues.apache.org/jira/browse/KAFKA-19340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lan Ding updated KAFKA-19340:
-
Priority: Minor (was: Major)
> Move DelayedRemoteFetch to the storage module
>
Lan Ding created KAFKA-19340:
Summary: Move DelayedRemoteFetch to the storage module
Key: KAFKA-19340
URL: https://issues.apache.org/jira/browse/KAFKA-19340
Project: Kafka
Issue Type: Sub-task
AndrewJSchofield merged PR #19824:
URL: https://github.com/apache/kafka/pull/19824
--
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...@kafk
Kuan Po Tseng created KAFKA-19339:
-
Summary: Move DelayedFetch to server module
Key: KAFKA-19339
URL: https://issues.apache.org/jira/browse/KAFKA-19339
Project: Kafka
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/KAFKA-19337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sushant Mahajan updated KAFKA-19337:
Summary: Bug in ShareCoordinatorShard.generateShareStateRecord causes
stateEpoch update mi
brandboat commented on code in PR #19793:
URL: https://github.com/apache/kafka/pull/19793#discussion_r2108937663
##
server/src/main/java/org/apache/kafka/server/DelayedProduce.java:
##
@@ -0,0 +1,235 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+
mingyen066 opened a new pull request, #19825:
URL: https://github.com/apache/kafka/pull/19825
[KIP-1143](https://cwiki.apache.org/confluence/x/LwqWF) replaced
`Optional listenerName()` with `String listener()`.
This patch migrates the usage from the deprecated method to the new one.
[
https://issues.apache.org/jira/browse/KAFKA-19337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sushant Mahajan updated KAFKA-19337:
Description:
{{private CoordinatorRecord generateShareStateRecord(}}
{{ WriteShareGroupSt
[
https://issues.apache.org/jira/browse/KAFKA-19337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sushant Mahajan updated KAFKA-19337:
Description:
{{private CoordinatorRecord generateShareStateRecord(}}
{{ WriteShareGroupSt
Sushant Mahajan created KAFKA-19337:
---
Summary: Bug in ShareCoordinatorShard.generateShareStateRecord
prevents stateEpoch update misses.
Key: KAFKA-19337
URL: https://issues.apache.org/jira/browse/KAFKA-19337
sjhajharia commented on PR #19510:
URL: https://github.com/apache/kafka/pull/19510#issuecomment-2912067260
Gentle reminder
@frankvicky
--
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 spec
[
https://issues.apache.org/jira/browse/KAFKA-19332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Apoorv Mittal reassigned KAFKA-19332:
-
Assignee: Abhinav Dixit
> Fix flaky test :
> testAlterReadCommittedToReadUncommittedIs
chia7712 commented on PR #19741:
URL: https://github.com/apache/kafka/pull/19741#issuecomment-2911987458
@mingyen066 please fix conflicts
--
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 speci
[
https://issues.apache.org/jira/browse/KAFKA-19330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai resolved KAFKA-19330.
Fix Version/s: 4.1.0
Resolution: Fixed
> MockSerializer should extend Serializer
>
chia7712 merged PR #19812:
URL: https://github.com/apache/kafka/pull/19812
--
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
chia7712 commented on PR #19812:
URL: https://github.com/apache/kafka/pull/19812#issuecomment-2911986064
the failed test is traced by https://issues.apache.org/jira/browse/KAFKA-7542
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Gi
lucasbru commented on code in PR #19758:
URL: https://github.com/apache/kafka/pull/19758#discussion_r2108793364
##
tools/src/main/java/org/apache/kafka/tools/streams/StreamsGroupCommand.java:
##
@@ -398,6 +403,127 @@ protected Admin createAdminClient(Map
configOverrides) throws
showuon merged PR #19780:
URL: https://github.com/apache/kafka/pull/19780
--
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.
showuon commented on PR #19780:
URL: https://github.com/apache/kafka/pull/19780#issuecomment-2911938507
> We just use the command that regenerates the file - that used all before.
Not sure if that changed.
Let's move to `bin` as suggested. And we can always move back to `all` if
need
adixitconfluent opened a new pull request, #19824:
URL: https://github.com/apache/kafka/pull/19824
### About
This PR attempts to removed the flakiness in
`testAlterReadCommittedToReadUncommittedIsolationLevelWithReleaseAck` and
`testAlterReadCommittedToReadUncommittedIsolationLevelWithRe
dajac commented on PR #19761:
URL: https://github.com/apache/kafka/pull/19761#issuecomment-2911847729
@FrankYang0529 We just merged https://github.com/apache/kafka/pull/19790.
Could you please rebase?
--
This is an automated message from the Apache Git Service.
To respond to the message,
1 - 100 of 113 matches
Mail list logo
