[
https://issues.apache.org/jira/browse/KAFKA-13085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mohamed Aashif updated KAFKA-13085:
---
Description:
This is to confirm the behaviour of
[retention.ms|https://kafka.apache.org/doc
cadonna commented on PR #12801:
URL: https://github.com/apache/kafka/pull/12801#issuecomment-1359004467
Build failures are unrelated:
```
Build / JDK 17 and Scala 2.13 /
kafka.api.PlaintextEndToEndAuthorizationTest.testNoConsumeWithoutDescribeAclViaSubscribe(String).quorum=zk
Build
cadonna merged PR #12801:
URL: https://github.com/apache/kafka/pull/12801
--
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-14343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lucas Brutschy resolved KAFKA-14343.
Resolution: Fixed
> Write upgrade/downgrade tests for enabling the state updater
> --
cadonna commented on code in PR #13014:
URL: https://github.com/apache/kafka/pull/13014#discussion_r1053065865
##
streams/src/test/java/org/apache/kafka/streams/integration/StoreQueryIntegrationTest.java:
##
@@ -650,12 +659,12 @@ private void produceValueRange(final int key, fin
mimaison commented on PR #13005:
URL: https://github.com/apache/kafka/pull/13005#issuecomment-1359157191
Thanks @showuon for the review! I've pushed an update.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL ab
chia7712 commented on code in PR #13024:
URL: https://github.com/apache/kafka/pull/13024#discussion_r1053182775
##
storage/src/main/java/org/apache/kafka/server/log/internals/AbstractIndex.java:
##
@@ -484,27 +478,35 @@ private static MappedByteBuffer
createMappedBuffer(RandomA
showuon commented on PR #12979:
URL: https://github.com/apache/kafka/pull/12979#issuecomment-1359274755
Thanks for the patch. I'll take a look this week.
--
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
[
https://issues.apache.org/jira/browse/KAFKA-14532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot updated KAFKA-14532:
Fix Version/s: 3.4.0
> IllegalStateException when fetch failure happens after assignment changed
>
dajac commented on code in PR #13023:
URL: https://github.com/apache/kafka/pull/13023#discussion_r1053276546
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/FetcherTest.java:
##
@@ -4762,6 +4763,39 @@ public void
testFetchDisconnectedShouldClearPreferredRea
[
https://issues.apache.org/jira/browse/KAFKA-14532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17649734#comment-17649734
]
David Jacot commented on KAFKA-14532:
-
cc [~ableegoldman]
> IllegalStateException w
[
https://issues.apache.org/jira/browse/KAFKA-14532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot updated KAFKA-14532:
Fix Version/s: 3.3.2
> IllegalStateException when fetch failure happens after assignment changed
>
dajac commented on PR #13023:
URL: https://github.com/apache/kafka/pull/13023#issuecomment-1359310514
The bug was introduced in https://github.com/apache/kafka/pull/12956.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and us
divijvaidya commented on PR #13024:
URL: https://github.com/apache/kafka/pull/13024#issuecomment-1359348307
^ please ignore my approval. @chia7712's comments need to be fixed first.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Git
mimaison merged PR #13005:
URL: https://github.com/apache/kafka/pull/13005
--
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
ijuma commented on PR #13010:
URL: https://github.com/apache/kafka/pull/13010#issuecomment-1359466826
Test failures look unrelated. Re-running the tests just in case.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
ijuma commented on PR #13009:
URL: https://github.com/apache/kafka/pull/13009#issuecomment-1359468819
Test failures look unrelated, re-running just in case.
--
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
lucasbru commented on code in PR #13023:
URL: https://github.com/apache/kafka/pull/13023#discussion_r1053392985
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/FetcherTest.java:
##
@@ -4762,6 +4763,39 @@ public void
testFetchDisconnectedShouldClearPreferred
ijuma commented on code in PR #13011:
URL: https://github.com/apache/kafka/pull/13011#discussion_r1053421666
##
server-common/src/main/java/org/apache/kafka/server/record/BrokerCompressionType.java:
##
@@ -0,0 +1,85 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) und
mumrah merged PR #13019:
URL: https://github.com/apache/kafka/pull/13019
--
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.o
[
https://issues.apache.org/jira/browse/KAFKA-7205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17649830#comment-17649830
]
Marten Richert commented on KAFKA-7205:
---
[~kirktrue] For now I do not plan to write
[
https://issues.apache.org/jira/browse/KAFKA-7205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17649830#comment-17649830
]
Marten Richert edited comment on KAFKA-7205 at 12/20/22 3:26 PM:
--
ijuma commented on code in PR #13024:
URL: https://github.com/apache/kafka/pull/13024#discussion_r1053450391
##
storage/src/main/java/org/apache/kafka/server/log/internals/AbstractIndex.java:
##
@@ -484,27 +478,35 @@ private static MappedByteBuffer
createMappedBuffer(RandomAcce
ijuma commented on code in PR #13024:
URL: https://github.com/apache/kafka/pull/13024#discussion_r1053451180
##
storage/src/main/java/org/apache/kafka/server/log/internals/AbstractIndex.java:
##
@@ -484,27 +478,35 @@ private static MappedByteBuffer
createMappedBuffer(RandomAcce
ijuma commented on PR #13024:
URL: https://github.com/apache/kafka/pull/13024#issuecomment-1359582927
@chia7712 Fixed the bug and also tweaked the name of the enum and variable
to avoid confusion with `SearchEntityType`.
--
This is an automated message from the Apache Git Service.
To resp
chia7712 commented on PR #13024:
URL: https://github.com/apache/kafka/pull/13024#issuecomment-1359594391
> Fixed the bug and also tweaked the name of the enum and variable to avoid
confusion with SearchEntityType.
Are there failed tests related to that bug (inverse usage of SearchType
David Jacot created KAFKA-14536:
---
Summary: SessionId in FetchResponse should be ignorable
Key: KAFKA-14536
URL: https://issues.apache.org/jira/browse/KAFKA-14536
Project: Kafka
Issue Type: Bug
ijuma commented on PR #13024:
URL: https://github.com/apache/kafka/pull/13024#issuecomment-1359643024
> Are there failed tests related to that bug (inverse usage of SearchType) ?
Not sure why I don't see the QA triggered by this PR
I was wondering the same thing for both and am invest
ijuma commented on PR #13024:
URL: https://github.com/apache/kafka/pull/13024#issuecomment-1359675311
@chia7712 `OffsetIndexTest` does fail without the fix and pass with the fix.
And the CI build is queued now.
--
This is an automated message from the Apache Git Service.
To respond to the
[
https://issues.apache.org/jira/browse/KAFKA-14536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17649884#comment-17649884
]
Ismael Juma commented on KAFKA-14536:
-
Interesting that we didn't get bug reports ei
lucasbru opened a new pull request, #13025:
URL: https://github.com/apache/kafka/pull/13025
The state updater performed at least one call to `poll` on the restore
consumer before realizing that a newly added task was already
in paused state when being added. To be fully correct, no prog
lucasbru commented on PR #13025:
URL: https://github.com/apache/kafka/pull/13025#issuecomment-1359682705
@cadonna Could you have a look?
--
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 specif
lucasbru opened a new pull request, #13026:
URL: https://github.com/apache/kafka/pull/13026
The call to `interrupt` on the state updater thread during shutdown
could interrupt the thread while writing the checkpoint file. This can
cause a failure to write the checkpoint file and a misle
Matt Allwood created KAFKA-14537:
Summary: Materialized with / as ordering issues
Key: KAFKA-14537
URL: https://issues.apache.org/jira/browse/KAFKA-14537
Project: Kafka
Issue Type: Bug
lucasbru commented on PR #13026:
URL: https://github.com/apache/kafka/pull/13026#issuecomment-1359712729
@cadonna Could you have a look please
--
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
[
https://issues.apache.org/jira/browse/KAFKA-14536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17649893#comment-17649893
]
David Jacot commented on KAFKA-14536:
-
Nevermind, I found the logic which handles th
[
https://issues.apache.org/jira/browse/KAFKA-14536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot resolved KAFKA-14536.
-
Resolution: Not A Problem
> SessionId in FetchResponse should be ignorable
> ---
[
https://issues.apache.org/jira/browse/KAFKA-14537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17649894#comment-17649894
]
Matthias J. Sax commented on KAFKA-14537:
-
What you observe is behavior as desig
[
https://issues.apache.org/jira/browse/KAFKA-14537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-14537.
-
Resolution: Not A Bug
> Materialized with / as ordering issues
> ---
cadonna commented on code in PR #13025:
URL: https://github.com/apache/kafka/pull/13025#discussion_r1053549663
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/DefaultStateUpdater.java:
##
@@ -276,6 +276,11 @@ private void addTask(final Task task) {
cadonna commented on code in PR #13017:
URL: https://github.com/apache/kafka/pull/13017#discussion_r1053559527
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java:
##
@@ -880,9 +885,7 @@ void runOnce() {
private void initializeAndRestoreP
vamossagar12 commented on code in PR #13014:
URL: https://github.com/apache/kafka/pull/13014#discussion_r1053568958
##
streams/src/test/java/org/apache/kafka/streams/integration/StoreQueryIntegrationTest.java:
##
@@ -650,12 +659,12 @@ private void produceValueRange(final int key
vamossagar12 commented on PR #13014:
URL: https://github.com/apache/kafka/pull/13014#issuecomment-1359867743
``
> Thanks for the KIP @vamossagar12 !
>
> I have just one minor comment!
Thanks @cadonna . I made the requested change.
--
This is an automated message from t
cadonna commented on code in PR #13014:
URL: https://github.com/apache/kafka/pull/13014#discussion_r1053578553
##
streams/src/test/java/org/apache/kafka/streams/integration/StoreQueryIntegrationTest.java:
##
@@ -650,12 +659,11 @@ private void produceValueRange(final int key, fin
junrao commented on code in PR #13009:
URL: https://github.com/apache/kafka/pull/13009#discussion_r1053582340
##
core/src/test/scala/unit/kafka/log/remote/RemoteLogManagerTest.scala:
##
@@ -273,4 +274,4 @@ class RemoteLogManagerTest {
new RemoteLogManagerConfig(config)
}
ijuma commented on code in PR #13009:
URL: https://github.com/apache/kafka/pull/13009#discussion_r1053590225
##
core/src/test/scala/unit/kafka/log/remote/RemoteLogManagerTest.scala:
##
@@ -273,4 +274,4 @@ class RemoteLogManagerTest {
new RemoteLogManagerConfig(config)
}
ijuma commented on code in PR #13009:
URL: https://github.com/apache/kafka/pull/13009#discussion_r1053590225
##
core/src/test/scala/unit/kafka/log/remote/RemoteLogManagerTest.scala:
##
@@ -273,4 +274,4 @@ class RemoteLogManagerTest {
new RemoteLogManagerConfig(config)
}
junrao commented on code in PR #13009:
URL: https://github.com/apache/kafka/pull/13009#discussion_r1053591043
##
core/src/test/scala/unit/kafka/log/remote/RemoteLogManagerTest.scala:
##
@@ -273,4 +274,4 @@ class RemoteLogManagerTest {
new RemoteLogManagerConfig(config)
}
[
https://issues.apache.org/jira/browse/KAFKA-14534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Harris reassigned KAFKA-14534:
---
Assignee: Greg Harris
> Flaky Test TransactionsExpirationTest.testTransactionAfterProducerI
ijuma commented on code in PR #13009:
URL: https://github.com/apache/kafka/pull/13009#discussion_r1053590225
##
core/src/test/scala/unit/kafka/log/remote/RemoteLogManagerTest.scala:
##
@@ -273,4 +274,4 @@ class RemoteLogManagerTest {
new RemoteLogManagerConfig(config)
}
ijuma commented on code in PR #13009:
URL: https://github.com/apache/kafka/pull/13009#discussion_r1053590225
##
core/src/test/scala/unit/kafka/log/remote/RemoteLogManagerTest.scala:
##
@@ -273,4 +274,4 @@ class RemoteLogManagerTest {
new RemoteLogManagerConfig(config)
}
Colin McCabe created KAFKA-14538:
Summary: Implement metadata transactions at arbitrary locations in
the log
Key: KAFKA-14538
URL: https://issues.apache.org/jira/browse/KAFKA-14538
Project: Kafka
jsancio commented on code in PR #13019:
URL: https://github.com/apache/kafka/pull/13019#discussion_r1053638059
##
core/src/test/scala/integration/kafka/server/KRaftClusterTest.scala:
##
@@ -917,4 +919,34 @@ class KRaftClusterTest {
cluster.close()
}
}
+
+ @Test
+
jsancio merged PR #12994:
URL: https://github.com/apache/kafka/pull/12994
--
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-14457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
José Armando García Sancio resolved KAFKA-14457.
Resolution: Fixed
> Inconsistent in quorum controller fenced broke
philipnee commented on code in PR #13021:
URL: https://github.com/apache/kafka/pull/13021#discussion_r1053661970
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/DefaultBackgroundThread.java:
##
@@ -111,21 +120,36 @@ public DefaultBackgroundThread(final Time
mumrah opened a new pull request, #13027:
URL: https://github.com/apache/kafka/pull/13027
Rather than a boolean `isMigratingZkBroker`, this patch includes the broker
epoch. The broker epoch, as it exists in ZK, is needed to construct valid
UpdateMetadataRequests.
The logic for determ
ijuma commented on PR #13009:
URL: https://github.com/apache/kafka/pull/13009#issuecomment-1360070072
Failures are unrelated.
--
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.
ijuma merged PR #13009:
URL: https://github.com/apache/kafka/pull/13009
--
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
ijuma commented on PR #13011:
URL: https://github.com/apache/kafka/pull/13011#issuecomment-1360076891
JDK 8 build passed, the other failures are unrelated.
@dengziming I will go ahead and merge since you approved, but please do let
me know if you have additional comments with regards
ijuma merged PR #13011:
URL: https://github.com/apache/kafka/pull/13011
--
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
akhileshchg commented on code in PR #13027:
URL: https://github.com/apache/kafka/pull/13027#discussion_r1053715359
##
core/src/main/scala/kafka/server/KafkaServer.scala:
##
@@ -359,6 +354,11 @@ class KafkaServer(
val brokerInfo = createBrokerInfo
val brokerEpoc
[
https://issues.apache.org/jira/browse/KAFKA-14531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Arthur resolved KAFKA-14531.
--
Resolution: Fixed
> KRaft controller time-based snapshots are too frequent
> -
akhileshchg opened a new pull request, #13028:
URL: https://github.com/apache/kafka/pull/13028
…te with ZkBrokers during migration
Introduced two new classes, KRaftControllerBrokerRequestBatch and
KRaftControllerToZkBrokersRpcClient, that use
AbstractControllerBrokerRequestBatch an
akhileshchg opened a new pull request, #13029:
URL: https://github.com/apache/kafka/pull/13029
This field will be used by the KRaft controller to see if the quorum is
ready to handle zk -> kraft migration.
--
This is an automated message from the Apache Git Service.
To respond to the
jolshan commented on code in PR #12870:
URL: https://github.com/apache/kafka/pull/12870#discussion_r1053796764
##
core/src/test/scala/unit/kafka/server/OffsetFetchRequestTest.scala:
##
@@ -150,42 +149,6 @@ class OffsetFetchRequestTest extends BaseRequestTest {
}
}
- @
jolshan commented on code in PR #12870:
URL: https://github.com/apache/kafka/pull/12870#discussion_r1053796897
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinator.java:
##
@@ -52,6 +54,7 @@ CompletableFuture joinGroup(
);
/**
+<
jolshan commented on PR #12870:
URL: https://github.com/apache/kafka/pull/12870#issuecomment-1360390779
Was looking for the tests and then remembered this comment:
https://github.com/apache/kafka/pull/12870#issuecomment-1318954178
Reminder on this 😄
--
This is an automated messa
junrao commented on code in PR #13010:
URL: https://github.com/apache/kafka/pull/13010#discussion_r1053827554
##
storage/src/main/java/org/apache/kafka/server/log/internals/TimeIndex.java:
##
@@ -0,0 +1,290 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or
[
https://issues.apache.org/jira/browse/KAFKA-14538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin McCabe updated KAFKA-14538:
-
Description: Implement KRaft metadata transactions (was: Implement
metadata transactions at arb
[
https://issues.apache.org/jira/browse/KAFKA-14538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin McCabe updated KAFKA-14538:
-
Summary: Implement KRaft metadata transactions (was: Implement metadata
transactions at arbitra
mumrah commented on code in PR #13028:
URL: https://github.com/apache/kafka/pull/13028#discussion_r1053840330
##
core/src/main/scala/kafka/controller/ControllerChannelManager.scala:
##
@@ -313,35 +313,76 @@ class RequestSendThread(val controllerId: Int,
}
}
-class Controll
ijuma commented on code in PR #13010:
URL: https://github.com/apache/kafka/pull/13010#discussion_r1053853496
##
storage/src/main/java/org/apache/kafka/server/log/internals/TimeIndex.java:
##
@@ -0,0 +1,290 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or
jolshan commented on code in PR #12886:
URL: https://github.com/apache/kafka/pull/12886#discussion_r1053854859
##
core/src/main/scala/kafka/server/KafkaApis.scala:
##
@@ -407,136 +416,200 @@ class KafkaApis(val requestChannel: RequestChannel,
* Handle an offset commit reques
jolshan commented on PR #12886:
URL: https://github.com/apache/kafka/pull/12886#issuecomment-1360502862
Looks like this needs a rebase. I will take another pass when that is
complete.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
jsancio opened a new pull request, #13030:
URL: https://github.com/apache/kafka/pull/13030
When KRaft updates the log layer's high-watermark it is possible for the log
layer to record a different high watermark. KRaft should log a warn message
when this happens.
### Committer Checkli
philipnee commented on code in PR #13023:
URL: https://github.com/apache/kafka/pull/13023#discussion_r1053900444
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/SubscriptionState.java:
##
@@ -620,7 +620,12 @@ public synchronized Optional
preferredReadReplic
ijuma commented on PR #13024:
URL: https://github.com/apache/kafka/pull/13024#issuecomment-1360792320
Test failures are unrelated:
> Build / JDK 11 and Scala 2.13 /
org.apache.kafka.connect.mirror.integration.MirrorConnectorsWithCustomForwardingAdminIntegrationTest.testReplicationIsCr
showuon commented on PR #13016:
URL: https://github.com/apache/kafka/pull/13016#issuecomment-1360793825
> Actually, do we support running kraft with just 2 members in the
controller quorum?
Yes, I don't see why we can't support that. The quorum of 2 members will be
2. It just doesn't
ijuma commented on PR #13010:
URL: https://github.com/apache/kafka/pull/13010#issuecomment-1360794255
JDK 8 and JDK 17 builds passed, JDK 11 failures are unrelated:
> Build / JDK 11 and Scala 2.13 /
kafka.api.TransactionsTest.testBumpTransactionalEpoch(String).quorum=kraft 1
min 18 s
ijuma merged PR #13010:
URL: https://github.com/apache/kafka/pull/13010
--
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
ijuma commented on PR #13016:
URL: https://github.com/apache/kafka/pull/13016#issuecomment-1360800889
I guess you're saying we don't care about the ability to tolerate failures
in this particular test. Fair enough.
--
This is an automated message from the Apache Git Service.
To respond to
showuon commented on PR #13016:
URL: https://github.com/apache/kafka/pull/13016#issuecomment-1360802090
> I guess you're saying we don't care about the ability to tolerate failures
in this particular test. Fair enough.
Yes, you're right. Thanks for the comment.
--
This is an automa
ijuma commented on code in PR #13030:
URL: https://github.com/apache/kafka/pull/13030#discussion_r1053941502
##
core/src/main/scala/kafka/raft/KafkaMetadataLog.scala:
##
@@ -187,17 +187,25 @@ final class KafkaMetadataLog private (
}
override def updateHighWatermark(offse
showuon commented on PR #13016:
URL: https://github.com/apache/kafka/pull/13016#issuecomment-1360802421
Failed tests are unrelated
```
Build / JDK 8 and Scala 2.12 /
kafka.network.SocketServerTest.idleExpiryWithBufferedReceives()
Build / JDK 17 and Scala 2.13 /
kafka.server
showuon merged PR #13016:
URL: https://github.com/apache/kafka/pull/13016
--
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-14498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen updated KAFKA-14498:
--
Fix Version/s: 3.5.0
> flaky org.apache.kafka.tools.MetadataQuorumCommandTest
> --
showuon commented on PR #13016:
URL: https://github.com/apache/kafka/pull/13016#issuecomment-1360804418
@ableegoldman , this is to help make some tests reliable by decreasing the
testing nodes (low risk). Do you think this should backport to 3.4?
--
This is an automated message from the
showuon opened a new pull request, #13031:
URL: https://github.com/apache/kafka/pull/13031
Saw this flaky test in recent builds:
[#1452](https://ci-builds.apache.org/job/Kafka/job/kafka/job/trunk/1452/testReport/junit/org.apache.kafka.common.network/SslTransportLayerTest/Build___JDK_17_and_S
showuon commented on PR #13031:
URL: https://github.com/apache/kafka/pull/13031#issuecomment-1360821011
@rajinisivaram , please take a look. Thanks.
--
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
ijuma commented on PR #13012:
URL: https://github.com/apache/kafka/pull/13012#issuecomment-1360836868
cc @satishd
--
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 unsubs
A. Sophie Blee-Goldman created KAFKA-14539:
--
Summary: Simplify StreamsMetadataState by replacing the Cluster
metadata with partition info map
Key: KAFKA-14539
URL: https://issues.apache.org/jira/browse/KA
Michael Marshall created KAFKA-14540:
Summary: DataOutputStreamWritable#writeByteBuffer writes the wrong
portion of the parameterized buffer
Key: KAFKA-14540
URL: https://issues.apache.org/jira/browse/KAFKA-14
michaeljmarshall opened a new pull request, #13032:
URL: https://github.com/apache/kafka/pull/13032
When writing a `ByteBuffer` backed by a `HeapBuffer` to a
`DataOutputStream`, it is necessary to pass in the offset, not the position.
The current code results in writing the wrong data to `D
showuon commented on code in PR #13032:
URL: https://github.com/apache/kafka/pull/13032#discussion_r1054067080
##
clients/src/main/java/org/apache/kafka/common/protocol/DataOutputStreamWritable.java:
##
@@ -99,7 +99,7 @@ public void writeUnsignedVarint(int i) {
public void
cadonna commented on PR #13026:
URL: https://github.com/apache/kafka/pull/13026#issuecomment-1360964756
Build failures are unrelated:
```
Build / JDK 11 and Scala 2.13 /
kafka.api.SslEndToEndAuthorizationTest.testNoConsumeWithoutDescribeAclViaSubscribe(String).quorum=kraft
Build / J
cadonna merged PR #13026:
URL: https://github.com/apache/kafka/pull/13026
--
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.
97 matches
Mail list logo
