apoorvmittal10 commented on code in PR #19261:
URL: https://github.com/apache/kafka/pull/19261#discussion_r2013454652
##
core/src/main/java/kafka/server/share/SharePartition.java:
##
@@ -2484,6 +2497,259 @@ private long startOffsetDuringInitialization(long
partitionDataStartOff
lianetm commented on code in PR #19281:
URL: https://github.com/apache/kafka/pull/19281#discussion_r2016344814
##
core/src/test/scala/unit/kafka/server/ConsumerGroupDescribeRequestTest.scala:
##
@@ -37,15 +37,17 @@ import java.lang.{Byte => JByte}
import java.util.Collections
ijuma commented on PR #15968:
URL: https://github.com/apache/kafka/pull/15968#issuecomment-2743945863
@OmniaGM Would you like someone to help get this over the finish line?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and u
nilmadhab commented on PR #19005:
URL: https://github.com/apache/kafka/pull/19005#issuecomment-2774512670
@mjsax LGTM
--
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 uns
chia7712 commented on PR #19327:
URL: https://github.com/apache/kafka/pull/19327#issuecomment-2781010552
@ijuma thanks for your explanation. I do agree that there is no strict
requirement of removing a test-only method. However, `nodeEndpoints` is crucial
for handling specific errors like `
srdo opened a new pull request, #19367:
URL: https://github.com/apache/kafka/pull/19367
This was done on trunk in 6a37d5ccebaa6bbfc1d1b943f0ff761cf978da7d
--
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
mumrah opened a new pull request, #63:
URL: https://github.com/apache/kafka-merge-queue-sandbox/pull/63
(no comment)
--
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 unsu
jsancio commented on code in PR #18987:
URL: https://github.com/apache/kafka/pull/18987#discussion_r2004145500
##
raft/src/test/java/org/apache/kafka/raft/RaftEventSimulationTest.java:
##
@@ -475,6 +563,99 @@ void canRecoverFromSingleNodeCommittedDataLoss(
scheduler.run
squah-confluent closed pull request #19260: KAFKA-19025: Reuse LZ4 buffers for
compression
URL: https://github.com/apache/kafka/pull/19260
--
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 specifi
[
https://issues.apache.org/jira/browse/KAFKA-19026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Edoardo Comar updated KAFKA-19026:
--
Attachment: KAFKA19026Test.java
> AlterConfigPolicy incompatibility between ZK mode and KRaft
frankvicky commented on code in PR #19277:
URL: https://github.com/apache/kafka/pull/19277#discussion_r2011287595
##
storage/src/test/java/org/apache/kafka/storage/internals/log/BrokerCompressionTest.java:
##
@@ -0,0 +1,117 @@
+/*
+ * Licensed to the Apache Software Foundation (
[
https://issues.apache.org/jira/browse/KAFKA-19079?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17940811#comment-17940811
]
oshione gabriel esiemokhai commented on KAFKA-19079:
hello ,what doe
ShivsundarR commented on code in PR #19335:
URL: https://github.com/apache/kafka/pull/19335#discussion_r2022361659
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ShareConsumerImpl.java:
##
@@ -250,6 +251,7 @@ private enum AcknowledgementMode {
Frédérik ROULEAU created KAFKA-19051:
Summary: Fix implicit acknowledgement cannot be override when
RecordDeserializationException occurs
Key: KAFKA-19051
URL: https://issues.apache.org/jira/browse/KAFKA-19051
chia7712 merged PR #19285:
URL: https://github.com/apache/kafka/pull/19285
--
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-14485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17941241#comment-17941241
]
Dmitry Werner commented on KAFKA-14485:
---
[~chia7712] Thank you for your guidance -
Chia-Ping Tsai created KAFKA-19093:
--
Summary: Change the "Handler on Broker" to "Handler on Controller"
for controller server
Key: KAFKA-19093
URL: https://issues.apache.org/jira/browse/KAFKA-19093
[
https://issues.apache.org/jira/browse/KAFKA-19093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17941243#comment-17941243
]
Nick Guo commented on KAFKA-19093:
--
Hi [~chia7712] ,I would like to handle this.Thanks!
[
https://issues.apache.org/jira/browse/KAFKA-19093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nick Guo reassigned KAFKA-19093:
Assignee: Nick Guo (was: Chia-Ping Tsai)
> Change the "Handler on Broker" to "Handler on Control
Ayoub Omari created KAFKA-19096:
---
Summary: Skipped Records in FK join should not be marked as dropped
Key: KAFKA-19096
URL: https://issues.apache.org/jira/browse/KAFKA-19096
Project: Kafka
Issu
[
https://issues.apache.org/jira/browse/KAFKA-19096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ayoub Omari updated KAFKA-19096:
Description:
Currently, we are logging all skipped records in FK join as dropped.
This seems inco
AyoubOm commented on code in PR #19303:
URL: https://github.com/apache/kafka/pull/19303#discussion_r2029961920
##
streams/src/test/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionSendProcessorSupplierTest.java:
##
@@ -316,6 +367,21 @@ public void inner
wernerdv opened a new pull request, #19387:
URL: https://github.com/apache/kafka/pull/19387
Move LogCleaner and related classes to storage module and rewrite in Java.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
[
https://issues.apache.org/jira/browse/KAFKA-14485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17941300#comment-17941300
]
Dmitry Werner commented on KAFKA-14485:
---
[~chia7712] [~mimaison] I've opened the P
apalan60 commented on PR #19274:
URL: https://github.com/apache/kafka/pull/19274#issuecomment-2759098547
I ran a few tests, and so far I have successfully invoked 14 nodes, with the
tests remaining stable.
 throws Exception {
beginShutdown(
github-actions[bot] commented on PR #17893:
URL: https://github.com/apache/kafka/pull/17893#issuecomment-2749985982
This PR is being marked as stale since it has not had any activity in 90
days. If you
would like to keep this PR alive, please leave a comment asking for a
review. If the P
Apoorv Mittal created KAFKA-19019:
-
Summary: Verify Share Fetch with Tiered Storage
Key: KAFKA-19019
URL: https://issues.apache.org/jira/browse/KAFKA-19019
Project: Kafka
Issue Type: Sub-task
Parkerhiphop commented on PR #19213:
URL: https://github.com/apache/kafka/pull/19213#issuecomment-2741254322
Since the reset behavior has changed, it now resets the configs to their
default values instead of leaving them empty as before.
Here’s a screenshot of the reset behavior—inter
dajac commented on code in PR #19251:
URL: https://github.com/apache/kafka/pull/19251#discussion_r2005969287
##
core/src/main/scala/kafka/server/KafkaApis.scala:
##
@@ -1635,40 +1635,8 @@ class KafkaApis(val requestChannel: RequestChannel,
trace(s"End transaction marker a
mjsax commented on code in PR #19005:
URL: https://github.com/apache/kafka/pull/19005#discussion_r2026065811
##
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/KTableKTableForeignKeyJoinIntegrationTest.java:
##
@@ -232,57 +236,134 @@ public void doJo
Rancho-7 commented on PR #19347:
URL: https://github.com/apache/kafka/pull/19347#issuecomment-2772098768
To verify the behavior, I ran the tests locally using the following
command,and the output is also shown below.
```
(base) lansg:kafka/ (KAFKA-19027✗) $ N=100; I=0; while [ $I -
TaiJuWu commented on code in PR #19286:
URL: https://github.com/apache/kafka/pull/19286#discussion_r2022583314
##
core/src/test/java/kafka/log/remote/RemoteLogManagerTest.java:
##
@@ -413,24 +418,19 @@ void
testRemoteLogMetadataManagerWithEndpointConfigOverridden() throws IOExc
gongxuanzhang commented on PR #19386:
URL: https://github.com/apache/kafka/pull/19386#issuecomment-2781166844
@chia7712 PTAL
--
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.
frankvicky commented on code in PR #19383:
URL: https://github.com/apache/kafka/pull/19383#discussion_r2030020799
##
server-common/src/main/java/org/apache/kafka/config/BrokerReconfigurable.java:
##
@@ -27,13 +29,10 @@
* The reconfiguration process follows three steps:
*
mjsax merged PR #19303:
URL: https://github.com/apache/kafka/pull/19303
--
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
[
https://issues.apache.org/jira/browse/KAFKA-18073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-18073:
Fix Version/s: (was: 4.1.0)
> Data loss when exception is raised from Kafka Connect re
github-actions[bot] commented on PR #19228:
URL: https://github.com/apache/kafka/pull/19228#issuecomment-2781197134
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 #18334:
URL: https://github.com/apache/kafka/pull/18334#issuecomment-2781197176
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
[
https://issues.apache.org/jira/browse/KAFKA-19042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
PoAn Yang updated KAFKA-19042:
--
Description:
This is an umbrella Jira about moving integration tests from kafka.api module
to clients
[
https://issues.apache.org/jira/browse/KAFKA-19042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
PoAn Yang updated KAFKA-19042:
--
Summary: Move kafka.api test cases to clients-integration-tests module
(was: Move kafka.api test case
[
https://issues.apache.org/jira/browse/KAFKA-19042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17941311#comment-17941311
]
PoAn Yang commented on KAFKA-19042:
---
Thanks. Updated it.
> Move kafka.api test cases
github-actions[bot] commented on PR #9493:
URL: https://github.com/apache/kafka/pull/9493#issuecomment-2781201685
This PR is being marked as stale since it has not had any activity in 90
days. If you
would like to keep this PR alive, please leave a comment asking for a
review. If the PR
AndrewJSchofield merged PR #19254:
URL: https://github.com/apache/kafka/pull/19254
--
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
mimaison commented on PR #19280:
URL: https://github.com/apache/kafka/pull/19280#issuecomment-2750753505
> Somehow, I was convinced that it was executed automatically now every
quarter.
Me too! But it does not seem to be the case.
--
This is an automated message from the Apache Git
lucasbru commented on code in PR #19219:
URL: https://github.com/apache/kafka/pull/19219#discussion_r2028473669
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java:
##
@@ -8148,7 +8174,10 @@ private TaskAssignor streamsGroupAssignor(St
[
https://issues.apache.org/jira/browse/KAFKA-18713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17939766#comment-17939766
]
Stanislav Spiridonov commented on KAFKA-18713:
--
# 4.0.0 is released, but th
ijuma commented on PR #19327:
URL: https://github.com/apache/kafka/pull/19327#issuecomment-2781041904
OK, if the concern is that this method is unsafe in prod, it's reasonable to
replace it with a test utility method.
--
This is an automated message from the Apache Git Service.
To respond
[
https://issues.apache.org/jira/browse/KAFKA-19050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17938882#comment-17938882
]
Chia-Ping Tsai commented on KAFKA-19050:
[~utkuaydin] do you mean we should move
lucasbru merged PR #18383:
URL: https://github.com/apache/kafka/pull/18383
--
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
mumrah merged PR #19248:
URL: https://github.com/apache/kafka/pull/19248
--
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-19096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-19096:
---
Assignee: Matthias J. Sax
> Skipped Records in FK join should not be marked as drop
201 - 252 of 252 matches
Mail list logo
