[
https://issues.apache.org/jira/browse/KAFKA-16222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Manikumar updated KAFKA-16222:
--
Fix Version/s: 3.6.2
3.8.0
3.7.1
> KRaft Migration: Incorrect
[
https://issues.apache.org/jira/browse/KAFKA-16073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Manikumar updated KAFKA-16073:
--
Fix Version/s: 3.7.1
> Kafka Tiered Storage: Consumer Fetch Error Due to Delayed localLogStartOffset
omkreddy commented on PR #15481:
URL: https://github.com/apache/kafka/pull/15481#issuecomment-2005776638
I am including this to 3.6.2 release plan
--
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
[
https://issues.apache.org/jira/browse/KAFKA-13361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17828150#comment-17828150
]
Cheng-Kai, Zhang edited comment on KAFKA-13361 at 3/19/24 4:05 AM:
---
Hi
Peter created KAFKA-16384:
-
Summary: KRaft controller number recommendation
Key: KAFKA-16384
URL: https://issues.apache.org/jira/browse/KAFKA-16384
Project: Kafka
Issue Type: Bug
gaoran10 commented on code in PR #13516:
URL: https://github.com/apache/kafka/pull/13516#discussion_r1529639335
##
examples/src/main/java/kafka/examples/ExactlyOnceMessageProcessor.java:
##
@@ -81,111 +88,115 @@ public ExactlyOnceMessageProcessor(final String
inputTopic,
gaoran10 commented on code in PR #13516:
URL: https://github.com/apache/kafka/pull/13516#discussion_r1529639335
##
examples/src/main/java/kafka/examples/ExactlyOnceMessageProcessor.java:
##
@@ -81,111 +88,115 @@ public ExactlyOnceMessageProcessor(final String
inputTopic,
showuon commented on PR #15481:
URL: https://github.com/apache/kafka/pull/15481#issuecomment-2005672241
Re-triggering the CI build.
--
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-13361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17828150#comment-17828150
]
Cheng-Kai, Zhang commented on KAFKA-13361:
--
Hi [~dongjin] [~mimaison]
I am interested to this
jolshan merged PR #15524:
URL: https://github.com/apache/kafka/pull/15524
--
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:
jolshan commented on PR #15524:
URL: https://github.com/apache/kafka/pull/15524#issuecomment-2005610376
I am seeing it fail more often on your branch (for a few runs), but after
merging with trunk, it seemed better. I will go ahead and merge.
--
This is an automated message from the
jolshan commented on code in PR #15533:
URL: https://github.com/apache/kafka/pull/15533#discussion_r1529489216
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java:
##
@@ -1904,16 +2000,7 @@ public void testReconciliationProcess()
jolshan commented on code in PR #15533:
URL: https://github.com/apache/kafka/pull/15533#discussion_r1529486638
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java:
##
@@ -1190,10 +1190,11 @@ private
CoordinatorResult consumerGr
jeffkbkim commented on PR #15533:
URL: https://github.com/apache/kafka/pull/15533#issuecomment-2005338241
> This patch changes the logic to check ownedTopicPartitions,
subscribedTopicNames and rebalanceTimeoutMs as they are the only three non
optional fields.
They are the only three
[
https://issues.apache.org/jira/browse/KAFKA-14359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Justine Olshan reassigned KAFKA-14359:
--
Assignee: Justine Olshan
> Idempotent Producer continues to retry on
CalvinConfluent commented on PR #14706:
URL: https://github.com/apache/kafka/pull/14706#issuecomment-2005099068
The test failures are irrelevant.
--
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
chia7712 commented on code in PR #15556:
URL: https://github.com/apache/kafka/pull/15556#discussion_r1529285548
##
connect/runtime/src/test/java/org/apache/kafka/connect/integration/ConnectorValidationIntegrationTest.java:
##
@@ -460,7 +460,7 @@ public static abstract class
jolshan commented on PR #15524:
URL: https://github.com/apache/kafka/pull/15524#issuecomment-2004976461
I ran "until failure" on trunk and it took about 30 runs to fail.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
dongnuo123 commented on code in PR #15411:
URL: https://github.com/apache/kafka/pull/15411#discussion_r1529263591
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupProtocolMigrationConfig.java:
##
@@ -0,0 +1,68 @@
+/*
+ * Licensed to the Apache Software
artemlivshits commented on PR #15524:
URL: https://github.com/apache/kafka/pull/15524#issuecomment-2004953080
LogDirFailureTest passed locally as well (probably just a flake) and it
doesn't seem to use any of the code that I touched, so unrelated.
--
This is an automated message from the
kirktrue commented on code in PR #14675:
URL: https://github.com/apache/kafka/pull/14675#discussion_r1529229638
##
core/src/test/scala/integration/kafka/api/ConsumerBounceTest.scala:
##
@@ -89,6 +96,8 @@ class ConsumerBounceTest extends AbstractConsumerTest with
Logging {
[
https://issues.apache.org/jira/browse/KAFKA-16217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17828089#comment-17828089
]
Kirk True commented on KAFKA-16217:
---
[~calvinliu]—I reassigned this to you as you've already started
[
https://issues.apache.org/jira/browse/KAFKA-16217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-16217:
-
Assignee: Calvin Liu (was: Kirk True)
> Transactional producer stuck in IllegalStateException
kirktrue commented on PR #15541:
URL: https://github.com/apache/kafka/pull/15541#issuecomment-2004890051
@CalvinConfluent—thanks for the PR!
This PR doesn't have any unit tests to verify the new behavior. Would it be
possible to migrate the test case from your _other PR_ (#15336) to
jeffkbkim commented on code in PR #15534:
URL: https://github.com/apache/kafka/pull/15534#discussion_r1529191724
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/runtime/CoordinatorRuntime.java:
##
@@ -1191,30 +1212,37 @@ public void onHighWatermarkUpdated(
wernerdv opened a new pull request, #15558:
URL: https://github.com/apache/kafka/pull/15558
Log the list of topics for which an authorization error has been received
when try to describe configs, along with the cluster alias.
### Committer Checklist (excluded from commit message)
jsancio merged PR #15478:
URL: https://github.com/apache/kafka/pull/15478
--
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:
kirktrue commented on code in PR #15475:
URL: https://github.com/apache/kafka/pull/15475#discussion_r1529074359
##
clients/src/main/java/org/apache/kafka/common/config/SaslConfigs.java:
##
@@ -192,6 +192,12 @@ public class SaslConfigs {
+ " be inspected for the
junrao commented on code in PR #14903:
URL: https://github.com/apache/kafka/pull/14903#discussion_r1526788841
##
core/src/main/scala/kafka/server/BrokerLifecycleManager.scala:
##
@@ -551,9 +580,11 @@ class BrokerLifecycleManager(
}
private def
[
https://issues.apache.org/jira/browse/KAFKA-15282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17828075#comment-17828075
]
Kirk True commented on KAFKA-15282:
---
[~zxcoccer]—you're certainly welcome to look at this. I would
clolov commented on code in PR #15254:
URL: https://github.com/apache/kafka/pull/15254#discussion_r1529018575
##
streams/src/test/java/org/apache/kafka/streams/processor/internals/TaskManagerTest.java:
##
@@ -190,7 +181,7 @@ public class TaskManagerTest {
jolshan commented on PR #15524:
URL: https://github.com/apache/kafka/pull/15524#issuecomment-2004586672
@artemlivshits it may be worth checking if the test is failing on trunk as
well. If so we can renew the JIRA to fix it
--
This is an automated message from the Apache Git Service.
edoardocomar commented on PR #15530:
URL: https://github.com/apache/kafka/pull/15530#issuecomment-2004581473
fix cherry picked to 3.6 and 3.7 branches
--
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
[
https://issues.apache.org/jira/browse/KAFKA-16369?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17828067#comment-17828067
]
Edoardo Comar commented on KAFKA-16369:
---
fix cherry picked to 3.6 and 3.7
> Broker may not shut
jolshan commented on PR #15524:
URL: https://github.com/apache/kafka/pull/15524#issuecomment-2004580064
> LogDirFailureTest > testIOExceptionDuringLogRoll(String) has been failing
for a while -- there are some issues I tried to tackle with respect to it, but
we ran into some issues. See
dongnuo123 commented on code in PR #15546:
URL: https://github.com/apache/kafka/pull/15546#discussion_r1529010875
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java:
##
@@ -9298,6 +9298,120 @@ public void
jolshan commented on code in PR #15486:
URL: https://github.com/apache/kafka/pull/15486#discussion_r1529005304
##
core/src/test/scala/unit/kafka/server/ReplicaManagerTest.scala:
##
@@ -3040,6 +3048,7 @@ class ReplicaManagerTest {
transactionalId = transactionalId,
jolshan commented on code in PR #15486:
URL: https://github.com/apache/kafka/pull/15486#discussion_r1528996611
##
clients/src/test/java/org/apache/kafka/clients/producer/internals/TransactionManagerTest.java:
##
@@ -3523,6 +3524,128 @@ public void
jolshan commented on code in PR #15486:
URL: https://github.com/apache/kafka/pull/15486#discussion_r1528996611
##
clients/src/test/java/org/apache/kafka/clients/producer/internals/TransactionManagerTest.java:
##
@@ -3523,6 +3524,128 @@ public void
jolshan commented on PR #15486:
URL: https://github.com/apache/kafka/pull/15486#issuecomment-2004546341
Hey @sjhajharia thanks for the updates. I think `ApiVersionErrorMapper` is
also a bit tricky since the addPartitions change will not be related to errors
at all. That's why I was
wcarlson5 commented on PR #15414:
URL: https://github.com/apache/kafka/pull/15414#issuecomment-2004539886
@mjsax I added some testing
--
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
fvaleri commented on code in PR #15273:
URL: https://github.com/apache/kafka/pull/15273#discussion_r1471706520
##
raft/src/main/java/org/apache/kafka/raft/RaftConfig.java:
##
@@ -206,6 +245,27 @@ private static Integer parseVoterId(String idString) {
}
}
+
[
https://issues.apache.org/jira/browse/KAFKA-16297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Igor Soarez updated KAFKA-16297:
Description:
KIP-858 proposed that when a directory failure occurs after changing the
assignment
[
https://issues.apache.org/jira/browse/KAFKA-16363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Igor Soarez reassigned KAFKA-16363:
---
Assignee: (was: Igor Soarez)
> Storage crashes if dir is unavailable
>
fvaleri commented on code in PR #13516:
URL: https://github.com/apache/kafka/pull/13516#discussion_r1528843407
##
examples/src/main/java/kafka/examples/ExactlyOnceMessageProcessor.java:
##
@@ -81,111 +88,115 @@ public ExactlyOnceMessageProcessor(final String
inputTopic,
wcarlson5 commented on code in PR #15414:
URL: https://github.com/apache/kafka/pull/15414#discussion_r1528822628
##
streams/src/test/java/org/apache/kafka/streams/integration/GlobalStateReprocessTest.java:
##
@@ -0,0 +1,205 @@
+/*
+ * Licensed to the Apache Software Foundation
wcarlson5 commented on code in PR #15414:
URL: https://github.com/apache/kafka/pull/15414#discussion_r1528810589
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateManagerImpl.java:
##
@@ -236,6 +252,91 @@ private List topicPartitionsForStore(final
wcarlson5 commented on code in PR #15414:
URL: https://github.com/apache/kafka/pull/15414#discussion_r1528807717
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordDeserializer.java:
##
@@ -68,40 +68,49 @@ ConsumerRecord deserialize(final
lianetm commented on code in PR #15533:
URL: https://github.com/apache/kafka/pull/15533#discussion_r1528798734
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java:
##
@@ -1650,6 +1650,102 @@ public void
lianetm commented on code in PR #15533:
URL: https://github.com/apache/kafka/pull/15533#discussion_r1528793006
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java:
##
@@ -1190,10 +1190,11 @@ private
CoordinatorResult consumerGr
gaoran10 commented on code in PR #13516:
URL: https://github.com/apache/kafka/pull/13516#discussion_r1528650747
##
examples/src/main/java/kafka/examples/ExactlyOnceMessageProcessor.java:
##
@@ -81,111 +88,115 @@ public ExactlyOnceMessageProcessor(final String
inputTopic,
[
https://issues.apache.org/jira/browse/KAFKA-16375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans updated KAFKA-16375:
---
Labels: client-transitions-issues kip-848-client-support (was:
kip-848-client-support)
>
gaoran10 commented on code in PR #13516:
URL: https://github.com/apache/kafka/pull/13516#discussion_r1528650747
##
examples/src/main/java/kafka/examples/ExactlyOnceMessageProcessor.java:
##
@@ -81,111 +88,115 @@ public ExactlyOnceMessageProcessor(final String
inputTopic,
gaoran10 commented on code in PR #13516:
URL: https://github.com/apache/kafka/pull/13516#discussion_r1528650747
##
examples/src/main/java/kafka/examples/ExactlyOnceMessageProcessor.java:
##
@@ -81,111 +88,115 @@ public ExactlyOnceMessageProcessor(final String
inputTopic,
[
https://issues.apache.org/jira/browse/KAFKA-15517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dmitry Werner reassigned KAFKA-15517:
-
Assignee: Dmitry Werner
> Improve MirrorMaker logging in case of authorization errors
[
https://issues.apache.org/jira/browse/KAFKA-15551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17827990#comment-17827990
]
Lianet Magrans commented on KAFKA-15551:
Also, given how tight the deadline is to get the fix/PR
[
https://issues.apache.org/jira/browse/KAFKA-15551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17827989#comment-17827989
]
Lianet Magrans commented on KAFKA-15551:
Hey [~zxcoccer], thanks for jumping in! This one should
cadonna commented on code in PR #15254:
URL: https://github.com/apache/kafka/pull/15254#discussion_r1528601954
##
streams/src/test/java/org/apache/kafka/streams/processor/internals/TaskManagerTest.java:
##
@@ -190,7 +181,7 @@ public class TaskManagerTest {
[
https://issues.apache.org/jira/browse/KAFKA-16369?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17827976#comment-17827976
]
Edoardo Comar commented on KAFKA-16369:
---
fix merged in trunk thanks [~showuon]
> Broker may not
[
https://issues.apache.org/jira/browse/KAFKA-16369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Edoardo Comar updated KAFKA-16369:
--
Fix Version/s: 3.8.0
> Broker may not shut down when SocketServer fails to bind as Address
[
https://issues.apache.org/jira/browse/KAFKA-16369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Edoardo Comar updated KAFKA-16369:
--
Fix Version/s: 3.6.2
3.7.1
> Broker may not shut down when SocketServer
johnnychhsu opened a new pull request, #15556:
URL: https://github.com/apache/kafka/pull/15556
## Context
This test failed in several PR, and from one of the failed build, there was
an error log
```
[2024-03-12 13:58:12,744] ERROR Failed to discover HeaderConverter in
classpath:
ijuma commented on code in PR #15254:
URL: https://github.com/apache/kafka/pull/15254#discussion_r1528552125
##
streams/src/test/java/org/apache/kafka/streams/processor/internals/TaskManagerTest.java:
##
@@ -190,7 +181,7 @@ public class TaskManagerTest {
Johnny Hsu created KAFKA-16383:
--
Summary: fix flaky test
IdentityReplicationIntegrationTest.testReplicateFromLatest()
Key: KAFKA-16383
URL: https://issues.apache.org/jira/browse/KAFKA-16383
Project:
lianetm closed pull request #15535: [WIP] Splitting consumer tests
URL: https://github.com/apache/kafka/pull/15535
--
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
[
https://issues.apache.org/jira/browse/KAFKA-15951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17827968#comment-17827968
]
sanghyeok An commented on KAFKA-15951:
--
Hi, [~mjsax] !
May i take this issue and work for it?
I
KevinZTW opened a new pull request, #1:
URL: https://github.com/apache/kafka/pull/1
KIP:
https://cwiki.apache.org/confluence/display/KAFKA/KIP-780%3A+Support+fine-grained+compression+options#KIP780:Supportfinegrainedcompressionoptions-Producer
*More detailed description of
johnnychhsu commented on code in PR #15483:
URL: https://github.com/apache/kafka/pull/15483#discussion_r1528503006
##
clients/src/main/java/org/apache/kafka/common/metrics/KafkaMetric.java:
##
@@ -78,6 +111,10 @@ public Measurable measurable() {
}
}
+/**
+
johnnychhsu commented on code in PR #15476:
URL: https://github.com/apache/kafka/pull/15476#discussion_r1528497039
##
core/src/test/scala/integration/kafka/admin/ListOffsetsIntegrationTest.scala:
##
@@ -79,9 +79,34 @@ class ListOffsetsIntegrationTest extends
Vaibhav-Nazare commented on PR #13817:
URL: https://github.com/apache/kafka/pull/13817#issuecomment-2003833677
Hi @mimaison additional jenkinsfile for ppc64le has been added , also as per
my understanding some changes would be required at
https://ci-builds.apache.org/job/Kafka/job/kafka/
johnnychhsu commented on code in PR #15476:
URL: https://github.com/apache/kafka/pull/15476#discussion_r1528477660
##
core/src/test/scala/integration/kafka/admin/ListOffsetsIntegrationTest.scala:
##
@@ -79,9 +79,34 @@ class ListOffsetsIntegrationTest extends
[
https://issues.apache.org/jira/browse/KAFKA-15538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17827950#comment-17827950
]
Phuc Hong Tran commented on KAFKA-15538:
[~lianetm] [~kirktrue], I have a question. What
clolov commented on code in PR #15254:
URL: https://github.com/apache/kafka/pull/15254#discussion_r1528403432
##
streams/src/test/java/org/apache/kafka/streams/processor/internals/TaskManagerTest.java:
##
@@ -785,7 +776,6 @@ public void
clolov commented on PR #15254:
URL: https://github.com/apache/kafka/pull/15254#issuecomment-2003726516
Heya @cadonna! This should be rebased, tests ought to be passing and all
comments are addressed . Let me know if there is something else you would
suggest improving!
--
This is an
clolov commented on PR #14788:
URL: https://github.com/apache/kafka/pull/14788#issuecomment-2003676807
Closing this in favour of https://issues.apache.org/jira/browse/KAFKA-15857
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
clolov closed pull request #14788: MINOR: Expose earliest local timestamp via
the GetOffsetShell
URL: https://github.com/apache/kafka/pull/14788
--
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
[
https://issues.apache.org/jira/browse/KAFKA-16322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17827933#comment-17827933
]
Chia-Ping Tsai commented on KAFKA-16322:
[~omkreddy] thanks for backporting this.
> Fix
jlprat commented on PR #15553:
URL: https://github.com/apache/kafka/pull/15553#issuecomment-2003653879
I managed to reproduce the issue with Gradle 8.6 once, but now that I'm
trying to reproduce it again, it seems that incremental compilation works as
expected (I tried it on `trunk` and
jlprat commented on code in PR #15404:
URL: https://github.com/apache/kafka/pull/15404#discussion_r1528355399
##
gradle/dependencies.gradle:
##
@@ -100,10 +100,10 @@ versions += [
commonsCli: "1.4",
commonsValidator: "1.7",
dropwizardMetrics: "4.1.12.1",
- gradle:
omkreddy opened a new pull request, #15554:
URL: https://github.com/apache/kafka/pull/15554
(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 unsubscribe,
lucasbru merged PR #15511:
URL: https://github.com/apache/kafka/pull/15511
--
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:
VictorvandenHoven commented on code in PR #15510:
URL: https://github.com/apache/kafka/pull/15510#discussion_r1527973416
##
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamJoin.java:
##
@@ -223,57 +224,51 @@ private void emitNonJoinedOuterRecords(
VictorvandenHoven commented on code in PR #15510:
URL: https://github.com/apache/kafka/pull/15510#discussion_r1527968309
##
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamOuterJoinTest.java:
##
@@ -727,7 +801,7 @@ public void testWindowing() {
VictorvandenHoven commented on code in PR #15510:
URL: https://github.com/apache/kafka/pull/15510#discussion_r1528271251
##
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamOuterJoinTest.java:
##
@@ -511,14 +511,88 @@ public void testGracePeriod()
VictorvandenHoven commented on code in PR #15510:
URL: https://github.com/apache/kafka/pull/15510#discussion_r1528270350
##
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamOuterJoinTest.java:
##
@@ -511,14 +511,88 @@ public void testGracePeriod()
[
https://issues.apache.org/jira/browse/KAFKA-16272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-16272:
-
Assignee: Sagar Rao
> Update connect_distributed_test.py to support KIP-848’s group protocol
edoardocomar commented on PR #15530:
URL: https://github.com/apache/kafka/pull/15530#issuecomment-2003461536
thanks @showuon !
--
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
edoardocomar merged PR #15530:
URL: https://github.com/apache/kafka/pull/15530
--
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:
edoardocomar commented on code in PR #15530:
URL: https://github.com/apache/kafka/pull/15530#discussion_r1528223058
##
core/src/test/scala/unit/kafka/server/KafkaServerTest.scala:
##
@@ -42,6 +43,24 @@ class KafkaServerTest extends QuorumTestHarness {
showuon commented on code in PR #15476:
URL: https://github.com/apache/kafka/pull/15476#discussion_r1528195441
##
core/src/test/scala/integration/kafka/admin/ListOffsetsIntegrationTest.scala:
##
@@ -79,9 +79,34 @@ class ListOffsetsIntegrationTest extends
KafkaServerTestHarness
omkreddy commented on PR #15141:
URL: https://github.com/apache/kafka/pull/15141#issuecomment-2003349984
If we want this to be 3.6.2 release, we need to merge the PR in next couple
of days.
--
This is an automated message from the Apache Git Service.
To respond to the message, please
[
https://issues.apache.org/jira/browse/KAFKA-16322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Manikumar updated KAFKA-16322:
--
Fix Version/s: 3.7.1
> Fix CVE-2023-50572 by updating jline from 3.22.0 to 3.25.1
>
[
https://issues.apache.org/jira/browse/KAFKA-16322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Manikumar updated KAFKA-16322:
--
Fix Version/s: 3.6.2
> Fix CVE-2023-50572 by updating jline from 3.22.0 to 3.25.1
>
[
https://issues.apache.org/jira/browse/KAFKA-16210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Manikumar updated KAFKA-16210:
--
Fix Version/s: 3.6.2
> Upgrade jose4j to 0.9.4
> ---
>
> Key:
Stanislav Spiridonov created KAFKA-16382:
Summary: Kafka Streams drop NULL values after reset
Key: KAFKA-16382
URL: https://issues.apache.org/jira/browse/KAFKA-16382
Project: Kafka
jlprat commented on PR #15553:
URL: https://github.com/apache/kafka/pull/15553#issuecomment-2003177508
I accidentally committed the `core/data` files from some failed test run.
@dajac feel free to review now. Thanks!
--
This is an automated message from the Apache Git Service.
To
jlprat commented on PR #15553:
URL: https://github.com/apache/kafka/pull/15553#issuecomment-2003170494
Oops, you are right @dajac I don't know what happened. I'll check
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
dajac commented on PR #15553:
URL: https://github.com/apache/kafka/pull/15553#issuecomment-2003168800
@jlprat Thanks for the PR. It looks like the PR contains unwanted files.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
jlprat commented on code in PR #15404:
URL: https://github.com/apache/kafka/pull/15404#discussion_r1528029938
##
gradle/dependencies.gradle:
##
@@ -100,10 +100,10 @@ versions += [
commonsCli: "1.4",
commonsValidator: "1.7",
dropwizardMetrics: "4.1.12.1",
- gradle:
jlprat opened a new pull request, #15553:
URL: https://github.com/apache/kafka/pull/15553
Rollback to Gradle 8.5.
When upgrading to Gradle 8.6, Scala incremental compilation seems to be
broken. See https://github.com/apache/kafka/pull/15404#discussion_r1526739190
### Committer
1 - 100 of 113 matches
Mail list logo
