fvaleri opened a new pull request, #14534:
URL: https://github.com/apache/kafka/pull/14534
This change adds the upgrade documentation for 3.6.0 and fix the notable
changes position in 3.5.0. In previous releases, notable changes always come
after the upgrade instructions.
--
This is an a
ijuma commented on code in PR #14502:
URL: https://github.com/apache/kafka/pull/14502#discussion_r1356255838
##
gradlew:
##
@@ -214,11 +215,11 @@ fi
# Add default JVM options here. You can also use JAVA_OPTS and GRADLE_OPTS to
pass JVM options to this script.
DEFAULT_JVM_OPTS
[
https://issues.apache.org/jira/browse/KAFKA-14987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot resolved KAFKA-14987.
-
Fix Version/s: 3.7.0
Reviewer: David Jacot
Resolution: Fixed
> Implement Group/O
dajac merged PR #14467:
URL: https://github.com/apache/kafka/pull/14467
--
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
bmscomp commented on code in PR #14502:
URL: https://github.com/apache/kafka/pull/14502#discussion_r1356170118
##
gradlew:
##
@@ -214,11 +215,11 @@ fi
# Add default JVM options here. You can also use JAVA_OPTS and GRADLE_OPTS to
pass JVM options to this script.
DEFAULT_JVM_OP
hanyuzheng7 commented on code in PR #14523:
URL: https://github.com/apache/kafka/pull/14523#discussion_r1356041608
##
streams/src/test/java/org/apache/kafka/streams/integration/IQv2StoreIntegrationTest.java:
##
@@ -880,25 +888,113 @@ private void shouldHandleWindowKeyQueries(fi
lkokhreidze commented on PR #14519:
URL: https://github.com/apache/kafka/pull/14519#issuecomment-1758991030
Many thanks @ableegoldman for merging the PR 🙇
What do you think about 3.5.2 release with a fix?
I'm no expert with the Kafka release processes, but given the feature was
implem
satishd commented on PR #14527:
URL: https://github.com/apache/kafka/pull/14527#issuecomment-1758959426
>Seems this does not cover KS -- btw: there is some issue for KS system
tests right now, and as a matter of fact, we did not even add the missing
upgrade tests in older release yet (PR is
[
https://issues.apache.org/jira/browse/KAFKA-15593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Satish Duggana updated KAFKA-15593:
---
Fix Version/s: 3.7.0
> Add 3.6.0 to broker/client upgrade/compatibility tests
>
[
https://issues.apache.org/jira/browse/KAFKA-15593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Satish Duggana reassigned KAFKA-15593:
--
Assignee: Satish Duggana
> Add 3.6.0 to broker/client upgrade/compatibility tests
> -
Satish Duggana created KAFKA-15593:
--
Summary: Add 3.6.0 to broker/client upgrade/compatibility tests
Key: KAFKA-15593
URL: https://issues.apache.org/jira/browse/KAFKA-15593
Project: Kafka
Is
Satish Duggana created KAFKA-15594:
--
Summary: Add 3.6.0 to streams upgrade/compatibility tests
Key: KAFKA-15594
URL: https://issues.apache.org/jira/browse/KAFKA-15594
Project: Kafka
Issue Ty
kamalcph commented on code in PR #14528:
URL: https://github.com/apache/kafka/pull/14528#discussion_r1356064302
##
docs/ops.html:
##
@@ -3984,27 +3984,73 @@ Configurations
Example
+Quick Start
Example
+
+Apache Kafka doesn't provide an out-of-the-box RemoteStorageManager
impl
kamalcph commented on code in PR #14528:
URL: https://github.com/apache/kafka/pull/14528#discussion_r1356064302
##
docs/ops.html:
##
@@ -3984,27 +3984,73 @@ Configurations
Example
+Quick Start
Example
+
+Apache Kafka doesn't provide an out-of-the-box RemoteStorageManager
impl
satishd merged PR #14510:
URL: https://github.com/apache/kafka/pull/14510
--
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.
yashmayya commented on code in PR #14518:
URL: https://github.com/apache/kafka/pull/14518#discussion_r1356053586
##
connect/runtime/src/test/java/org/apache/kafka/connect/storage/MemoryConfigBackingStoreTest.java:
##
@@ -0,0 +1,183 @@
+/*
+ * Licensed to the Apache Software Foun
hanyuzheng7 commented on code in PR #14523:
URL: https://github.com/apache/kafka/pull/14523#discussion_r1356034620
##
streams/src/test/java/org/apache/kafka/streams/integration/IQv2StoreIntegrationTest.java:
##
@@ -863,6 +863,14 @@ private void shouldHandleWindowKeyQueries(fina
hanyuzheng7 commented on code in PR #14523:
URL: https://github.com/apache/kafka/pull/14523#discussion_r1356034620
##
streams/src/test/java/org/apache/kafka/streams/integration/IQv2StoreIntegrationTest.java:
##
@@ -863,6 +863,14 @@ private void shouldHandleWindowKeyQueries(fina
hanyuzheng7 commented on code in PR #14523:
URL: https://github.com/apache/kafka/pull/14523#discussion_r1356034620
##
streams/src/test/java/org/apache/kafka/streams/integration/IQv2StoreIntegrationTest.java:
##
@@ -863,6 +863,14 @@ private void shouldHandleWindowKeyQueries(fina
hanyuzheng7 commented on code in PR #14523:
URL: https://github.com/apache/kafka/pull/14523#discussion_r1356034620
##
streams/src/test/java/org/apache/kafka/streams/integration/IQv2StoreIntegrationTest.java:
##
@@ -863,6 +863,14 @@ private void shouldHandleWindowKeyQueries(fina
hanyuzheng7 commented on code in PR #14523:
URL: https://github.com/apache/kafka/pull/14523#discussion_r1356033429
##
streams/src/test/java/org/apache/kafka/streams/integration/IQv2StoreIntegrationTest.java:
##
@@ -716,7 +716,7 @@ public void process(final Record record) {
hanyuzheng7 commented on code in PR #14523:
URL: https://github.com/apache/kafka/pull/14523#discussion_r1356041608
##
streams/src/test/java/org/apache/kafka/streams/integration/IQv2StoreIntegrationTest.java:
##
@@ -880,25 +888,113 @@ private void shouldHandleWindowKeyQueries(fi
hanyuzheng7 commented on code in PR #14523:
URL: https://github.com/apache/kafka/pull/14523#discussion_r1356044046
##
streams/src/test/java/org/apache/kafka/streams/integration/IQv2StoreIntegrationTest.java:
##
@@ -847,11 +847,11 @@ private void shouldHandleWindowKeyQueries(fin
hanyuzheng7 commented on code in PR #14523:
URL: https://github.com/apache/kafka/pull/14523#discussion_r1356033429
##
streams/src/test/java/org/apache/kafka/streams/integration/IQv2StoreIntegrationTest.java:
##
@@ -716,7 +716,7 @@ public void process(final Record record) {
hanyuzheng7 commented on code in PR #14523:
URL: https://github.com/apache/kafka/pull/14523#discussion_r1356033429
##
streams/src/test/java/org/apache/kafka/streams/integration/IQv2StoreIntegrationTest.java:
##
@@ -716,7 +716,7 @@ public void process(final Record record) {
hanyuzheng7 commented on code in PR #14523:
URL: https://github.com/apache/kafka/pull/14523#discussion_r1356043842
##
streams/src/test/java/org/apache/kafka/streams/integration/IQv2StoreIntegrationTest.java:
##
@@ -413,7 +413,7 @@ public static void before()
hanyuzheng7 commented on code in PR #14523:
URL: https://github.com/apache/kafka/pull/14523#discussion_r1356044046
##
streams/src/test/java/org/apache/kafka/streams/integration/IQv2StoreIntegrationTest.java:
##
@@ -847,11 +847,11 @@ private void shouldHandleWindowKeyQueries(fin
hanyuzheng7 commented on code in PR #14523:
URL: https://github.com/apache/kafka/pull/14523#discussion_r1356043842
##
streams/src/test/java/org/apache/kafka/streams/integration/IQv2StoreIntegrationTest.java:
##
@@ -413,7 +413,7 @@ public static void before()
hanyuzheng7 commented on PR #14523:
URL: https://github.com/apache/kafka/pull/14523#issuecomment-1758892421
> Thanks for extending this test. This is very helpful.
>
> I am wondering, if it would be beneficial to add more input record, such
that a few windows have more than one record
hanyuzheng7 commented on code in PR #14523:
URL: https://github.com/apache/kafka/pull/14523#discussion_r1356042346
##
streams/src/test/java/org/apache/kafka/streams/integration/IQv2StoreIntegrationTest.java:
##
@@ -880,25 +888,113 @@ private void shouldHandleWindowKeyQueries(fi
hanyuzheng7 commented on code in PR #14523:
URL: https://github.com/apache/kafka/pull/14523#discussion_r1356041608
##
streams/src/test/java/org/apache/kafka/streams/integration/IQv2StoreIntegrationTest.java:
##
@@ -880,25 +888,113 @@ private void shouldHandleWindowKeyQueries(fi
hanyuzheng7 commented on code in PR #14523:
URL: https://github.com/apache/kafka/pull/14523#discussion_r1356034620
##
streams/src/test/java/org/apache/kafka/streams/integration/IQv2StoreIntegrationTest.java:
##
@@ -863,6 +863,14 @@ private void shouldHandleWindowKeyQueries(fina
hanyuzheng7 commented on code in PR #14523:
URL: https://github.com/apache/kafka/pull/14523#discussion_r1356033429
##
streams/src/test/java/org/apache/kafka/streams/integration/IQv2StoreIntegrationTest.java:
##
@@ -716,7 +716,7 @@ public void process(final Record record) {
hanyuzheng7 commented on code in PR #14523:
URL: https://github.com/apache/kafka/pull/14523#discussion_r1356033429
##
streams/src/test/java/org/apache/kafka/streams/integration/IQv2StoreIntegrationTest.java:
##
@@ -716,7 +716,7 @@ public void process(final Record record) {
hanyuzheng7 commented on code in PR #14523:
URL: https://github.com/apache/kafka/pull/14523#discussion_r1356033429
##
streams/src/test/java/org/apache/kafka/streams/integration/IQv2StoreIntegrationTest.java:
##
@@ -716,7 +716,7 @@ public void process(final Record record) {
[
https://issues.apache.org/jira/browse/KAFKA-15301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jimmy Wang reassigned KAFKA-15301:
--
Assignee: Jimmy Wang
> [Tiered Storage] Historically compacted topics send request to remote
[
https://issues.apache.org/jira/browse/KAFKA-15592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Philip Nee updated KAFKA-15592:
---
Parent: KAFKA-14048
Issue Type: Sub-task (was: Bug)
> Member does not need to always try to
Philip Nee created KAFKA-15592:
--
Summary: Member does not need to always try to join a group when a
groupId is configured
Key: KAFKA-15592
URL: https://issues.apache.org/jira/browse/KAFKA-15592
Project:
philipnee commented on PR #14532:
URL: https://github.com/apache/kafka/pull/14532#issuecomment-1758856125
@cadonna @mjsax @lucasbru - Any one of you would be interested in reviewing
this PR? I think this is a fairly straightforward patch.
--
This is an automated message from the Apache Gi
showuon merged PR #14484:
URL: https://github.com/apache/kafka/pull/14484
--
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.
philipnee commented on PR #14390:
URL: https://github.com/apache/kafka/pull/14390#issuecomment-1758845137
Hello @dajac @lianetm @kirktrue - I think the scope of this PR extended a
bit beyond "replacing GroupState" because we've realized the member may
join/leave the group anytime during it
showuon commented on PR #14484:
URL: https://github.com/apache/kafka/pull/14484#issuecomment-1758844798
Failed tests 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
mjsax commented on code in PR #14523:
URL: https://github.com/apache/kafka/pull/14523#discussion_r1355991839
##
streams/src/test/java/org/apache/kafka/streams/integration/IQv2StoreIntegrationTest.java:
##
@@ -716,7 +716,7 @@ public void process(final Record record) {
ijuma commented on PR #14533:
URL: https://github.com/apache/kafka/pull/14533#issuecomment-1758815150
Looks like the new version is not in the Maven repo yet. Will remove draft
once that's resolved.
--
This is an automated message from the Apache Git Service.
To respond to the message, pl
ijuma opened a new pull request, #14533:
URL: https://github.com/apache/kafka/pull/14533
Update to spotbugs 4.8.0, changelog:
https://github.com/spotbugs/spotbugs/blob/4.8.0/CHANGELOG.md
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
[
https://issues.apache.org/jira/browse/KAFKA-15492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismael Juma reassigned KAFKA-15492:
---
Assignee: Ismael Juma
> Enable spotbugs when building with Java 21
> --
[
https://issues.apache.org/jira/browse/KAFKA-15388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17774288#comment-17774288
]
Jimmy Wang commented on KAFKA-15388:
Hi [~christo_lolov]Â
I hope you're doing well.
[ https://issues.apache.org/jira/browse/KAFKA-15388 ]
Jimmy Wang deleted comment on KAFKA-15388:
was (Author: JIRAUSER300327):
Hi [~christo_lolov] ,
Have you worked on this issue? If not, I would like to give it a try.
Thanks so much.
> Handl
rbaddam commented on PR #14491:
URL: https://github.com/apache/kafka/pull/14491#issuecomment-1758769891
Hi @mjsax, @jlprat, @satishd, @jolshan, @raboof, @dajac, Would any of you be
available to review this new PR I raised?
Your insights and suggestions would be very helpful.
T
ahuang98 commented on code in PR #14206:
URL: https://github.com/apache/kafka/pull/14206#discussion_r1355932210
##
metadata/src/test/java/org/apache/kafka/metadata/migration/KRaftMigrationDriverTest.java:
##
@@ -627,10 +629,13 @@ public void testTopicDualWriteDelta() throws Exce
ahuang98 commented on code in PR #14206:
URL: https://github.com/apache/kafka/pull/14206#discussion_r1355932210
##
metadata/src/test/java/org/apache/kafka/metadata/migration/KRaftMigrationDriverTest.java:
##
@@ -627,10 +629,13 @@ public void testTopicDualWriteDelta() throws Exce
soarez commented on code in PR #14290:
URL: https://github.com/apache/kafka/pull/14290#discussion_r1355927097
##
generator/src/main/java/org/apache/kafka/message/FieldSpec.java:
##
@@ -157,11 +157,6 @@ private void checkTagInvariants() {
this.taggedVersions
Xi Yang created KAFKA-15591:
---
Summary: Trogdor produce workload reports errors in KRaft mode
Key: KAFKA-15591
URL: https://issues.apache.org/jira/browse/KAFKA-15591
Project: Kafka
Issue Type: Bug
ableegoldman merged PR #14526:
URL: https://github.com/apache/kafka/pull/14526
--
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
[
https://issues.apache.org/jira/browse/KAFKA-15571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman updated KAFKA-15571:
---
Fix Version/s: 3.5.2
3.7.0
3.6.1
> Sta
[
https://issues.apache.org/jira/browse/KAFKA-15571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman resolved KAFKA-15571.
Resolution: Fixed
> StateRestoreListener#onRestoreSuspended is never calle
ableegoldman commented on PR #14519:
URL: https://github.com/apache/kafka/pull/14519#issuecomment-1758665862
Merged to trunk and will backport to 3.6 and 3.5
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL abov
ableegoldman merged PR #14519:
URL: https://github.com/apache/kafka/pull/14519
--
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 #14519:
URL: https://github.com/apache/kafka/pull/14519#issuecomment-1758663469
By the way, make sure to format the PR titles exactly as recommended --
there are some integrations that regex match and rely on this (you had a slash
`/` instead of a colon `:`)
[
https://issues.apache.org/jira/browse/KAFKA-15566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17774251#comment-17774251
]
Justine Olshan edited comment on KAFKA-15566 at 10/11/23 10:24 PM:
---
[
https://issues.apache.org/jira/browse/KAFKA-15566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17774251#comment-17774251
]
Justine Olshan commented on KAFKA-15566:
I closed my ticket. These are not flaky
[
https://issues.apache.org/jira/browse/KAFKA-15589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Justine Olshan resolved KAFKA-15589.
Resolution: Duplicate
Duplicate of https://issues.apache.org/jira/browse/KAFKA-15566
> Fl
jolshan commented on PR #14417:
URL: https://github.com/apache/kafka/pull/14417#issuecomment-1758628495
Disabled the failing tests as this is a known issue:
https://github.com/apache/kafka/pull/14525
--
This is an automated message from the Apache Git Service.
To respond to the messag
jolshan merged PR #14525:
URL: https://github.com/apache/kafka/pull/14525
--
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 PR #14295:
URL: https://github.com/apache/kafka/pull/14295#issuecomment-1758626352
Ah I also filed a JIRA for this. They are not flaky and failing on most
builds. I don't think we should have merged this.
https://issues.apache.org/jira/browse/KAFKA-15589. We should d
[
https://issues.apache.org/jira/browse/KAFKA-15590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Calvin Liu updated KAFKA-15590:
---
Summary: Replica.updateFetchStateOrThrow should also fence updates with
stale leader epoch (was: Re
CalvinConfluent commented on PR #14053:
URL: https://github.com/apache/kafka/pull/14053#issuecomment-1758611548
@splett2 @hachikuji Ticket created
https://issues.apache.org/jira/browse/KAFKA-15590
--
This is an automated message from the Apache Git Service.
To respond to the message, plea
Calvin Liu created KAFKA-15590:
--
Summary: Replica.updateFetchState should also fence updates with
stale leader epoch
Key: KAFKA-15590
URL: https://issues.apache.org/jira/browse/KAFKA-15590
Project: Kafka
philipnee opened a new pull request, #14532:
URL: https://github.com/apache/kafka/pull/14532
Several places in the code, we relies on making a system time call to get
the response time. This is not ideal because these system calls can add up.
Instead, time is already retrieved on the top
imcdo commented on code in PR #14524:
URL: https://github.com/apache/kafka/pull/14524#discussion_r1355750615
##
tests/kafkatest/tests/core/consume_bench_test.py:
##
@@ -44,7 +44,6 @@ def setUp(self):
self.trogdor.start()
if self.zk:
self.zk.start()
Justine Olshan created KAFKA-15589:
--
Summary: Flaky kafka.server.FetchRequestTest
Key: KAFKA-15589
URL: https://issues.apache.org/jira/browse/KAFKA-15589
Project: Kafka
Issue Type: Task
jolshan commented on PR #14417:
URL: https://github.com/apache/kafka/pull/14417#issuecomment-1758474606
I also filed: https://issues.apache.org/jira/browse/KAFKA-15589
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use th
jolshan commented on PR #14417:
URL: https://github.com/apache/kafka/pull/14417#issuecomment-1758466564
AK builds have not been happy lately :(
--
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
jimbogithub commented on PR #14531:
URL: https://github.com/apache/kafka/pull/14531#issuecomment-1758458826
See https://issues.apache.org/jira/browse/KAFKA-14546 for rationale.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub a
jimbogithub opened a new pull request, #14531:
URL: https://github.com/apache/kafka/pull/14531
Allow custom Partitioners to fallback to default partitioning.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL abov
mjsax commented on PR #14527:
URL: https://github.com/apache/kafka/pull/14527#issuecomment-1758413129
Seems this does not cover KS -- btw: there is some issue for KS system tests
right now, and as a matter of fact, we did not even add the missing upgrade
tests in older release yet (PR is st
rreddy-22 commented on code in PR #14524:
URL: https://github.com/apache/kafka/pull/14524#discussion_r1355666083
##
tests/kafkatest/tests/core/consume_bench_test.py:
##
@@ -68,12 +67,21 @@ def produce_messages(self, topics, max_messages=1):
self.logger.debug("Produc
rreddy-22 commented on code in PR #14524:
URL: https://github.com/apache/kafka/pull/14524#discussion_r1355663593
##
tests/kafkatest/tests/core/consume_bench_test.py:
##
@@ -68,12 +67,21 @@ def produce_messages(self, topics, max_messages=1):
self.logger.debug("Produc
rreddy-22 commented on code in PR #14524:
URL: https://github.com/apache/kafka/pull/14524#discussion_r1355653216
##
tests/kafkatest/services/kafka/kafka.py:
##
@@ -764,6 +769,9 @@ def prop_file(self, node):
else:
override_configs[config_property.ZOO
rreddy-22 commented on code in PR #14524:
URL: https://github.com/apache/kafka/pull/14524#discussion_r1355652198
##
tests/kafkatest/services/kafka/kafka.py:
##
@@ -407,6 +411,7 @@ def __init__(self, context, num_nodes, zk,
security_protocol=SecurityConfig.PLAI
kraf
[
https://issues.apache.org/jira/browse/KAFKA-15588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Philip Nee updated KAFKA-15588:
---
Labels: kip-848 kip-848-client-support kip-848-e2e (was: )
> Purge the unsent offset commits/fetche
[
https://issues.apache.org/jira/browse/KAFKA-15588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Philip Nee updated KAFKA-15588:
---
Parent: KAFKA-14048
Issue Type: Sub-task (was: Bug)
> Purge the unsent offset commits/fetch
Philip Nee created KAFKA-15588:
--
Summary: Purge the unsent offset commits/fetches when the member
is fenced
Key: KAFKA-15588
URL: https://issues.apache.org/jira/browse/KAFKA-15588
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-14546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17774202#comment-17774202
]
James Olsen edited comment on KAFKA-14546 at 10/11/23 7:11 PM:
---
[
https://issues.apache.org/jira/browse/KAFKA-14546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17774202#comment-17774202
]
James Olsen edited comment on KAFKA-14546 at 10/11/23 7:09 PM:
---
[
https://issues.apache.org/jira/browse/KAFKA-14546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17774202#comment-17774202
]
James Olsen commented on KAFKA-14546:
-
I'm still hoping for a solution to this issue
imcdo commented on code in PR #14524:
URL: https://github.com/apache/kafka/pull/14524#discussion_r1355617795
##
tests/kafkatest/tests/core/consume_bench_test.py:
##
@@ -68,12 +67,21 @@ def produce_messages(self, topics, max_messages=1):
self.logger.debug("Produce wo
imcdo commented on code in PR #14524:
URL: https://github.com/apache/kafka/pull/14524#discussion_r1355617795
##
tests/kafkatest/tests/core/consume_bench_test.py:
##
@@ -68,12 +67,21 @@ def produce_messages(self, topics, max_messages=1):
self.logger.debug("Produce wo
imcdo commented on code in PR #14524:
URL: https://github.com/apache/kafka/pull/14524#discussion_r1355435960
##
tests/kafkatest/services/kafka/config.py:
##
@@ -28,7 +28,8 @@ class KafkaConfig(dict):
config_property.METADATA_LOG_SEGMENT_BYTES: str(9*1024*1024), # 9 MB
imcdo commented on code in PR #14524:
URL: https://github.com/apache/kafka/pull/14524#discussion_r1355605756
##
tests/kafkatest/tests/core/consume_bench_test.py:
##
@@ -68,12 +67,21 @@ def produce_messages(self, topics, max_messages=1):
self.logger.debug("Produce wo
jeffkbkim commented on code in PR #14417:
URL: https://github.com/apache/kafka/pull/14417#discussion_r1355561775
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/runtime/CoordinatorRuntime.java:
##
@@ -709,6 +727,16 @@ public void complete(Throwable exceptio
Jeff Kim created KAFKA-15587:
Summary: Limit the number of records per batch in
GroupCoordinatorShard#cleanupGroupMetadata
Key: KAFKA-15587
URL: https://issues.apache.org/jira/browse/KAFKA-15587
Project:
ijuma commented on code in PR #14502:
URL: https://github.com/apache/kafka/pull/14502#discussion_r1355560355
##
gradlew:
##
@@ -214,11 +215,11 @@ fi
# Add default JVM options here. You can also use JAVA_OPTS and GRADLE_OPTS to
pass JVM options to this script.
DEFAULT_JVM_OPTS
jeffkbkim commented on PR #14467:
URL: https://github.com/apache/kafka/pull/14467#issuecomment-1758248999
created https://issues.apache.org/jira/browse/KAFKA-15587
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
UR
C0urante commented on code in PR #14518:
URL: https://github.com/apache/kafka/pull/14518#discussion_r1355538647
##
connect/runtime/src/test/java/org/apache/kafka/connect/storage/MemoryConfigBackingStoreTest.java:
##
@@ -0,0 +1,183 @@
+/*
+ * Licensed to the Apache Software Found
ijuma closed pull request #14530: MINOR: Upgrade gradle to 8.4
URL: https://github.com/apache/kafka/pull/14530
--
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
ijuma commented on PR #14530:
URL: https://github.com/apache/kafka/pull/14530#issuecomment-1758243845
I missed that. We can close 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 to the specifi
Calvin Liu created KAFKA-15586:
--
Summary: Clean shutdown detection, server side
Key: KAFKA-15586
URL: https://issues.apache.org/jira/browse/KAFKA-15586
Project: Kafka
Issue Type: Sub-task
Calvin Liu created KAFKA-15585:
--
Summary: DescribeTopic API
Key: KAFKA-15585
URL: https://issues.apache.org/jira/browse/KAFKA-15585
Project: Kafka
Issue Type: Sub-task
Reporter: Calv
Calvin Liu created KAFKA-15584:
--
Summary: ELR leader election
Key: KAFKA-15584
URL: https://issues.apache.org/jira/browse/KAFKA-15584
Project: Kafka
Issue Type: Sub-task
Reporter: Ca
1 - 100 of 193 matches
Mail list logo
