sjhajharia commented on code in PR #15486:
URL: https://github.com/apache/kafka/pull/15486#discussion_r1529794514
##
core/src/test/scala/unit/kafka/server/ReplicaManagerTest.scala:
##
@@ -3040,6 +3048,7 @@ class ReplicaManagerTest {
transactionalId = transactionalId,
sjhajharia commented on code in PR #15486:
URL: https://github.com/apache/kafka/pull/15486#discussion_r1529793846
##
clients/src/test/java/org/apache/kafka/clients/producer/internals/TransactionManagerTest.java:
##
@@ -3523,6 +3524,128 @@ public void
testForegroundInvalidStateT
chia7712 commented on PR #15476:
URL: https://github.com/apache/kafka/pull/15476#issuecomment-2005884703
I have rebase the PR to trigger QA again, and I will merge it if no related
failed tests.
--
This is an automated message from the Apache Git Service.
To respond to the message, please
[
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 de
[
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&focusedCommentId=17828150#comment-17828150
]
Cheng-Kai, Zhang edited comment on KAFKA-13361 at 3/19/24 4:05 AM:
---
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
Components
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 co
[
https://issues.apache.org/jira/browse/KAFKA-13361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17828150#comment-17828150
]
Cheng-Kai, Zhang commented on KAFKA-13361:
--
Hi [~dongjin] [~mimaison]
I am in
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: jira-unsubscr...@kafka.apache.
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 Apach
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 OutOfOrderSequen
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 Abst
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&focusedCommentId=17828089#comment-17828089
]
Kirk True commented on KAFKA-16217:
---
[~calvinliu]—I reassigned this to you as you've a
[
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: jira-unsubscr...@kafka.apache.
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 stan
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 scheduleNextCommunication(i
[
https://issues.apache.org/jira/browse/KAFKA-15282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17828075#comment-17828075
]
Kirk True commented on KAFKA-15282:
---
[~zxcoccer]—you're certainly welcome to look at t
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 {
@org.mockito.Moc
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.
To
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 go
[
https://issues.apache.org/jira/browse/KAFKA-16369?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17828067#comment-17828067
]
Edoardo Comar commented on KAFKA-16369:
---
fix cherry picked to 3.6 and 3.7
> Broke
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 ht
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
testOnConsumerGroupState
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
testForegroundInvalidStateTran
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
testForegroundInvalidStateTran
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 thinking
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) {
}
}
+pri
[
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
ProcessorConte
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
testShouldThrowFencedInstan
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)
> F
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&focusedCommentId=17827990#comment-17827990
]
Lianet Magrans commented on KAFKA-15551:
Also, given how tight the deadline is t
[
https://issues.apache.org/jira/browse/KAFKA-15551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17827989#comment-17827989
]
Lianet Magrans commented on KAFKA-15551:
Hey [~zxcoccer], thanks for jumping in!
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 {
@org.mockito.Mo
[
https://issues.apache.org/jira/browse/KAFKA-16369?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17827976#comment-17827976
]
Edoardo Comar commented on KAFKA-16369:
---
fix merged in trunk thanks [~showuon]
>
[
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 alr
[
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 fai
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: Un
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 {
@org.mockito.Mock
Johnny Hsu created KAFKA-16383:
--
Summary: fix flaky test
IdentityReplicationIntegrationTest.testReplicateFromLatest()
Key: KAFKA-16383
URL: https://issues.apache.org/jira/browse/KAFKA-16383
Project: Kafk
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 unsubscrib
[
https://issues.apache.org/jira/browse/KAFKA-15951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17827968#comment-17827968
]
sanghyeok An commented on KAFKA-15951:
--
Hi, [~mjsax] !
May i take this issue and w
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 you
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
KafkaServerTestHarn
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/ to
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
KafkaServerTestHarn
[
https://issues.apache.org/jira/browse/KAFKA-15538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17827950#comment-17827950
]
Phuc Hong Tran commented on KAFKA-15538:
[~lianetm] [~kirktrue], I have a questi
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 shouldNotReturnStateUpdaterTasksInOwnedTas
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 auto
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 GitHub
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 s
[
https://issues.apache.org/jira/browse/KAFKA-16322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17827933#comment-17827933
]
Chia-Ping Tsai commented on KAFKA-16322:
[~omkreddy] thanks for backporting this
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 mod
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: "8.5
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, e-m
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: jira-unsubscr...@kafka.apache
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 co
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 comment
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: jira-unsubscr...@kafka.ap
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 {
TestUtils.shutdownServ
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 log
[
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: KAFK
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
Is
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 respon
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 t
1 - 100 of 114 matches
Mail list logo
