github-actions[bot] commented on PR #20197:
URL: https://github.com/apache/kafka/pull/20197#issuecomment-3121125126
A label of 'needs-attention' was automatically added to this PR in order to
raise the
attention of the committers. Once this issue has been triaged, the `triage`
label
s
github-actions[bot] commented on PR #20198:
URL: https://github.com/apache/kafka/pull/20198#issuecomment-3121125094
A label of 'needs-attention' was automatically added to this PR in order to
raise the
attention of the committers. Once this issue has been triaged, the `triage`
label
s
Lucy Liu created KAFKA-19550:
Summary: Integration test for Streams-related Admin APIs[1/N]
Key: KAFKA-19550
URL: https://issues.apache.org/jira/browse/KAFKA-19550
Project: Kafka
Issue Type: Tes
[
https://issues.apache.org/jira/browse/KAFKA-19550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lucy Liu reassigned KAFKA-19550:
Assignee: Lucy Liu
> Integration test for Streams-related Admin APIs[1/N]
>
lucliu1108 opened a new pull request, #20244:
URL: https://github.com/apache/kafka/pull/20244
This PR adds:
- Integration test for `Admin#describeStreamsGroups` API
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use th
Mirai1129 opened a new pull request, #20243:
URL: https://github.com/apache/kafka/pull/20243
the constructor is error-prone when migrating code, since metrics could get
unintentionally changed. We should remove the constructor and use constant
strings instead to avoid issues like
[KAFKA-17
0x-zhiyan opened a new pull request, #20242:
URL: https://github.com/apache/kafka/pull/20242
There is a small logic bug in topic replay. If a topic is created and then
removed before the TopicsDelta is applied, we end up with the deleted topic in
createdTopics on the delta but not in de
ahuang98 commented on PR #19854:
URL: https://github.com/apache/kafka/pull/19854#issuecomment-3120475711
btw, build is green! I'm pushing a commit for a single test fix which I
validated still passes locally
--
This is an automated message from the Apache Git Service.
To respond to the me
ahuang98 commented on code in PR #19854:
URL: https://github.com/apache/kafka/pull/19854#discussion_r2232070935
##
raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java:
##
@@ -2570,7 +2570,7 @@ private void maybeTransition(
transitionToUnattached(epoch,
jsancio commented on code in PR #19854:
URL: https://github.com/apache/kafka/pull/19854#discussion_r2232057083
##
raft/src/test/java/org/apache/kafka/raft/RequestManagerTest.java:
##
@@ -245,6 +245,41 @@ public void testFindReadyWithRequestTimedOut() {
assertFalse(cache
jsancio commented on code in PR #19854:
URL: https://github.com/apache/kafka/pull/19854#discussion_r2232057083
##
raft/src/test/java/org/apache/kafka/raft/RequestManagerTest.java:
##
@@ -245,6 +245,41 @@ public void testFindReadyWithRequestTimedOut() {
assertFalse(cache
ahuang98 commented on code in PR #19854:
URL: https://github.com/apache/kafka/pull/19854#discussion_r2231846413
##
raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java:
##
@@ -2569,13 +2569,15 @@ private void maybeTransition(
} else {
trans
sjhajharia commented on PR #20222:
URL: https://github.com/apache/kafka/pull/20222#issuecomment-3119862224
gentle ping @chia7712
TIA!
--
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
mjsax merged PR #20239:
URL: https://github.com/apache/kafka/pull/20239
--
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
sjhajharia commented on code in PR #20180:
URL: https://github.com/apache/kafka/pull/20180#discussion_r2231662307
##
server/src/main/java/org/apache/kafka/server/share/session/ShareSessionKey.java:
##
@@ -21,23 +21,12 @@
import java.util.Objects;
-public class ShareSessionK
AndrewJSchofield merged PR #20241:
URL: https://github.com/apache/kafka/pull/20241
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscr...@kafk
AndrewJSchofield commented on code in PR #20241:
URL: https://github.com/apache/kafka/pull/20241#discussion_r2231574494
##
docs/streams/upgrade-guide.html:
##
@@ -213,6 +213,11 @@ Early Access of the Streams Rebalance Protocol
Set unstable.feature.versions.enable=true f
AndrewJSchofield commented on code in PR #20241:
URL: https://github.com/apache/kafka/pull/20241#discussion_r2231549770
##
docs/streams/upgrade-guide.html:
##
@@ -213,6 +213,11 @@ Early Access of the Streams Rebalance Protocol
Set unstable.feature.versions.enable=true f
ravikalla commented on code in PR #20219:
URL: https://github.com/apache/kafka/pull/20219#discussion_r2231508798
##
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerTest.java:
##
@@ -2998,15 +2993,6 @@ private void
verifyVersionedTaskConverterFromWorker(Stri
[
https://issues.apache.org/jira/browse/KAFKA-19541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jonah Hooper reassigned KAFKA-19541:
Assignee: Jonah Hooper
> KRaft should handle snapshot fetches under slow networks
> -
Mickael Maison created KAFKA-19549:
--
Summary: network_degrade_test.py failure
Key: KAFKA-19549
URL: https://issues.apache.org/jira/browse/KAFKA-19549
Project: Kafka
Issue Type: Bug
Affec
lucliu1108 opened a new pull request, #20241:
URL: https://github.com/apache/kafka/pull/20241
As a follow-up on https://github.com/apache/kafka/pull/20029 , add the
instructions for upgrading `streams.version` parameter for KIP-1071 EA.
--
This is an automated message from the Apache Git
jiafu1115 commented on PR #20007:
URL: https://github.com/apache/kafka/pull/20007#issuecomment-3118226302
@kamalcph Hi, kamalcph. I already fix the import sequence issue and squash
several commits. you can help to retrigger the build when you free. thanks
--
This is an automated message f
iddeepak opened a new pull request, #20240:
URL: https://github.com/apache/kafka/pull/20240
The newly added `StreamsGroupCommand.java` tool, does not return a popper
error code, what might break scripts which use `bin/kafka-streams-group.sh` as
they cannot do proper error handling.
S
Pankraz76 commented on PR #20219:
URL: https://github.com/apache/kafka/pull/20219#issuecomment-3117403438
```
BUILD SUCCESSFUL in 38m 46s
374 actionable tasks: 90 executed, 284 up-to-date
➜ kafka git:(rewrite-) ./gradlew build -x test
```
Kindly request your feedback.
TaiJuWu commented on code in PR #20235:
URL: https://github.com/apache/kafka/pull/20235#discussion_r2230764127
##
tools/src/test/java/org/apache/kafka/tools/consumer/group/ResetConsumerGroupOffsetTest.java:
##
@@ -153,6 +155,29 @@ public void
testResetOffsetsNotExistingGroup(Cl
Yunyung commented on code in PR #20235:
URL: https://github.com/apache/kafka/pull/20235#discussion_r2230635080
##
tools/src/test/java/org/apache/kafka/tools/consumer/group/ResetConsumerGroupOffsetTest.java:
##
@@ -153,6 +155,29 @@ public void
testResetOffsetsNotExistingGroup(Cl
TaiJuWu commented on code in PR #20235:
URL: https://github.com/apache/kafka/pull/20235#discussion_r2230581343
##
tools/src/test/java/org/apache/kafka/tools/consumer/group/ResetConsumerGroupOffsetTest.java:
##
@@ -153,6 +154,26 @@ public void
testResetOffsetsNotExistingGroup(Cl
zt52875287 commented on code in PR #19442:
URL: https://github.com/apache/kafka/pull/19442#discussion_r2230499616
##
clients/src/main/java/org/apache/kafka/common/internals/PartitionStates.java:
##
@@ -129,28 +129,14 @@ public int size() {
*/
public void set(Map parti
chia7712 commented on code in PR #20235:
URL: https://github.com/apache/kafka/pull/20235#discussion_r2230496206
##
tools/src/test/java/org/apache/kafka/tools/consumer/group/ResetConsumerGroupOffsetTest.java:
##
@@ -153,6 +154,26 @@ public void
testResetOffsetsNotExistingGroup(C
zt52875287 closed pull request #19442: MINOR: Simplify PartitionStates update
logic by removing unnecessary grouping
URL: https://github.com/apache/kafka/pull/19442
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
jiafu1115 commented on PR #20008:
URL: https://github.com/apache/kafka/pull/20008#issuecomment-3116804378
close it due to I already open another one with new approach which can solve
the RC.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
jiafu1115 closed pull request #20008: KAFKA-19426: Correct the
TopicBasedRemoteLogMetadataManager#initializeResources' retry default configure
value to reasonable one
URL: https://github.com/apache/kafka/pull/20008
--
This is an automated message from the Apache Git Service.
To respond to th
jiafu1115 commented on code in PR #20203:
URL: https://github.com/apache/kafka/pull/20203#discussion_r2230435337
##
storage/api/src/main/java/org/apache/kafka/server/log/remote/storage/RemoteLogMetadataManager.java:
##
@@ -242,4 +242,18 @@ default Optional
nextSegmentWithTxnInd
Yunyung commented on PR #20239:
URL: https://github.com/apache/kafka/pull/20239#issuecomment-3116727404
> Hi @mjsax , just found that without the default implementation the code
can't pass the test `org.gradle.api.plugins.quality.internal.CheckstyleAction`,
so I add it back.
Hi, actu
fvaleri commented on code in PR #20221:
URL: https://github.com/apache/kafka/pull/20221#discussion_r2230353006
##
tools/src/main/java/org/apache/kafka/tools/ConsumerPerformance.java:
##
@@ -134,8 +136,13 @@ private static void consume(KafkaConsumer
consumer,
long repor
[
https://issues.apache.org/jira/browse/KAFKA-19548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haozhong Ma updated KAFKA-19548:
Description: In our production environment, we encountered a scenario where
a broker failed to sta
[
https://issues.apache.org/jira/browse/KAFKA-19548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haozhong Ma updated KAFKA-19548:
Description: In our production environment, we encountered a scenario where
a broker failed to sta
Yunyung commented on PR #20145:
URL: https://github.com/apache/kafka/pull/20145#issuecomment-3116682848
> @Yunyung the example of section `Run a specific test method with specific
parameters` is also broken. Could you please fix it in this PR?
Thanks for checking. Done.
I saw the m
Haozhong Ma created KAFKA-19548:
---
Summary: Broker Startup: Handle Checkpoint Creation Failure via
logDirFailureChannel
Key: KAFKA-19548
URL: https://issues.apache.org/jira/browse/KAFKA-19548
Project: Ka
40 matches
Mail list logo
