gongxuanzhang commented on PR #16547:
URL: https://github.com/apache/kafka/pull/16547#issuecomment-182852
LGTM, @chia7712 Can we batch modify this refacible code?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use th
abhijeetk88 commented on code in PR #16502:
URL: https://github.com/apache/kafka/pull/16502#discussion_r1673509846
##
core/src/main/java/kafka/log/remote/RemoteLogManager.java:
##
@@ -686,60 +702,98 @@ List getLeaderEpochEntries(UnifiedLog log,
long startOffset, long en
}
abhijeetk88 commented on PR #16502:
URL: https://github.com/apache/kafka/pull/16502#issuecomment-189362
@showuon I have responded to your comments. Please take another look.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
abhijeetk88 commented on code in PR #16502:
URL: https://github.com/apache/kafka/pull/16502#discussion_r1673511532
##
core/src/main/java/kafka/log/remote/RemoteLogManager.java:
##
@@ -241,7 +245,12 @@ public RemoteLogManager(RemoteLogManagerConfig rlmConfig,
indexCach
showuon commented on code in PR #16502:
URL: https://github.com/apache/kafka/pull/16502#discussion_r1673519734
##
core/src/main/java/kafka/log/remote/RemoteLogManager.java:
##
@@ -686,60 +702,98 @@ List getLeaderEpochEntries(UnifiedLog log,
long startOffset, long en
}
showuon commented on code in PR #16502:
URL: https://github.com/apache/kafka/pull/16502#discussion_r1673520175
##
core/src/main/java/kafka/log/remote/RemoteLogManager.java:
##
@@ -241,7 +245,12 @@ public RemoteLogManager(RemoteLogManagerConfig rlmConfig,
indexCache =
[
https://issues.apache.org/jira/browse/KAFKA-9738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864948#comment-17864948
]
Bruno Cadonna commented on KAFKA-9738:
--
The old `MockProcessorContext` is still not
cadonna merged PR #16561:
URL: https://github.com/apache/kafka/pull/16561
--
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-17111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Josep Prat updated KAFKA-17111:
---
Fix Version/s: 3.8.0
> ServiceConfigurationError in JsonSerializer/Deserializer during Plugin
> Dis
yazgoo commented on code in PR #16486:
URL: https://github.com/apache/kafka/pull/16486#discussion_r1673685382
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/IncrementalCooperativeAssignor.java:
##
@@ -793,6 +796,46 @@ protected void assignConnector
yazgoo commented on code in PR #16486:
URL: https://github.com/apache/kafka/pull/16486#discussion_r1673685382
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/IncrementalCooperativeAssignor.java:
##
@@ -793,6 +796,46 @@ protected void assignConnector
[
https://issues.apache.org/jira/browse/KAFKA-17094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864980#comment-17864980
]
Igor Soarez commented on KAFKA-17094:
-
I agree it makes sense to make this informati
[
https://issues.apache.org/jira/browse/KAFKA-17098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna updated KAFKA-17098:
--
Priority: Critical (was: Minor)
> Error Opening RocksDBStore
> --
>
>
soarez commented on code in PR #14628:
URL: https://github.com/apache/kafka/pull/14628#discussion_r1673749083
##
core/src/main/scala/kafka/tools/StorageTool.scala:
##
@@ -60,7 +63,11 @@ object StorageTool extends Logging {
if (!metadataVersion.isKRaftSupported) {
subhashiyer9 commented on code in PR #16496:
URL: https://github.com/apache/kafka/pull/16496#discussion_r1673749240
##
clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java:
##
@@ -1201,13 +1201,26 @@ private ClusterAndWaitTime waitOnMetadata(String topic,
soarez commented on code in PR #14628:
URL: https://github.com/apache/kafka/pull/14628#discussion_r1673749083
##
core/src/main/scala/kafka/tools/StorageTool.scala:
##
@@ -60,7 +63,11 @@ object StorageTool extends Logging {
if (!metadataVersion.isKRaftSupported) {
cadonna opened a new pull request, #16570:
URL: https://github.com/apache/kafka/pull/16570
When Streams tries to transit a restored active task to RUNNING, the first
thing it does is getting the committed offsets for this task. If getting the
offsets expires a timeout, Streams does not re-t
kamalcph commented on code in PR #16502:
URL: https://github.com/apache/kafka/pull/16502#discussion_r1673686505
##
core/src/main/java/kafka/log/remote/RemoteLogManager.java:
##
@@ -241,12 +245,17 @@ public RemoteLogManager(RemoteLogManagerConfig rlmConfig,
indexCache
[
https://issues.apache.org/jira/browse/KAFKA-17098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna reassigned KAFKA-17098:
-
Assignee: Bruno Cadonna
> Error Opening RocksDBStore
> --
>
>
[
https://issues.apache.org/jira/browse/KAFKA-17098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864987#comment-17864987
]
Bruno Cadonna commented on KAFKA-17098:
---
[~eduwerc] I think, I found the issue. Se
Andy Coates created KAFKA-17120:
---
Summary: Race condition in KafkaStreams.close can result in
StreamsException "Failed to shut down while in state"
Key: KAFKA-17120
URL: https://issues.apache.org/jira/browse/KAFKA-1
jlprat commented on PR #16565:
URL: https://github.com/apache/kafka/pull/16565#issuecomment-582924
Test 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 co
jlprat commented on PR #16565:
URL: https://github.com/apache/kafka/pull/16565#issuecomment-585080
@mimaison or @divijvaidya As you reviewed
https://github.com/apache/kafka/pull/14992 do you want to take a look at this
one as well?
--
This is an automated message from the Apache Git
FrankYang0529 commented on PR #16499:
URL: https://github.com/apache/kafka/pull/16499#issuecomment-597872
> @FrankYang0529 please take a look at build error
Fixed it. The latest CI doesn't have build error. Could you take a look?
Thank you.
--
This is an automated message from
Andy Wilkinson created KAFKA-17121:
--
Summary: junit-platform.properties files in published artifacts
pollute the test classpath of consumers
Key: KAFKA-17121
URL: https://issues.apache.org/jira/browse/KAFKA-17121
[
https://issues.apache.org/jira/browse/KAFKA-17079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
kaushik srinivas updated KAFKA-17079:
-
Priority: Major (was: Blocker)
> scoverage plugin not found in maven repo, version 1.9.
TaiJuWu commented on code in PR #16127:
URL: https://github.com/apache/kafka/pull/16127#discussion_r1673847880
##
clients/src/test/java/org/apache/kafka/test/TestUtils.java:
##
@@ -706,4 +706,9 @@ public static ApiVersionsResponse createApiVersionsResponse(
ApiV
TaiJuWu commented on code in PR #16127:
URL: https://github.com/apache/kafka/pull/16127#discussion_r1673848590
##
core/src/test/java/kafka/testkit/KafkaClusterTestKit.java:
##
@@ -191,7 +191,7 @@ private KafkaConfig createNodeConfig(TestKitNode node) {
contr
TaiJuWu commented on code in PR #16127:
URL: https://github.com/apache/kafka/pull/16127#discussion_r1673847880
##
clients/src/test/java/org/apache/kafka/test/TestUtils.java:
##
@@ -706,4 +706,9 @@ public static ApiVersionsResponse createApiVersionsResponse(
ApiV
TaiJuWu commented on code in PR #16127:
URL: https://github.com/apache/kafka/pull/16127#discussion_r1673847880
##
clients/src/test/java/org/apache/kafka/test/TestUtils.java:
##
@@ -706,4 +706,9 @@ public static ApiVersionsResponse createApiVersionsResponse(
ApiV
[
https://issues.apache.org/jira/browse/KAFKA-6939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17865033#comment-17865033
]
Ksolves India Limited commented on KAFKA-6939:
--
The configuration
[log.mess
omkreddy commented on code in PR #16461:
URL: https://github.com/apache/kafka/pull/16461#discussion_r1673850589
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/Acknowledgements.java:
##
@@ -0,0 +1,323 @@
+/*
+ * Licensed to the Apache Software Foundation (AS
Nancy-ksolves commented on PR #16548:
URL: https://github.com/apache/kafka/pull/16548#issuecomment-760243
Hi @mimaison, to proceed with changing the default value of a public
configuration, we require access to the Kafka Improvement Proposal (KIP). Could
you please provide details on ho
AndrewJSchofield commented on code in PR #16461:
URL: https://github.com/apache/kafka/pull/16461#discussion_r1673903246
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ShareConsumeRequestManager.java:
##
@@ -0,0 +1,888 @@
+/*
+ * Licensed to the Apache Softw
jlprat merged PR #16565:
URL: https://github.com/apache/kafka/pull/16565
--
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
cadonna commented on PR #16570:
URL: https://github.com/apache/kafka/pull/16570#issuecomment-789726
Streams system tests have zero failures on this PR:
http://confluent-open-source-kafka-branch-builder-system-test-results.s3-us-west-2.amazonaws.com/trunk/2024-07-11--001.f881b68f-ae76-4fa
mimaison commented on PR #16548:
URL: https://github.com/apache/kafka/pull/16548#issuecomment-834086
If you give me you Confluence userid, I can grant you permissions to create
a KIP.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log o
jlprat commented on PR #16565:
URL: https://github.com/apache/kafka/pull/16565#issuecomment-844388
Cherry picked as well to `3.8`.
--
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
[
https://issues.apache.org/jira/browse/KAFKA-17112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17865048#comment-17865048
]
Bruno Cadonna commented on KAFKA-17112:
---
[~aoli-al] I think you are right. We are
[
https://issues.apache.org/jira/browse/KAFKA-17094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17865049#comment-17865049
]
Mickael Maison commented on KAFKA-17094:
[~soarez] It seems this is a topic that
subhashiyer9 commented on code in PR #16496:
URL: https://github.com/apache/kafka/pull/16496#discussion_r1673749240
##
clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java:
##
@@ -1201,13 +1201,26 @@ private ClusterAndWaitTime waitOnMetadata(String topic,
m1a2st commented on PR #16381:
URL: https://github.com/apache/kafka/pull/16381#issuecomment-873610
@chia7712, add new test for `InvalidConfigurationException`, PTAL, Thanks
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub a
m1a2st commented on PR #16557:
URL: https://github.com/apache/kafka/pull/16557#issuecomment-96
@chia7712, Thanks for your comments, 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 th
[
https://issues.apache.org/jira/browse/KAFKA-17121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andy Wilkinson updated KAFKA-17121:
---
Description:
https://github.com/apache/kafka/commit/6e998cffdd33e343945877ccee1fec8337c7d57d
[
https://issues.apache.org/jira/browse/KAFKA-17121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andy Wilkinson updated KAFKA-17121:
---
Description:
https://github.com/apache/kafka/commit/6e998cffdd33e343945877ccee1fec8337c7d57d
FrankYang0529 opened a new pull request, #16571:
URL: https://github.com/apache/kafka/pull/16571
[KIP-1040](https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=303794677)
mentioned adding new configuration to InsertField, ExtractField, HeaderFrom,
Cast, SetSchemaMetadata, Time
[
https://issues.apache.org/jira/browse/KAFKA-17112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17865080#comment-17865080
]
Ao Li commented on KAFKA-17112:
---
Yes, I'm happy to submit a patch. I'm thinking of two pot
lianetm commented on code in PR #16449:
URL: https://github.com/apache/kafka/pull/16449#discussion_r1674077031
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java:
##
@@ -1501,11 +1501,11 @@ public void unsubscribe() {
private void
[
https://issues.apache.org/jira/browse/KAFKA-17115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-17115:
--
Component/s: clients
> Closing newly-created legacy consumers during rebalance can cause rebalances
>
lianetm commented on PR #16449:
URL: https://github.com/apache/kafka/pull/16449#issuecomment-2223050194
Hey @FrankYang0529 , thanks for the updates. Only one nit left. Also I
notice the build did not complete, please merge trunk latest changes too and
let's see what we get on the next run.
[
https://issues.apache.org/jira/browse/KAFKA-17116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-17116:
--
Component/s: clients
> New consumer may not send effective leave group if member ID received after
>
dujian0068 commented on code in PR #16509:
URL: https://github.com/apache/kafka/pull/16509#discussion_r1674098676
##
streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java:
##
@@ -834,6 +834,10 @@ public class StreamsConfig extends AbstractConfig {
private static
dujian0068 commented on PR #16509:
URL: https://github.com/apache/kafka/pull/16509#issuecomment-2223084635
Thank you @mjsax
I have updated config-stream doc. Do I need to update upgrade-guide? Can you
tell me in which cases I need to update upgrade-guide?
--
This is an automated messa
jlprat commented on PR #16570:
URL: https://github.com/apache/kafka/pull/16570#issuecomment-2223114080
Test failures seem 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 specifi
lianetm commented on code in PR #16200:
URL: https://github.com/apache/kafka/pull/16200#discussion_r1674138238
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestManagerTest.java:
##
@@ -201,8 +202,42 @@ public void testSuccessfulHeartbeatTiming
lianetm commented on code in PR #16200:
URL: https://github.com/apache/kafka/pull/16200#discussion_r1674142299
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestManagerTest.java:
##
@@ -201,8 +202,42 @@ public void testSuccessfulHeartbeatTiming
FrankYang0529 commented on code in PR #16449:
URL: https://github.com/apache/kafka/pull/16449#discussion_r1674145282
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java:
##
@@ -1501,11 +1501,11 @@ public void unsubscribe() {
privat
[
https://issues.apache.org/jira/browse/KAFKA-17061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haruki Okada updated KAFKA-17061:
-
Description:
h2. Environment
* Kafka version: 3.3.2
* Cluster: 200~ brokers
* Total num parti
[
https://issues.apache.org/jira/browse/KAFKA-17061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haruki Okada updated KAFKA-17061:
-
Attachment: flame.html
> KafkaController takes long time to connect to newly added broker after
[
https://issues.apache.org/jira/browse/KAFKA-17061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haruki Okada updated KAFKA-17061:
-
Attachment: flame-patched.html
> KafkaController takes long time to connect to newly added broke
lianetm commented on code in PR #16200:
URL: https://github.com/apache/kafka/pull/16200#discussion_r1674150218
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestManagerTest.java:
##
@@ -251,23 +304,25 @@ public void testSkippingHeartbeat(final
[
https://issues.apache.org/jira/browse/KAFKA-17061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haruki Okada updated KAFKA-17061:
-
Attachment: screenshot-flame.png
> KafkaController takes long time to connect to newly added bro
[
https://issues.apache.org/jira/browse/KAFKA-17061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haruki Okada updated KAFKA-17061:
-
Attachment: screenshot-flame-patched.png
> KafkaController takes long time to connect to newly a
[
https://issues.apache.org/jira/browse/KAFKA-17061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haruki Okada updated KAFKA-17061:
-
Description:
h2. Environment
* Kafka version: 3.3.2
* Cluster: 200~ brokers
* Total num parti
[
https://issues.apache.org/jira/browse/KAFKA-17061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17865110#comment-17865110
]
Haruki Okada commented on KAFKA-17061:
--
Did a micro benchmark to check the performa
ocadaruma commented on PR #16529:
URL: https://github.com/apache/kafka/pull/16529#issuecomment-2223158388
@chia7712 Added a flamegraph. PTAL
https://issues.apache.org/jira/browse/KAFKA-17061?focusedCommentId=17865110&page=com.atlassian.jira.plugin.system.issuetabpanels%3Acomment-tabpanel#
lianetm commented on code in PR #16200:
URL: https://github.com/apache/kafka/pull/16200#discussion_r1674165119
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestManagerTest.java:
##
@@ -756,18 +801,19 @@ public void
testFencedMemberStopHeartbe
lianetm commented on code in PR #16200:
URL: https://github.com/apache/kafka/pull/16200#discussion_r1674174436
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestManagerTest.java:
##
@@ -659,95 +749,50 @@ public void
testPollTimerExpirationShou
lianetm commented on code in PR #16200:
URL: https://github.com/apache/kafka/pull/16200#discussion_r1674207651
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestManagerTest.java:
##
@@ -201,8 +202,42 @@ public void testSuccessfulHeartbeatTiming
lianetm commented on code in PR #16200:
URL: https://github.com/apache/kafka/pull/16200#discussion_r1674210447
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestManagerTest.java:
##
@@ -201,8 +202,42 @@ public void testSuccessfulHeartbeatTiming
lianetm commented on code in PR #16200:
URL: https://github.com/apache/kafka/pull/16200#discussion_r1674210447
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestManagerTest.java:
##
@@ -201,8 +202,42 @@ public void testSuccessfulHeartbeatTiming
[
https://issues.apache.org/jira/browse/KAFKA-17119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17865131#comment-17865131
]
Greg Harris commented on KAFKA-17119:
-
Hi [~StarBoy1005] The Apache Kafka project do
[
https://issues.apache.org/jira/browse/KAFKA-17119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Harris resolved KAFKA-17119.
-
Resolution: Cannot Reproduce
> After enabled kafka-ranger-plugin and baned the user for using de
[
https://issues.apache.org/jira/browse/KAFKA-17111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Harris resolved KAFKA-17111.
-
Resolution: Fixed
> ServiceConfigurationError in JsonSerializer/Deserializer during Plugin
> Di
jlprat merged PR #16570:
URL: https://github.com/apache/kafka/pull/16570
--
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-17098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Josep Prat updated KAFKA-17098:
---
Fix Version/s: 3.8.0
> Error Opening RocksDBStore
> --
>
> K
[
https://issues.apache.org/jira/browse/KAFKA-17117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17865134#comment-17865134
]
Greg Harris commented on KAFKA-17117:
-
Considering that the only plugins typically o
mjsax commented on PR #16570:
URL: https://github.com/apache/kafka/pull/16570#issuecomment-2223275885
Who is cherry-picking this to `trunk`? @jlprat are you doing this, or should
we (@cadonna) do the cherry-pick?
--
This is an automated message from the Apache Git Service.
To respond to t
[
https://issues.apache.org/jira/browse/KAFKA-17101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864935#comment-17864935
]
Greg Harris edited comment on KAFKA-17101 at 7/11/24 3:40 PM:
jlprat commented on PR #16570:
URL: https://github.com/apache/kafka/pull/16570#issuecomment-2223277883
I'll cherry pick this one 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 to go to the spe
[
https://issues.apache.org/jira/browse/KAFKA-17101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17865137#comment-17865137
]
Greg Harris commented on KAFKA-17101:
-
[~kaushik srinivas] Unfortunately I don't see
[
https://issues.apache.org/jira/browse/KAFKA-17101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17865138#comment-17865138
]
Greg Harris commented on KAFKA-17101:
-
Also you mentioned MM1, is that a typo or are
jlprat commented on PR #16570:
URL: https://github.com/apache/kafka/pull/16570#issuecomment-2223290582
Cherry picked 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 to go to the specific commen
dongjinleekr opened a new pull request, #16572:
URL: https://github.com/apache/kafka/pull/16572
### Summary
If the user runs `ReplicaVerificationTool`, it shows a deprecation warning.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementatio
apoorvmittal10 opened a new pull request, #16573:
URL: https://github.com/apache/kafka/pull/16573
ShareGroupHeartbeat API support as defined in KIP-932. The heartbeat
persists Group and Member information on `__consumer_offsets` topic.
The PR also moves some of the ShareGroupConfigs t
junrao commented on code in PR #16183:
URL: https://github.com/apache/kafka/pull/16183#discussion_r1674294082
##
server-common/src/main/java/org/apache/kafka/server/common/MetadataVersion.java:
##
@@ -217,8 +217,11 @@ public enum MetadataVersion {
// Add ELR related support
[
https://issues.apache.org/jira/browse/KAFKA-10814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-10814.
-
Resolution: Incomplete
Unclear what the problem is. Closing.
> improving ability of han
[
https://issues.apache.org/jira/browse/KAFKA-9738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17865145#comment-17865145
]
Matthias J. Sax commented on KAFKA-9738:
Given that `Processor` is deprecated alr
[
https://issues.apache.org/jira/browse/KAFKA-9738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-9738:
--
Assignee: Matthias J. Sax
> Add Generics Type Parameters to forwarded() in MockProcess
lianetm commented on code in PR #16200:
URL: https://github.com/apache/kafka/pull/16200#discussion_r1674309494
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestManagerTest.java:
##
@@ -425,6 +482,7 @@ topicId, mkSortedSet(0)
assertEqu
jolshan commented on code in PR #16183:
URL: https://github.com/apache/kafka/pull/16183#discussion_r1674310171
##
server-common/src/main/java/org/apache/kafka/server/common/MetadataVersion.java:
##
@@ -217,8 +217,11 @@ public enum MetadataVersion {
// Add ELR related suppor
jolshan commented on code in PR #16496:
URL: https://github.com/apache/kafka/pull/16496#discussion_r1674314203
##
clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java:
##
@@ -1201,13 +1201,26 @@ private ClusterAndWaitTime waitOnMetadata(String topic,
Integ
[
https://issues.apache.org/jira/browse/KAFKA-9738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-9738:
---
Labels: kip (was: )
> Add Generics Type Parameters to forwarded() in MockProcessorContext
>
[
https://issues.apache.org/jira/browse/KAFKA-9738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-9738:
---
Description:
The method {{forwarded()}} to capture the forwarded records in
{{MockProcessorC
lianetm commented on code in PR #16200:
URL: https://github.com/apache/kafka/pull/16200#discussion_r1674318250
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestManagerTest.java:
##
@@ -447,7 +505,8 @@ private ConsumerGroupHeartbeatRequest
get
[
https://issues.apache.org/jira/browse/KAFKA-16937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17865164#comment-17865164
]
Greg Harris edited comment on KAFKA-16937 at 7/11/24 5:15 PM:
[
https://issues.apache.org/jira/browse/KAFKA-16937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17865164#comment-17865164
]
Greg Harris commented on KAFKA-16937:
-
I thought about this some more. Right now the
jsancio commented on code in PR #16563:
URL: https://github.com/apache/kafka/pull/16563#discussion_r1674382183
##
raft/src/test/java/org/apache/kafka/raft/KafkaRaftClientTest.java:
##
@@ -281,15 +281,20 @@ public void testGrantVotesWhenShuttingDown(boolean
withKip853Rpc) throws
jolshan commented on PR #16462:
URL: https://github.com/apache/kafka/pull/16462#issuecomment-2223500451
Finally got to confirming the test results 👍 All passed. will merge now.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub a
jsancio commented on code in PR #16230:
URL: https://github.com/apache/kafka/pull/16230#discussion_r1674397738
##
clients/src/main/java/org/apache/kafka/common/requests/ApiVersionsResponse.java:
##
@@ -313,10 +313,12 @@ private static FinalizedFeatureKeyCollection
createFinaliz
1 - 100 of 154 matches
Mail list logo
