showuon commented on PR #14649:
URL: https://github.com/apache/kafka/pull/14649#issuecomment-1851453276
@nikramakrishnan , nice catch! I've set
[KAFKA-15529](https://issues.apache.org/jira/browse/KAFKA-15529) as a blocker
for v3.7.0. Re-triggering the CI to make sure the tests are flaky.
[
https://issues.apache.org/jira/browse/KAFKA-15529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen updated KAFKA-15529:
--
Fix Version/s: 3.7.0
> Flaky test ReassignReplicaShrinkTest.executeTieredStorageTest
> ---
[
https://issues.apache.org/jira/browse/KAFKA-15529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen updated KAFKA-15529:
--
Priority: Blocker (was: Major)
> Flaky test ReassignReplicaShrinkTest.executeTieredStorageTest
>
hni61223 commented on PR #14400:
URL: https://github.com/apache/kafka/pull/14400#issuecomment-1851446583
Hey Ron, thank you for catching that bug. I added a log message to notify
the user that the start process and the stop process should be called from the
same directory. WDYT?
> T
VedarthConfluent opened a new pull request, #14989:
URL: https://github.com/apache/kafka/pull/14989
*More detailed description of your change,
if necessary. The PR title and PR message become
the squashed commit message, so use a separate
comment to ping reviewers.*
*Summary o
jolshan commented on code in PR #14774:
URL: https://github.com/apache/kafka/pull/14774#discussion_r1423490009
##
core/src/main/scala/kafka/coordinator/group/GroupMetadataManager.scala:
##
@@ -1378,6 +1350,28 @@ object GroupMetadataManager {
"%X".format(BigInt(1, bytes))
jolshan commented on code in PR #14774:
URL: https://github.com/apache/kafka/pull/14774#discussion_r1423489699
##
core/src/main/scala/kafka/coordinator/group/GroupMetadataManager.scala:
##
@@ -283,36 +284,7 @@ class GroupMetadataManager(brokerId: Int,
} else {
Vedarth Sharma created KAFKA-15994:
--
Summary: Add complex example compose file
Key: KAFKA-15994
URL: https://issues.apache.org/jira/browse/KAFKA-15994
Project: Kafka
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/KAFKA-15881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vedarth Sharma updated KAFKA-15881:
---
Description: Make changes to Release Process Wiki and docker README.md for
detailed release
[
https://issues.apache.org/jira/browse/KAFKA-15881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vedarth Sharma updated KAFKA-15881:
---
Summary: Make changes in Release Process Wiki and Release Process (was:
Update release.py s
[
https://issues.apache.org/jira/browse/KAFKA-15903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vedarth Sharma resolved KAFKA-15903.
Fix Version/s: 3.7.0
Reviewer: Manikumar
Resolution: Fixed
> Add github ac
[
https://issues.apache.org/jira/browse/KAFKA-15880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vedarth Sharma resolved KAFKA-15880.
Fix Version/s: 3.7.0
Reviewer: Manikumar
Resolution: Fixed
PR merged
> Ad
[
https://issues.apache.org/jira/browse/KAFKA-15879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vedarth Sharma resolved KAFKA-15879.
Fix Version/s: 3.7.0
Reviewer: Manikumar
Resolution: Fixed
Documentation P
laststem closed pull request #14703: MINOR: edit enableCleaner description
URL: https://github.com/apache/kafka/pull/14703
--
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 un
omkreddy merged PR #14938:
URL: https://github.com/apache/kafka/pull/14938
--
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-10404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-10404:
--
Labels: flaky-test (was: )
> Flaky Test kafka.api.SaslSslConsumerTest.testCoordinatorFailover
> -
kirktrue commented on PR #14640:
URL: https://github.com/apache/kafka/pull/14640#issuecomment-1851280653
A [quick search on
Jira](https://issues.apache.org/jira/issues/?jql=project%20%3D%20KAFKA%20AND%20text%20~%20%22testCoordinatorFailover%22)
shows that `testCoordinatorFailover` is a know
[
https://issues.apache.org/jira/browse/KAFKA-7605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-7605:
-
Labels: flaky-test (was: )
> Flaky Test `SaslMultiMechanismConsumerTest.testCoordinatorFailover`
> -
kirktrue commented on PR #14640:
URL: https://github.com/apache/kafka/pull/14640#issuecomment-1851277041
@dajac—I've made the requested changes. Can you take another look?
The latest test run had the usual suspects of flaky tests, plus two that
stood out:
- Build / JDK 17 and S
pprovenzano commented on PR #14984:
URL: https://github.com/apache/kafka/pull/14984#issuecomment-1851271238
Okay, I think I have addresses the issues.
--
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
ashwinpankaj commented on code in PR #14987:
URL: https://github.com/apache/kafka/pull/14987#discussion_r1423381159
##
connect/runtime/src/test/java/org/apache/kafka/connect/integration/BlockingConnectorTest.java:
##
@@ -406,6 +411,7 @@ public Block(String block) {
philipnee commented on code in PR #14873:
URL: https://github.com/apache/kafka/pull/14873#discussion_r1423372314
##
core/src/test/scala/integration/kafka/api/PlaintextConsumerTest.scala:
##
@@ -948,6 +948,7 @@ class PlaintextConsumerTest extends BaseConsumerTest {
// 1 cons
hachikuji commented on code in PR #14774:
URL: https://github.com/apache/kafka/pull/14774#discussion_r1423342213
##
core/src/main/scala/kafka/coordinator/group/GroupMetadataManager.scala:
##
@@ -1378,6 +1350,28 @@ object GroupMetadataManager {
"%X".format(BigInt(1, bytes)
hachikuji commented on code in PR #14774:
URL: https://github.com/apache/kafka/pull/14774#discussion_r1423341054
##
core/src/main/scala/kafka/coordinator/group/GroupMetadataManager.scala:
##
@@ -283,36 +284,7 @@ class GroupMetadataManager(brokerId: Int,
} else {
jolshan commented on code in PR #14774:
URL: https://github.com/apache/kafka/pull/14774#discussion_r1423323788
##
core/src/main/scala/kafka/coordinator/group/GroupCoordinator.scala:
##
@@ -909,8 +911,35 @@ private[group] class GroupCoordinator(
val group = groupManager.
hachikuji commented on code in PR #14774:
URL: https://github.com/apache/kafka/pull/14774#discussion_r1423319991
##
core/src/main/scala/kafka/coordinator/group/GroupCoordinator.scala:
##
@@ -909,8 +911,35 @@ private[group] class GroupCoordinator(
val group = groupManage
jolshan commented on code in PR #14774:
URL: https://github.com/apache/kafka/pull/14774#discussion_r1423314305
##
core/src/main/scala/kafka/coordinator/group/GroupCoordinator.scala:
##
@@ -909,8 +911,35 @@ private[group] class GroupCoordinator(
val group = groupManager.
hachikuji commented on code in PR #14774:
URL: https://github.com/apache/kafka/pull/14774#discussion_r1423310554
##
core/src/main/scala/kafka/server/ReplicaManager.scala:
##
@@ -915,64 +975,239 @@ class ReplicaManager(val config: KafkaConfig,
// probably unblock som
jolshan commented on code in PR #14774:
URL: https://github.com/apache/kafka/pull/14774#discussion_r1423297237
##
core/src/main/scala/kafka/server/ReplicaManager.scala:
##
@@ -915,64 +975,239 @@ class ReplicaManager(val config: KafkaConfig,
// probably unblock some
hachikuji commented on code in PR #14774:
URL: https://github.com/apache/kafka/pull/14774#discussion_r1423297221
##
core/src/main/scala/kafka/server/ReplicaManager.scala:
##
@@ -915,64 +975,239 @@ class ReplicaManager(val config: KafkaConfig,
// probably unblock som
jolshan commented on code in PR #14774:
URL: https://github.com/apache/kafka/pull/14774#discussion_r1423296867
##
core/src/main/scala/kafka/coordinator/group/GroupCoordinator.scala:
##
@@ -909,8 +911,35 @@ private[group] class GroupCoordinator(
val group = groupManager.
hachikuji commented on code in PR #14774:
URL: https://github.com/apache/kafka/pull/14774#discussion_r1423294351
##
core/src/main/scala/kafka/server/ReplicaManager.scala:
##
@@ -915,64 +975,239 @@ class ReplicaManager(val config: KafkaConfig,
// probably unblock som
hachikuji commented on code in PR #14774:
URL: https://github.com/apache/kafka/pull/14774#discussion_r1423293611
##
core/src/main/scala/kafka/server/ReplicaManager.scala:
##
@@ -915,64 +975,239 @@ class ReplicaManager(val config: KafkaConfig,
// probably unblock som
hachikuji commented on code in PR #14774:
URL: https://github.com/apache/kafka/pull/14774#discussion_r1423290758
##
core/src/main/scala/kafka/server/ReplicaManager.scala:
##
@@ -915,64 +975,239 @@ class ReplicaManager(val config: KafkaConfig,
// probably unblock som
hachikuji commented on code in PR #14774:
URL: https://github.com/apache/kafka/pull/14774#discussion_r1423277341
##
core/src/main/scala/kafka/coordinator/group/GroupCoordinator.scala:
##
@@ -909,8 +911,35 @@ private[group] class GroupCoordinator(
val group = groupManage
gharris1727 merged PR #14967:
URL: https://github.com/apache/kafka/pull/14967
--
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.apa
gharris1727 commented on PR #14967:
URL: https://github.com/apache/kafka/pull/14967#issuecomment-1851119930
Test failures appear unrelated, and tests pass locally.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
UR
[
https://issues.apache.org/jira/browse/KAFKA-15981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Kim updated KAFKA-15981:
-
Description:
Currently, we increment generic group metrics whenever we create a new Group
object when w
jeffkbkim opened a new pull request, #14988:
URL: https://github.com/apache/kafka/pull/14988
Currently, we increment generic group metrics whenever we create a new Group
object when we load a partition. This is incorrect as the partition may contain
several records for the same group if in
[
https://issues.apache.org/jira/browse/KAFKA-15981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Kim updated KAFKA-15981:
-
Summary: update Group size only when groups size changes (was: only record
Group state metrics once per
jolshan commented on PR #14599:
URL: https://github.com/apache/kafka/pull/14599#issuecomment-1851104746
At first I was confused since the original PR had
https://github.com/apache/kafka/blob/2a5fbf28820ddcde5ead605e070391059d5d2e18/core/src/test/scala/integration/kafka/api/PlaintextAdminInte
kirktrue commented on code in PR #14640:
URL: https://github.com/apache/kafka/pull/14640#discussion_r1423245926
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java:
##
@@ -177,34 +202,37 @@ public void process(final BackgroundEvent event)
gharris1727 commented on code in PR #14763:
URL: https://github.com/apache/kafka/pull/14763#discussion_r1423238556
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java:
##
@@ -812,6 +812,7 @@ public void stop() {
ThreadUti
[
https://issues.apache.org/jira/browse/KAFKA-15981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Kim updated KAFKA-15981:
-
Summary: only record Group state metrics once per group during load (was:
only record GenericGroup stat
[
https://issues.apache.org/jira/browse/KAFKA-15981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Kim updated KAFKA-15981:
-
Description:
Currently, we increment generic group metrics whenever we create a new
GenericGroup object
C0urante commented on code in PR #14763:
URL: https://github.com/apache/kafka/pull/14763#discussion_r1423214226
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java:
##
@@ -812,6 +812,7 @@ public void stop() {
ThreadUtils.
gharris1727 opened a new pull request, #14987:
URL: https://github.com/apache/kafka/pull/14987
The kafka.utils.TestUtils.verifyNoUnexpectedThreads method used before and
after core tests finds threads leaked by these tests. If these tests run before
core tests, then those tests will all fai
C0urante commented on code in PR #14966:
URL: https://github.com/apache/kafka/pull/14966#discussion_r1423211506
##
connect/runtime/src/test/java/org/apache/kafka/connect/integration/OffsetsApiIntegrationTest.java:
##
@@ -324,127 +363,151 @@ public void
testAlterSinkConnectorOff
mwesterby commented on PR #14942:
URL: https://github.com/apache/kafka/pull/14942#issuecomment-1851003645
Should be fixed now!
--
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
C0urante commented on code in PR #14966:
URL: https://github.com/apache/kafka/pull/14966#discussion_r1423199416
##
connect/runtime/src/test/java/org/apache/kafka/connect/integration/OffsetsApiIntegrationTest.java:
##
@@ -324,127 +363,151 @@ public void
testAlterSinkConnectorOff
C0urante commented on code in PR #14966:
URL: https://github.com/apache/kafka/pull/14966#discussion_r1423199242
##
connect/runtime/src/test/java/org/apache/kafka/connect/integration/OffsetsApiIntegrationTest.java:
##
@@ -70,74 +80,115 @@ public class OffsetsApiIntegrationTest {
rondagostino commented on PR #14984:
URL: https://github.com/apache/kafka/pull/14984#issuecomment-1850991968
@pprovenzano Can you look at the test failures?
`60 tests have failed. There are 0 new tests failing, 60 existing failing`
https://ci-builds.apache.org/blue/organizations/jenkin
rondagostino commented on PR #14942:
URL: https://github.com/apache/kafka/pull/14942#issuecomment-1850990787
@mwesterby Looks like we have a checkstyle issue:
```
Task :server:checkstyleTest
[ant:checkstyle] [ERROR]
/home/jenkins/jenkins-agent/workspace/Kafka_kafka-pr_PR-14942/s
rondagostino commented on PR #14903:
URL: https://github.com/apache/kafka/pull/14903#issuecomment-1850988044
`12 tests have failed. There are 12 new tests failing, 0 existing failing`
I think this PR can be merged now assuming @cmccabe takes a look at the
question above regarding pre
gharris1727 commented on PR #14762:
URL: https://github.com/apache/kafka/pull/14762#issuecomment-1850986158
I found this same leak again when debugging some failures of the
`kafka.utils.TestUtils.verifyNoUnexpectedThreads` assertion in core tests.
Whenever we leak one of these clients in co
gharris1727 commented on PR #14763:
URL: https://github.com/apache/kafka/pull/14763#issuecomment-1850969462
Hi @C0urante I found another very similar problem, where
InternalTopicsIntegrationTest was causing us to leak clients.
There, the "bad topics" cause startServices to throw an ex
[
https://issues.apache.org/jira/browse/KAFKA-15563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton resolved KAFKA-15563.
---
Fix Version/s: 3.7.0
Resolution: Fixed
> Provide informative error messages when Conn
C0urante merged PR #14562:
URL: https://github.com/apache/kafka/pull/14562
--
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
C0urante commented on PR #14562:
URL: https://github.com/apache/kafka/pull/14562#issuecomment-1850942821
All CI failures appear unrelated, merging.
--
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
lianetm commented on code in PR #14557:
URL: https://github.com/apache/kafka/pull/14557#discussion_r1423159520
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/CommitRequestManager.java:
##
@@ -619,11 +838,36 @@ private CompletableFuture> chainFuture(fi
cadonna commented on code in PR #14873:
URL: https://github.com/apache/kafka/pull/14873#discussion_r1423147503
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestManager.java:
##
@@ -201,13 +224,35 @@ public long maximumTimeToWait(long currentTi
soarez commented on code in PR #14942:
URL: https://github.com/apache/kafka/pull/14942#discussion_r1423140834
##
server/src/main/java/org/apache/kafka/server/AssignmentsManager.java:
##
@@ -93,10 +100,24 @@ public AssignmentsManager(Time time,
"broker-" + broker
kirktrue commented on code in PR #14640:
URL: https://github.com/apache/kafka/pull/14640#discussion_r1423135362
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java:
##
@@ -177,34 +202,37 @@ public void process(final BackgroundEvent event)
kirktrue commented on code in PR #14640:
URL: https://github.com/apache/kafka/pull/14640#discussion_r1423134165
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/MembershipManagerImplTest.java:
##
@@ -790,6 +791,297 @@ public void
testOnSubscriptionUpdatedTra
kirktrue commented on code in PR #14640:
URL: https://github.com/apache/kafka/pull/14640#discussion_r1423128358
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerUtils.java:
##
@@ -224,4 +224,21 @@ else if (t instanceof KafkaException)
thr
kirktrue commented on code in PR #14640:
URL: https://github.com/apache/kafka/pull/14640#discussion_r1423127956
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java:
##
@@ -1499,6 +1575,149 @@ private void subscribeInternal(Collection
top
rondagostino commented on PR #14942:
URL: https://github.com/apache/kafka/pull/14942#issuecomment-1850876018
@mwesterby Can you resolve the conflicts here?
--
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
rondagostino commented on PR #14400:
URL: https://github.com/apache/kafka/pull/14400#issuecomment-1850870460
Thanks for describing the testing. I just did a test to see what would
happen if the config file was specified with a relative path, and it did not
work well. For example:
# sta
philipnee commented on code in PR #14873:
URL: https://github.com/apache/kafka/pull/14873#discussion_r1423103409
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestManager.java:
##
@@ -201,13 +224,35 @@ public long maximumTimeToWait(long current
[
https://issues.apache.org/jira/browse/KAFKA-15993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Philip Nee updated KAFKA-15993:
---
Parent: KAFKA-14246
Issue Type: Sub-task (was: Task)
> Enable integration tests that relies
philipnee commented on PR #14873:
URL: https://github.com/apache/kafka/pull/14873#issuecomment-1850852690
Per request: https://issues.apache.org/jira/browse/KAFKA-15993
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use t
dongnuo123 opened a new pull request, #14986:
URL: https://github.com/apache/kafka/pull/14986
*More detailed description of your change,
if necessary. The PR title and PR message become
the squashed commit message, so use a separate
comment to ping reviewers.*
*Summary of test
[
https://issues.apache.org/jira/browse/KAFKA-15993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Philip Nee updated KAFKA-15993:
---
Labels: consumer-threading-refactor kip-848-preview (was: )
> Enable integration tests that relies
[
https://issues.apache.org/jira/browse/KAFKA-15993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Philip Nee updated KAFKA-15993:
---
Component/s: consumer
> Enable integration tests that relies on rebalance listener
> ---
[
https://issues.apache.org/jira/browse/KAFKA-15993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Philip Nee updated KAFKA-15993:
---
Priority: Blocker (was: Major)
> Enable integration tests that relies on rebalance listener
> -
Philip Nee created KAFKA-15993:
--
Summary: Enable integration tests that relies on rebalance listener
Key: KAFKA-15993
URL: https://issues.apache.org/jira/browse/KAFKA-15993
Project: Kafka
Issue
philipnee commented on PR #14873:
URL: https://github.com/apache/kafka/pull/14873#issuecomment-1850844332
Hey @lianetm - You are right. It uses rebalance callback in the test so it
will need to be enabled after implementing the rebalance callback. However, I
did verify the leave group requ
lianetm commented on code in PR #14873:
URL: https://github.com/apache/kafka/pull/14873#discussion_r1423084344
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestManager.java:
##
@@ -201,13 +224,35 @@ public long maximumTimeToWait(long currentTi
kirktrue commented on code in PR #14640:
URL: https://github.com/apache/kafka/pull/14640#discussion_r1423064727
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java:
##
@@ -1499,6 +1575,149 @@ private void subscribeInternal(Collection
top
kirktrue commented on code in PR #14640:
URL: https://github.com/apache/kafka/pull/14640#discussion_r1423062667
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/MembershipManagerImplTest.java:
##
@@ -790,6 +812,197 @@ public void
testOnSubscriptionUpdatedTra
lianetm commented on PR #14873:
URL: https://github.com/apache/kafka/pull/14873#issuecomment-1850787095
@philipnee thanks for the updates! One last comment. Important follow-up to
this PR is to enable the specific max poll related integration tests (like
`testMaxPollIntervalMs`), that are c
lucasbru commented on PR #14944:
URL: https://github.com/apache/kafka/pull/14944#issuecomment-1850757955
@cadonna If you have more comments on #14930, please feel free to merge
this, I will anyways have conflicts with every single CTR/KIP-848 PR.
Instead, if #14930 is good to go, let
dajac commented on code in PR #14985:
URL: https://github.com/apache/kafka/pull/14985#discussion_r1423031514
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/OffsetMetadataManager.java:
##
@@ -892,6 +893,43 @@ public void replay(
}
}
+/**
dajac commented on code in PR #14985:
URL: https://github.com/apache/kafka/pull/14985#discussion_r1423031807
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/runtime/CoordinatorRuntime.java:
##
@@ -881,6 +882,120 @@ public String toString() {
}
dajac commented on code in PR #14985:
URL: https://github.com/apache/kafka/pull/14985#discussion_r1423030686
##
core/src/main/scala/kafka/server/KafkaApis.scala:
##
@@ -2416,14 +2418,49 @@ class KafkaApis(val requestChannel: RequestChannel,
numAppends.decrementAndGet()
dajac commented on code in PR #14985:
URL: https://github.com/apache/kafka/pull/14985#discussion_r1423030220
##
core/src/main/scala/kafka/server/KafkaApis.scala:
##
@@ -2361,25 +2361,27 @@ class KafkaApis(val requestChannel: RequestChannel,
* request, so there could be mu
dajac commented on code in PR #14985:
URL: https://github.com/apache/kafka/pull/14985#discussion_r1423029751
##
core/src/main/scala/kafka/coordinator/group/CoordinatorPartitionWriter.scala:
##
@@ -190,4 +170,56 @@ class CoordinatorPartitionWriter[T](
throw Errors.NOT_LE
dajac commented on code in PR #14985:
URL: https://github.com/apache/kafka/pull/14985#discussion_r1423029434
##
core/src/main/scala/kafka/coordinator/group/CoordinatorLoaderImpl.scala:
##
@@ -135,7 +136,22 @@ class CoordinatorLoaderImpl[T](
memoryRecords.batches.f
dajac opened a new pull request, #14985:
URL: https://github.com/apache/kafka/pull/14985
This patch wires the handling of makers written by the transaction
coordinator via the WriteTxnMarkers API. In the old group coordinator, the
markers are written to the logs and the group coordinator is
lucasbru commented on PR #14873:
URL: https://github.com/apache/kafka/pull/14873#issuecomment-1850740142
@philipnee thanks for the updates.
@cadonna I'll wait for you green light this by approving.
--
This is an automated message from the Apache Git Service.
To respond to the message, p
[
https://issues.apache.org/jira/browse/KAFKA-15574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot resolved KAFKA-15574.
-
Fix Version/s: 3.7.0
Resolution: Fixed
> Update states and transitions for membership man
philipnee commented on PR #14873:
URL: https://github.com/apache/kafka/pull/14873#issuecomment-1850712115
Hi @lianetm and @lucasbru - Per your request, I've just ran the tests using
```
Arguments.of("kraft+kip848", "consumer"))
```
All tests passed except `testRemoteAssig
dajac merged PR #14857:
URL: https://github.com/apache/kafka/pull/14857
--
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
dajac commented on PR #14857:
URL: https://github.com/apache/kafka/pull/14857#issuecomment-1850707387
I looked at all the failed tests and none of them are related to this PR.
The "existing failure" are related to JBDO changes. Merging to trunk.
--
This is an automated message from the Ap
lucasbru commented on code in PR #14930:
URL: https://github.com/apache/kafka/pull/14930#discussion_r1423004412
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java:
##
@@ -1535,6 +1591,11 @@ int callbacks() {
return invoker.callb
lihaosky commented on code in PR #14605:
URL: https://github.com/apache/kafka/pull/14605#discussion_r1422983101
##
streams/test-utils/src/test/java/org/apache/kafka/streams/test/MockFixedKeyProcessorContextTest.java:
##
@@ -0,0 +1,315 @@
+/*
+ * Licensed to the Apache Software F
philipnee commented on PR #14873:
URL: https://github.com/apache/kafka/pull/14873#issuecomment-1850676664
hi @cadonna - Sorry about unintentionally ignoring your question. I've just
responded to it.
--
This is an automated message from the Apache Git Service.
To respond to the message, p
philipnee commented on code in PR #14873:
URL: https://github.com/apache/kafka/pull/14873#discussion_r1422983344
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestManager.java:
##
@@ -201,13 +224,35 @@ public long maximumTimeToWait(long current
lihaosky commented on PR #14426:
URL: https://github.com/apache/kafka/pull/14426#issuecomment-1850672002
@mjsax , @guozhangwang , can we merge this?
--
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 t
cadonna commented on PR #14961:
URL: https://github.com/apache/kafka/pull/14961#issuecomment-1850662683
@alok123t I just read your comment. FYI, I worked on fixing this PR today.
The [resulting PR](https://github.com/apache/kafka/pull/14983) is ready to
merge. I just need an approval.
--
1 - 100 of 178 matches
Mail list logo
