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.
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
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
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
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
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
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
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
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 #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
[
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 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.
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
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-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 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
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 #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
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 #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
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
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
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
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
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
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
[
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
[
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
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
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
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 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 {
}
}
- @
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
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
[
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 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
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
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 #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 #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.
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
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
[
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
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.
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
+
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
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)
}
[
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
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)
}
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_r1053582340
##
core/src/test/scala/unit/kafka/log/remote/RemoteLogManagerTest.scala:
##
@@ -273,4 +274,4 @@ class RemoteLogManagerTest {
new RemoteLogManagerConfig(config)
}
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
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
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
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
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) {
[
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
> ---
[
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-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
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
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 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
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, #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
[
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
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
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
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
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
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
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 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
[
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:
--
[
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
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
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
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 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
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
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
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
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
[
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
>
[
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
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:all-tabpanel
]
David Jacot updated KAFKA-14532:
Fix Version/s: 3.4.0
> IllegalStateException when fetch failure happens after assignment changed
>
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
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
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
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
[
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 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.
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
[
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
97 matches
Mail list logo
