jeffkbkim commented on code in PR #12845:
URL: https://github.com/apache/kafka/pull/12845#discussion_r1027051707
##
core/src/main/scala/kafka/server/KafkaApis.scala:
##
@@ -1647,69 +1656,51 @@ class KafkaApis(val requestChannel: RequestChannel,
}
}
- def handleJoinGro
ableegoldman commented on PR #12869:
URL: https://github.com/apache/kafka/pull/12869#issuecomment-1320825312
Cherrypicked all the way back to 3.0...whew!
Had to resolve a few minor merge conflicts along the way but it was
generally smooth (I did make a small mistake on the 3.3 resolut
[
https://issues.apache.org/jira/browse/KAFKA-14382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman updated KAFKA-14382:
---
Fix Version/s: 3.1.3
3.0.3
> StreamThreads can miss rebal
dajac commented on code in PR #12845:
URL: https://github.com/apache/kafka/pull/12845#discussion_r1027049468
##
core/src/main/scala/kafka/server/KafkaServer.scala:
##
@@ -21,11 +21,10 @@ import java.io.{File, IOException}
import java.net.{InetAddress, SocketTimeoutException}
i
dajac commented on code in PR #12845:
URL: https://github.com/apache/kafka/pull/12845#discussion_r1027049342
##
core/src/main/scala/kafka/server/KafkaApis.scala:
##
@@ -1647,69 +1656,51 @@ class KafkaApis(val requestChannel: RequestChannel,
}
}
- def handleJoinGroupRe
dajac commented on code in PR #12845:
URL: https://github.com/apache/kafka/pull/12845#discussion_r1027049080
##
core/src/main/scala/kafka/server/KafkaApis.scala:
##
@@ -1647,69 +1656,51 @@ class KafkaApis(val requestChannel: RequestChannel,
}
}
- def handleJoinGroupRe
[
https://issues.apache.org/jira/browse/KAFKA-14362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17636116#comment-17636116
]
A. Sophie Blee-Goldman commented on KAFKA-14362:
Well I mean, regardless
[
https://issues.apache.org/jira/browse/KAFKA-14382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman updated KAFKA-14382:
---
Fix Version/s: 3.3.2
3.2.4
> StreamThreads can miss rebal
[
https://issues.apache.org/jira/browse/KAFKA-14382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman updated KAFKA-14382:
---
Labels: rebalancing (was: )
> StreamThreads can miss rebalance events when
ableegoldman merged PR #12869:
URL: https://github.com/apache/kafka/pull/12869
--
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.ap
ableegoldman commented on PR #12869:
URL: https://github.com/apache/kafka/pull/12869#issuecomment-1320817093
Test failures are all unrelated -- merging this 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 a
jeffkbkim commented on code in PR #12845:
URL: https://github.com/apache/kafka/pull/12845#discussion_r1027036420
##
core/src/main/scala/kafka/server/KafkaApis.scala:
##
@@ -1647,69 +1656,51 @@ class KafkaApis(val requestChannel: RequestChannel,
}
}
- def handleJoinGro
ableegoldman merged PR #12842:
URL: https://github.com/apache/kafka/pull/12842
--
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.ap
ableegoldman commented on PR #12842:
URL: https://github.com/apache/kafka/pull/12842#issuecomment-1320799136
test failures are unrelated, merging to trunk
--
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 t
jsancio commented on code in PR #12761:
URL: https://github.com/apache/kafka/pull/12761#discussion_r1027026027
##
metadata/src/main/java/org/apache/kafka/controller/QuorumController.java:
##
@@ -1455,30 +1523,56 @@ private void replay(ApiMessage message,
Optional snapshotId, lo
jsancio commented on code in PR #12761:
URL: https://github.com/apache/kafka/pull/12761#discussion_r1027024757
##
metadata/src/main/java/org/apache/kafka/controller/QuorumController.java:
##
@@ -1376,6 +1413,37 @@ private void cancelNextWriteNoOpRecord() {
queue.cancelD
jsancio commented on code in PR #12761:
URL: https://github.com/apache/kafka/pull/12761#discussion_r1027024702
##
core/src/main/scala/kafka/server/KafkaConfig.scala:
##
@@ -725,7 +727,14 @@ object KafkaConfig {
"This is required configuration when running in KRaft mode."
jsancio commented on code in PR #12761:
URL: https://github.com/apache/kafka/pull/12761#discussion_r1027024629
##
raft/src/main/java/org/apache/kafka/raft/RaftClient.java:
##
@@ -229,4 +229,15 @@ default void beginShutdown() {}
* or less than the log start offset.
jsancio commented on code in PR #12761:
URL: https://github.com/apache/kafka/pull/12761#discussion_r1027024376
##
metadata/src/main/java/org/apache/kafka/controller/QuorumController.java:
##
@@ -986,6 +1012,13 @@ public void
handleCommit(BatchReader reader) {
jsancio commented on code in PR #12761:
URL: https://github.com/apache/kafka/pull/12761#discussion_r1027022584
##
metadata/src/main/java/org/apache/kafka/controller/QuorumController.java:
##
@@ -568,45 +576,62 @@ void cancel() {
}
void reschedule(long delayNs
Jeff Kim created KAFKA-14407:
Summary: Able to access offset index memory map even after memory
map flag is turned off
Key: KAFKA-14407
URL: https://issues.apache.org/jira/browse/KAFKA-14407
Project: Kafk
jeffkbkim opened a new pull request, #12877:
URL: https://github.com/apache/kafka/pull/12877
The default replica selector chooses a replica on whether the broker.rack
matches the client.rack in the fetch request and whether the offset exists in
the follower. If the follower is not in the IS
jsancio commented on code in PR #12761:
URL: https://github.com/apache/kafka/pull/12761#discussion_r1027019732
##
metadata/src/main/java/org/apache/kafka/controller/QuorumController.java:
##
@@ -568,45 +576,62 @@ void cancel() {
}
void reschedule(long delayNs
ableegoldman commented on code in PR #12859:
URL: https://github.com/apache/kafka/pull/12859#discussion_r1027007714
##
streams/src/test/resources/log4j.properties:
##
@@ -27,7 +27,7 @@ log4j.logger.org.apache.kafka.clients=ERROR
# These are the only logs we will likely ever fin
ableegoldman commented on code in PR #12859:
URL: https://github.com/apache/kafka/pull/12859#discussion_r1027007076
##
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/ProcessorParameters.java:
##
@@ -130,7 +129,8 @@ public String processorName() {
@Ov
ableegoldman commented on code in PR #12859:
URL: https://github.com/apache/kafka/pull/12859#discussion_r1027007003
##
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/ProcessorParameters.java:
##
@@ -114,13 +114,12 @@ KTableSource kTableSourceSupplier() {
[
https://issues.apache.org/jira/browse/KAFKA-14325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman reassigned KAFKA-14325:
--
Assignee: Jorge Esteban Quilcate Otoya (was: A. Sophie Blee-Goldman)
[
https://issues.apache.org/jira/browse/KAFKA-14406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman resolved KAFKA-14406.
Resolution: Fixed
> Double iteration of records in batches to be restored
A. Sophie Blee-Goldman created KAFKA-14406:
--
Summary: Double iteration of records in batches to be restored
Key: KAFKA-14406
URL: https://issues.apache.org/jira/browse/KAFKA-14406
Project: Kaf
A. Sophie Blee-Goldman created KAFKA-14405:
--
Summary: Log a warning when users attempt to set a config
controlled by Streams
Key: KAFKA-14405
URL: https://issues.apache.org/jira/browse/KAFKA-14405
[
https://issues.apache.org/jira/browse/KAFKA-14404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman updated KAFKA-14404:
---
Summary: Fix & update docs on client configs controlled by Streams (was:
Im
A. Sophie Blee-Goldman created KAFKA-14404:
--
Summary: Improve dWarn that the ProducerConfig partitioner.class
cannot be used in Streams
Key: KAFKA-14404
URL: https://issues.apache.org/jira/browse/KAFKA-14
niket-goel commented on code in PR #12761:
URL: https://github.com/apache/kafka/pull/12761#discussion_r1027000889
##
metadata/src/main/java/org/apache/kafka/controller/QuorumController.java:
##
@@ -568,45 +576,62 @@ void cancel() {
}
void reschedule(long dela
niket-goel commented on code in PR #12761:
URL: https://github.com/apache/kafka/pull/12761#discussion_r1027000889
##
metadata/src/main/java/org/apache/kafka/controller/QuorumController.java:
##
@@ -568,45 +576,62 @@ void cancel() {
}
void reschedule(long dela
niket-goel commented on code in PR #12761:
URL: https://github.com/apache/kafka/pull/12761#discussion_r1026985550
##
core/src/main/scala/kafka/server/KafkaConfig.scala:
##
@@ -725,7 +727,14 @@ object KafkaConfig {
"This is required configuration when running in KRaft mode."
hachikuji commented on code in PR #12761:
URL: https://github.com/apache/kafka/pull/12761#discussion_r1026995028
##
metadata/src/main/java/org/apache/kafka/controller/QuorumController.java:
##
@@ -568,45 +576,62 @@ void cancel() {
}
void reschedule(long delay
gharris1727 opened a new pull request, #12876:
URL: https://github.com/apache/kafka/pull/12876
The current method of computing the member poll duration does not take into
account the time spent on connector operations in tick(), which may be
significant. This can cause a worker to sleep for
[
https://issues.apache.org/jira/browse/KAFKA-12476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Harris reassigned KAFKA-12476:
---
Assignee: Greg Harris
> Worker can block for longer than scheduled rebalance delay and/or s
jsancio commented on code in PR #12761:
URL: https://github.com/apache/kafka/pull/12761#discussion_r1026974492
##
metadata/src/main/java/org/apache/kafka/controller/QuorumController.java:
##
@@ -1455,30 +1523,56 @@ private void replay(ApiMessage message,
Optional snapshotId, lo
jsancio commented on code in PR #12761:
URL: https://github.com/apache/kafka/pull/12761#discussion_r1026974404
##
core/src/main/scala/kafka/server/KafkaConfig.scala:
##
@@ -725,7 +727,12 @@ object KafkaConfig {
"This is required configuration when running in KRaft mode."
jsancio commented on code in PR #12761:
URL: https://github.com/apache/kafka/pull/12761#discussion_r1026965577
##
metadata/src/main/java/org/apache/kafka/controller/QuorumController.java:
##
@@ -986,6 +1012,13 @@ public void
handleCommit(BatchReader reader) {
jsancio commented on code in PR #12761:
URL: https://github.com/apache/kafka/pull/12761#discussion_r1026965577
##
metadata/src/main/java/org/apache/kafka/controller/QuorumController.java:
##
@@ -986,6 +1012,13 @@ public void
handleCommit(BatchReader reader) {
jsancio commented on code in PR #12761:
URL: https://github.com/apache/kafka/pull/12761#discussion_r1026963407
##
metadata/src/main/java/org/apache/kafka/controller/QuorumController.java:
##
@@ -568,45 +576,62 @@ void cancel() {
}
void reschedule(long delayNs
José Armando García Sancio created KAFKA-14403:
--
Summary: Snapshot failure metrics
Key: KAFKA-14403
URL: https://issues.apache.org/jira/browse/KAFKA-14403
Project: Kafka
Issue Ty
jsancio commented on code in PR #12761:
URL: https://github.com/apache/kafka/pull/12761#discussion_r1026957838
##
metadata/src/main/java/org/apache/kafka/controller/QuorumController.java:
##
@@ -568,45 +576,62 @@ void cancel() {
}
void reschedule(long delayNs
jsancio commented on code in PR #12761:
URL: https://github.com/apache/kafka/pull/12761#discussion_r1026950932
##
core/src/main/scala/kafka/server/KafkaConfig.scala:
##
@@ -1157,6 +1164,7 @@ object KafkaConfig {
* KRaft mode configs.
*/
.define(MetadataSna
wcarlson5 commented on PR #12842:
URL: https://github.com/apache/kafka/pull/12842#issuecomment-1320560081
I think this might need a ticket. If you don't mind creating one. It would
be good to track this to see when we get the fix in and what branches it's on
--
This is an automated messag
[
https://issues.apache.org/jira/browse/KAFKA-14372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Kim updated KAFKA-14372:
-
Description:
The default replica selector chooses a replica on whether the broker.rack
matches the clie
jolshan commented on PR #12392:
URL: https://github.com/apache/kafka/pull/12392#issuecomment-1320546110
@urbandan By the way, KIP-890 is now available to review 😄
https://cwiki.apache.org/confluence/display/KAFKA/KIP-890%3A+Transactions+Server-Side+Defense
--
This is an automated mess
jolshan commented on code in PR #12845:
URL: https://github.com/apache/kafka/pull/12845#discussion_r1026894950
##
core/src/main/scala/kafka/server/KafkaApis.scala:
##
@@ -1647,69 +1656,51 @@ class KafkaApis(val requestChannel: RequestChannel,
}
}
- def handleJoinGroup
Justine Olshan created KAFKA-14402:
--
Summary: Transactions Server Side Defense
Key: KAFKA-14402
URL: https://issues.apache.org/jira/browse/KAFKA-14402
Project: Kafka
Issue Type: Task
dajac commented on code in PR #12845:
URL: https://github.com/apache/kafka/pull/12845#discussion_r1026881513
##
core/src/main/scala/kafka/server/KafkaApis.scala:
##
@@ -1647,69 +1656,51 @@ class KafkaApis(val requestChannel: RequestChannel,
}
}
- def handleJoinGroupRe
hachikuji commented on code in PR #12761:
URL: https://github.com/apache/kafka/pull/12761#discussion_r1026780591
##
core/src/main/scala/kafka/server/KafkaConfig.scala:
##
@@ -725,7 +727,12 @@ object KafkaConfig {
"This is required configuration when running in KRaft mode."
jolshan commented on code in PR #12848:
URL: https://github.com/apache/kafka/pull/12848#discussion_r1026784250
##
core/src/test/scala/unit/kafka/server/KafkaApisTest.scala:
##
@@ -2806,6 +2806,100 @@ class KafkaApisTest {
}
}
+ @ParameterizedTest
Review Comment:
W
jolshan commented on code in PR #12845:
URL: https://github.com/apache/kafka/pull/12845#discussion_r1026780137
##
core/src/main/scala/kafka/server/KafkaApis.scala:
##
@@ -1647,69 +1656,51 @@ class KafkaApis(val requestChannel: RequestChannel,
}
}
- def handleJoinGroup
[
https://issues.apache.org/jira/browse/KAFKA-14320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Manikumar resolved KAFKA-14320.
---
Resolution: Fixed
> Upgrade Jackson for CVE fix
> ---
>
> Ke
C0urante commented on PR #12784:
URL: https://github.com/apache/kafka/pull/12784#issuecomment-1320363284
@sudeshwasnik are you still working on 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
omkreddy closed pull request #12766: KAFKA-14320: Upgrade Jackson for CVE Fix
URL: https://github.com/apache/kafka/pull/12766
--
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
omkreddy commented on PR #12766:
URL: https://github.com/apache/kafka/pull/12766#issuecomment-1320352617
closing as duplicate https://github.com/apache/kafka/pull/12840
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use t
omkreddy merged PR #12840:
URL: https://github.com/apache/kafka/pull/12840
--
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
jolshan commented on code in PR #12847:
URL: https://github.com/apache/kafka/pull/12847#discussion_r1024400644
##
core/src/test/scala/unit/kafka/coordinator/group/GroupCoordinatorAdapterTest.scala:
##
@@ -135,4 +133,71 @@ class GroupCoordinatorAdapterTest {
assertEquals(exp
jolshan commented on code in PR #12845:
URL: https://github.com/apache/kafka/pull/12845#discussion_r1026687239
##
core/src/test/scala/unit/kafka/coordinator/group/GroupCoordinatorAdapterTest.scala:
##
@@ -0,0 +1,138 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) un
jolshan commented on code in PR #12845:
URL: https://github.com/apache/kafka/pull/12845#discussion_r1026684714
##
core/src/main/scala/kafka/server/KafkaServer.scala:
##
@@ -21,11 +21,10 @@ import java.io.{File, IOException}
import java.net.{InetAddress, SocketTimeoutException}
jolshan commented on code in PR #12845:
URL: https://github.com/apache/kafka/pull/12845#discussion_r1026680653
##
core/src/main/scala/kafka/server/KafkaApis.scala:
##
@@ -1647,69 +1656,51 @@ class KafkaApis(val requestChannel: RequestChannel,
}
}
- def handleJoinGroup
[
https://issues.apache.org/jira/browse/KAFKA-14401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao updated KAFKA-14401:
--
Description:
When a connector or task tries to read the offsets from the offsets topic, it
issues `Of
Sagar Rao created KAFKA-14401:
-
Summary: Connector/Tasks reading offsets can get stuck if
underneath WorkThread dies
Key: KAFKA-14401
URL: https://issues.apache.org/jira/browse/KAFKA-14401
Project: Kafka
C0urante commented on PR #12863:
URL: https://github.com/apache/kafka/pull/12863#issuecomment-1320238030
@NLincoln It looks like this issue was already assigned to @jsancio on Jira;
it's best to find tickets that either have not yet been assigned, or have not
been worked on in a while.
[
https://issues.apache.org/jira/browse/KAFKA-14362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17635921#comment-17635921
]
Mikael commented on KAFKA-14362:
No, no errors or warnings related to rebalancing. I'm c
C0urante commented on PR #12295:
URL: https://github.com/apache/kafka/pull/12295#issuecomment-1320186592
Backported to 3.3 (with the new test disabled) in
https://github.com/apache/kafka/commit/80e4f42bb3c8f6843b8e3aa2823e38b1a6269a38
--
This is an automated message from the Apache Git Se
[
https://issues.apache.org/jira/browse/KAFKA-13586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton updated KAFKA-13586:
--
Fix Version/s: 3.3.2
> ConfigExceptions thrown by FileConfigProvider during connector/task sta
ijuma commented on code in PR #12783:
URL: https://github.com/apache/kafka/pull/12783#discussion_r1026569181
##
core/src/test/scala/unit/kafka/utils/TestUtils.scala:
##
@@ -214,14 +214,14 @@ object TestUtils extends Logging {
enableToken: Boolean = false,
numPartitions
ijuma commented on code in PR #12783:
URL: https://github.com/apache/kafka/pull/12783#discussion_r1026569181
##
core/src/test/scala/unit/kafka/utils/TestUtils.scala:
##
@@ -214,14 +214,14 @@ object TestUtils extends Logging {
enableToken: Boolean = false,
numPartitions
lucasbru commented on PR #12875:
URL: https://github.com/apache/kafka/pull/12875#issuecomment-1320135097
@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, #12875:
URL: https://github.com/apache/kafka/pull/12875
In this change, we enable backing off when the state directory
is still locked during initialization of a task. For this, we
introduce a new queue inside the state updater, that keeps all
task
dstelljes commented on PR #12295:
URL: https://github.com/apache/kafka/pull/12295#issuecomment-1320112618
Thanks @C0urante!
--
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-13586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton resolved KAFKA-13586.
---
Resolution: Fixed
> ConfigExceptions thrown by FileConfigProvider during connector/task star
C0urante merged PR #12295:
URL: https://github.com/apache/kafka/pull/12295
--
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-13586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton updated KAFKA-13586:
--
Fix Version/s: 3.4.0
> ConfigExceptions thrown by FileConfigProvider during connector/task sta
lucasbru commented on PR #12801:
URL: https://github.com/apache/kafka/pull/12801#issuecomment-1320051193
CI test failures are unrelated.
Passing system test run 10x for the new upgrade / downgrade test:
https://jenkins.confluent.io/job/system-test-kafka-branch-builder/5206/
jeqo commented on PR #12859:
URL: https://github.com/apache/kafka/pull/12859#issuecomment-131111
cc @ableegoldman @bbejeck @vvcephei
--
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-14400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Victor van den Hoven updated KAFKA-14400:
-
Description:
In Kafka-streams 3.1.1 :
When using +JoinWindows.ofTimeDifferenceW
Victor van den Hoven created KAFKA-14400:
Summary: KStream - KStream - LeftJoin() does not call ValueJoiner
with null value
Key: KAFKA-14400
URL: https://issues.apache.org/jira/browse/KAFKA-14400
[
https://issues.apache.org/jira/browse/KAFKA-6579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ahmed Sobeh reassigned KAFKA-6579:
--
Assignee: Ahmed Sobeh
> Consolidate window store and session store unit tests into a single cl
[
https://issues.apache.org/jira/browse/KAFKA-14362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17635833#comment-17635833
]
A. Sophie Blee-Goldman commented on KAFKA-14362:
Do you ever see anythin
[
https://issues.apache.org/jira/browse/KAFKA-14374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17635805#comment-17635805
]
Youcef Sebiat commented on KAFKA-14374:
---
Thanks for your answer. I will try to ela
showuon commented on code in PR #11390:
URL: https://github.com/apache/kafka/pull/11390#discussion_r1026242726
##
core/src/test/scala/unit/kafka/server/AbstractFetcherThreadTest.scala:
##
@@ -614,12 +613,103 @@ class AbstractFetcherThreadTest {
assertEquals(0L, replicaState
showuon merged PR #12872:
URL: https://github.com/apache/kafka/pull/12872
--
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 #12872:
URL: https://github.com/apache/kafka/pull/12872#issuecomment-1319776013
Failed tests are unrelated:
```
Build / JDK 17 and Scala 2.13 /
kafka.server.KRaftClusterTest.testIncrementalAlterConfigs()
Build / JDK 17 and Scala 2.13 /
kafka.server.K
showuon commented on code in PR #11390:
URL: https://github.com/apache/kafka/pull/11390#discussion_r1026150319
##
core/src/main/scala/kafka/server/ReplicaFetcherThread.scala:
##
@@ -169,4 +181,140 @@ class ReplicaFetcherThread(name: String,
partition.truncateFullyAndStartAt
evan.zhao created KAFKA-14399:
-
Summary: ERROR Processor got uncaught exception: Java heap space
OutOfMemory
Key: KAFKA-14399
URL: https://issues.apache.org/jira/browse/KAFKA-14399
Project: Kafka
showuon commented on code in PR #11390:
URL: https://github.com/apache/kafka/pull/11390#discussion_r1025959204
##
clients/src/test/java/org/apache/kafka/common/record/RemoteLogInputStreamTest.java:
##
@@ -0,0 +1,292 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) und
91 matches
Mail list logo
