[
https://issues.apache.org/jira/browse/KAFKA-14184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17642351#comment-17642351
]
Matthias J. Sax commented on KAFKA-14184:
-
Thanks for the update. – It's hard to
cmccabe merged PR #12837:
URL: https://github.com/apache/kafka/pull/12837
--
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-14400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17642353#comment-17642353
]
Matthias J. Sax commented on KAFKA-14400:
-
{quote}Am I correct that when one +LA
[
https://issues.apache.org/jira/browse/KAFKA-14400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17642366#comment-17642366
]
Victor van den Hoven commented on KAFKA-14400:
--
Thank you for answering my
[
https://issues.apache.org/jira/browse/KAFKA-14400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Victor van den Hoven resolved KAFKA-14400.
--
Resolution: Not A Bug
It behaves differently because stream-stram-leftjoin sem
[
https://issues.apache.org/jira/browse/KAFKA-14374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17642374#comment-17642374
]
Youcef Sebiat commented on KAFKA-14374:
---
Thanks for the response.
1.
{quote}Did y
divijvaidya commented on PR #12933:
URL: https://github.com/apache/kafka/pull/12933#issuecomment-1335021913
@mimaison please take a look when you get a chance.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL ab
divijvaidya commented on PR #12940:
URL: https://github.com/apache/kafka/pull/12940#issuecomment-1335028608
The build is failing with:
```
[2022-12-01T20:35:07.343Z] FAILURE: Build completed with 2 failures.
[2022-12-01T20:35:07.343Z]
[2022-12-01T20:35:07.343Z] 1: Task fa
[
https://issues.apache.org/jira/browse/KAFKA-14309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lucas Brutschy updated KAFKA-14309:
---
Component/s: streams
> Kafka Streams upgrade tests do not cover for FK-joins
> -
[
https://issues.apache.org/jira/browse/KAFKA-14278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lucas Brutschy reassigned KAFKA-14278:
--
Assignee: Lucas Brutschy
> Convert INVALID_PRODUCER_EPOCH into PRODUCER_FENCED TxnOff
[
https://issues.apache.org/jira/browse/KAFKA-14278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lucas Brutschy updated KAFKA-14278:
---
Component/s: producer
streams
> Convert INVALID_PRODUCER_EPOCH into PRODUC
Purshotam Chauhan created KAFKA-14435:
-
Summary: Kraft: StandardAuthorizer allowing a non-authorized user
when `allow.everyone.if.no.acl.found` is enabled
Key: KAFKA-14435
URL: https://issues.apache.org/jira/b
[
https://issues.apache.org/jira/browse/KAFKA-14435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17642497#comment-17642497
]
Purshotam Chauhan commented on KAFKA-14435:
---
This can be fixed by adding a fla
[
https://issues.apache.org/jira/browse/KAFKA-14435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17642497#comment-17642497
]
Purshotam Chauhan edited comment on KAFKA-14435 at 12/2/22 1:20 PM:
--
[
https://issues.apache.org/jira/browse/KAFKA-14435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17642497#comment-17642497
]
Purshotam Chauhan edited comment on KAFKA-14435 at 12/2/22 1:21 PM:
--
[
https://issues.apache.org/jira/browse/KAFKA-12679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17642502#comment-17642502
]
Lucas Brutschy commented on KAFKA-12679:
I referenced this ticket in the PR
> R
divijvaidya commented on PR #12940:
URL: https://github.com/apache/kafka/pull/12940#issuecomment-1335251627
Rebased from trunk. Test failures are unrelated.
```
Build / JDK 11 and Scala 2.13 / testFailureToFenceEpoch(String).quorum=kraft
– kafka.api.TransactionsTest
Build / JDK
divijvaidya commented on PR #12940:
URL: https://github.com/apache/kafka/pull/12940#issuecomment-1335252064
@mimaison please take a look when you get a chance! Thanks.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use th
lucasbru commented on PR #12935:
URL: https://github.com/apache/kafka/pull/12935#issuecomment-1335257553
@cadonna Could you have a look? I ran this for a few hours in the soak and
the native memory is stable. So I think this was the main leak
--
This is an automated message from the Apach
[
https://issues.apache.org/jira/browse/KAFKA-14435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Purshotam Chauhan reassigned KAFKA-14435:
-
Assignee: Purshotam Chauhan
> Kraft: StandardAuthorizer allowing a non-authoriz
[
https://issues.apache.org/jira/browse/KAFKA-14435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17642497#comment-17642497
]
Purshotam Chauhan edited comment on KAFKA-14435 at 12/2/22 2:12 PM:
--
[
https://issues.apache.org/jira/browse/KAFKA-14435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Purshotam Chauhan updated KAFKA-14435:
--
Affects Version/s: 3.2.3
3.2.2
3.2.1
pprovenzano commented on PR #12896:
URL: https://github.com/apache/kafka/pull/12896#issuecomment-1335323936
I have validated that the failing tests work by manually running them.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
dajac commented on code in PR #12914:
URL: https://github.com/apache/kafka/pull/12914#discussion_r1037881208
##
clients/src/main/resources/common/message/ConsumerProtocolAssignment.json:
##
@@ -23,6 +23,7 @@
// that new versions cannot remove or reorder any of the existing fi
mumrah merged PR #12942:
URL: https://github.com/apache/kafka/pull/12942
--
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-14433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Arthur reassigned KAFKA-14433:
Assignee: David Arthur
> Clear all yammer metrics when test harnesses clean up
>
[
https://issues.apache.org/jira/browse/KAFKA-14433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Arthur resolved KAFKA-14433.
--
Resolution: Fixed
> Clear all yammer metrics when test harnesses clean up
> --
[
https://issues.apache.org/jira/browse/KAFKA-14427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Arthur updated KAFKA-14427:
-
Summary: Add support for ZK migration multi-ops transaction (was: Add
support for ZK migration
[
https://issues.apache.org/jira/browse/KAFKA-14429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton updated KAFKA-14429:
--
Labels: needs-kip (was: )
> Move OffsetStorageReader from storage package to source package
>
[
https://issues.apache.org/jira/browse/KAFKA-14429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17642565#comment-17642565
]
Chris Egerton commented on KAFKA-14429:
---
Although I agree that the package name is
David Arthur created KAFKA-14436:
Summary: Initialize KRaft with arbitrary epoch
Key: KAFKA-14436
URL: https://issues.apache.org/jira/browse/KAFKA-14436
Project: Kafka
Issue Type: Sub-task
dajac commented on code in PR #12175:
URL: https://github.com/apache/kafka/pull/12175#discussion_r1038279577
##
core/src/test/scala/unit/kafka/tools/ConsoleConsumerTest.scala:
##
@@ -488,6 +488,31 @@ class ConsoleConsumerTest {
assertTrue(formatter.keyDeserializer.get.asIn
omkreddy merged PR #12896:
URL: https://github.com/apache/kafka/pull/12896
--
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
dajac merged PR #12175:
URL: https://github.com/apache/kafka/pull/12175
--
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
zigarn commented on PR #12175:
URL: https://github.com/apache/kafka/pull/12175#issuecomment-1335472177
No problem, thanks for the review.
--
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 speci
zigarn commented on code in PR #12175:
URL: https://github.com/apache/kafka/pull/12175#discussion_r1038293918
##
core/src/test/scala/unit/kafka/tools/ConsoleConsumerTest.scala:
##
@@ -488,6 +488,31 @@ class ConsoleConsumerTest {
assertTrue(formatter.keyDeserializer.get.asI
dajac merged PR #12847:
URL: https://github.com/apache/kafka/pull/12847
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.or
[
https://issues.apache.org/jira/browse/KAFKA-14358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
José Armando García Sancio resolved KAFKA-14358.
Resolution: Fixed
> Users should not be able to create a regular t
Andrew Grant created KAFKA-14437:
Summary: Enhance StripedReplicaPlacer to account for existing
partition assignments
Key: KAFKA-14437
URL: https://issues.apache.org/jira/browse/KAFKA-14437
Project: K
andymg3 opened a new pull request, #12943:
URL: https://github.com/apache/kafka/pull/12943
### Details
This is a draft PR showing a potential solution to
https://issues.apache.org/jira/browse/KAFKA-14437. The idea is to enhance
StripedReplicaPlacer to use previous partition assignments t
[
https://issues.apache.org/jira/browse/KAFKA-14437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17642602#comment-17642602
]
Andrew Grant commented on KAFKA-14437:
--
I created a draft PR, [https://github.com/a
[
https://issues.apache.org/jira/browse/KAFKA-14437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrew Grant updated KAFKA-14437:
-
Description:
Currently, in StripedReplicaPlacer we don’t take existing partition assignments
in
[
https://issues.apache.org/jira/browse/KAFKA-14437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrew Grant updated KAFKA-14437:
-
Description:
Currently, in StripedReplicaPlacer we don’t take existing partition assignments
in
[
https://issues.apache.org/jira/browse/KAFKA-14437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrew Grant updated KAFKA-14437:
-
Description:
Currently, in StripedReplicaPlacer we don’t take existing partition assignments
in
[
https://issues.apache.org/jira/browse/KAFKA-14437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrew Grant updated KAFKA-14437:
-
Description:
Currently, in StripedReplicaPlacer we don’t take existing partition assignments
in
[
https://issues.apache.org/jira/browse/KAFKA-14437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrew Grant updated KAFKA-14437:
-
Description:
Currently, in StripedReplicaPlacer we don’t take existing partition assignments
in
jonathan-albrecht-ibm commented on PR #12343:
URL: https://github.com/apache/kafka/pull/12343#issuecomment-1335553986
Thanks @mimaison!
--
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
hachikuji commented on code in PR #12915:
URL: https://github.com/apache/kafka/pull/12915#discussion_r1038362105
##
clients/src/test/java/org/apache/kafka/clients/producer/internals/TransactionManagerTest.java:
##
@@ -1678,6 +1680,62 @@ public void testMultipleAddPartitionsPerFo
hachikuji commented on code in PR #12915:
URL: https://github.com/apache/kafka/pull/12915#discussion_r1038362105
##
clients/src/test/java/org/apache/kafka/clients/producer/internals/TransactionManagerTest.java:
##
@@ -1678,6 +1680,62 @@ public void testMultipleAddPartitionsPerFo
jolshan commented on code in PR #12915:
URL: https://github.com/apache/kafka/pull/12915#discussion_r1038365461
##
clients/src/test/java/org/apache/kafka/clients/producer/internals/TransactionManagerTest.java:
##
@@ -1678,6 +1680,62 @@ public void testMultipleAddPartitionsPerForO
hachikuji commented on code in PR #12915:
URL: https://github.com/apache/kafka/pull/12915#discussion_r1038367059
##
clients/src/test/java/org/apache/kafka/clients/producer/internals/TransactionManagerTest.java:
##
@@ -1678,6 +1680,62 @@ public void testMultipleAddPartitionsPerFo
jolshan commented on code in PR #12915:
URL: https://github.com/apache/kafka/pull/12915#discussion_r1038368961
##
clients/src/test/java/org/apache/kafka/clients/producer/internals/TransactionManagerTest.java:
##
@@ -1678,6 +1680,62 @@ public void testMultipleAddPartitionsPerForO
hachikuji commented on code in PR #12862:
URL: https://github.com/apache/kafka/pull/12862#discussion_r1038378151
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/CoordinatorRequestManager.java:
##
@@ -0,0 +1,272 @@
+/*
+ * Licensed to the Apache Software Foun
jolshan commented on code in PR #12915:
URL: https://github.com/apache/kafka/pull/12915#discussion_r1038385341
##
clients/src/test/java/org/apache/kafka/clients/producer/internals/TransactionManagerTest.java:
##
@@ -1678,6 +1680,62 @@ public void testMultipleAddPartitionsPerForO
[
https://issues.apache.org/jira/browse/KAFKA-14436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alyssa Huang reassigned KAFKA-14436:
Assignee: Alyssa Huang
> Initialize KRaft with arbitrary epoch
>
hachikuji commented on code in PR #12862:
URL: https://github.com/apache/kafka/pull/12862#discussion_r1038418696
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/NetworkClientDelegate.java:
##
@@ -0,0 +1,260 @@
+/*
+ * Licensed to the Apache Software Foundati
hachikuji commented on code in PR #12862:
URL: https://github.com/apache/kafka/pull/12862#discussion_r1038418696
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/NetworkClientDelegate.java:
##
@@ -0,0 +1,260 @@
+/*
+ * Licensed to the Apache Software Foundati
hachikuji commented on code in PR #12862:
URL: https://github.com/apache/kafka/pull/12862#discussion_r1038418696
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/NetworkClientDelegate.java:
##
@@ -0,0 +1,260 @@
+/*
+ * Licensed to the Apache Software Foundati
hachikuji commented on code in PR #12862:
URL: https://github.com/apache/kafka/pull/12862#discussion_r1038423837
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/NetworkClientDelegate.java:
##
@@ -0,0 +1,260 @@
+/*
+ * Licensed to the Apache Software Foundati
hachikuji commented on code in PR #12862:
URL: https://github.com/apache/kafka/pull/12862#discussion_r1038422365
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/NetworkClientDelegate.java:
##
@@ -0,0 +1,260 @@
+/*
+ * Licensed to the Apache Software Foundati
belugabehr commented on PR #8066:
URL: https://github.com/apache/kafka/pull/8066#issuecomment-1335664538
I documented my work on the ticket as well. It got very little attention
from the Kafka Dev Team and seems to be pretty out of date now (merge
conflicts). Will need someone internal to
hachikuji commented on code in PR #12862:
URL: https://github.com/apache/kafka/pull/12862#discussion_r1038423520
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/NetworkClientDelegate.java:
##
@@ -0,0 +1,260 @@
+/*
+ * Licensed to the Apache Software Foundati
hachikuji commented on code in PR #12862:
URL: https://github.com/apache/kafka/pull/12862#discussion_r1038423837
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/NetworkClientDelegate.java:
##
@@ -0,0 +1,260 @@
+/*
+ * Licensed to the Apache Software Foundati
hachikuji commented on code in PR #12862:
URL: https://github.com/apache/kafka/pull/12862#discussion_r1038423520
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/NetworkClientDelegate.java:
##
@@ -0,0 +1,260 @@
+/*
+ * Licensed to the Apache Software Foundati
hachikuji commented on code in PR #12862:
URL: https://github.com/apache/kafka/pull/12862#discussion_r1038423837
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/NetworkClientDelegate.java:
##
@@ -0,0 +1,260 @@
+/*
+ * Licensed to the Apache Software Foundati
hachikuji commented on code in PR #12862:
URL: https://github.com/apache/kafka/pull/12862#discussion_r1038427640
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/CoordinatorRequestManager.java:
##
@@ -0,0 +1,272 @@
+/*
+ * Licensed to the Apache Software Foun
hachikuji commented on code in PR #12862:
URL: https://github.com/apache/kafka/pull/12862#discussion_r1038427945
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/CoordinatorRequestManager.java:
##
@@ -0,0 +1,272 @@
+/*
+ * Licensed to the Apache Software Foun
hachikuji commented on code in PR #12862:
URL: https://github.com/apache/kafka/pull/12862#discussion_r1038427640
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/CoordinatorRequestManager.java:
##
@@ -0,0 +1,272 @@
+/*
+ * Licensed to the Apache Software Foun
hachikuji commented on code in PR #12862:
URL: https://github.com/apache/kafka/pull/12862#discussion_r1038429334
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/CoordinatorRequestManager.java:
##
@@ -0,0 +1,272 @@
+/*
+ * Licensed to the Apache Software Foun
[
https://issues.apache.org/jira/browse/KAFKA-5493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-5493:
---
Labels: eos (was: )
> Optimize calls to flush for tasks and standby tasks
>
[
https://issues.apache.org/jira/browse/KAFKA-5085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-5085.
Resolution: Abandoned
Might no be necessary any longer given all the changes we did over th
[
https://issues.apache.org/jira/browse/KAFKA-5245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-5245.
Resolution: Fixed
> KStream builder should capture serdes
> --
[
https://issues.apache.org/jira/browse/KAFKA-6509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-6509.
Resolution: Not A Problem
> Add additional tests for validating store restoration completes
[
https://issues.apache.org/jira/browse/KAFKA-6542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-6542.
Resolution: Invalid
This will be fixed via versioned stores and "delayed table lookups".
>
[
https://issues.apache.org/jira/browse/KAFKA-14379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson updated KAFKA-14379:
Fix Version/s: 3.4.0
> consumer should refresh preferred read replica on update metadata
>
[
https://issues.apache.org/jira/browse/KAFKA-14379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson updated KAFKA-14379:
Priority: Critical (was: Major)
> consumer should refresh preferred read replica on updat
[
https://issues.apache.org/jira/browse/KAFKA-6643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-6643.
Resolution: Won't Fix
> Warm up new replicas from scratch when changelog topic has LIMITED
hachikuji commented on code in PR #12897:
URL: https://github.com/apache/kafka/pull/12897#discussion_r1038530374
##
clients/src/test/java/org/apache/kafka/common/requests/RequestTestUtils.java:
##
@@ -208,10 +209,10 @@ public static MetadataResponse metadataUpdateWith(final
Str
lihaosky opened a new pull request, #12944:
URL: https://github.com/apache/kafka/pull/12944
## Description
This PR is for
https://cwiki.apache.org/confluence/display/KAFKA/KIP-884%3A+Add+config+to+configure+KafkaClientSupplier+in+Kafka+Streams.
It adds a new `default.client.supplier` con
Philip Nee created KAFKA-14438:
--
Summary: Stop supporting empty consumer groupId
Key: KAFKA-14438
URL: https://issues.apache.org/jira/browse/KAFKA-14438
Project: Kafka
Issue Type: Task
[
https://issues.apache.org/jira/browse/KAFKA-14437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrew Grant reassigned KAFKA-14437:
Assignee: Andrew Grant
> Enhance StripedReplicaPlacer to account for existing partition a
Justine Olshan created KAFKA-14439:
--
Summary: Specify returned errors for various APIs and versions
Key: KAFKA-14439
URL: https://issues.apache.org/jira/browse/KAFKA-14439
Project: Kafka
Iss
[
https://issues.apache.org/jira/browse/KAFKA-14439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17642726#comment-17642726
]
Jason Gustafson commented on KAFKA-14439:
-
Yeah, we've had so many compatibility
[
https://issues.apache.org/jira/browse/KAFKA-14439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17642726#comment-17642726
]
Jason Gustafson edited comment on KAFKA-14439 at 12/2/22 11:44 PM:
---
[
https://issues.apache.org/jira/browse/KAFKA-14438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson updated KAFKA-14438:
Priority: Blocker (was: Major)
> Stop supporting empty consumer groupId
> ---
[
https://issues.apache.org/jira/browse/KAFKA-14439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17642735#comment-17642735
]
Ismael Juma commented on KAFKA-14439:
-
I think it would also be useful for the serve
[
https://issues.apache.org/jira/browse/KAFKA-14439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17642726#comment-17642726
]
Jason Gustafson edited comment on KAFKA-14439 at 12/2/22 11:52 PM:
---
kirktrue opened a new pull request, #12945:
URL: https://github.com/apache/kafka/pull/12945
This change refactors the existing `Fetcher` by splitting out the parts
related to offset listing into a dedicated class named `OffsetsFinder`. This
allows the `Fetcher` implementation to be more ded
mumrah merged PR #12928:
URL: https://github.com/apache/kafka/pull/12928
--
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
mumrah opened a new pull request, #12946:
URL: https://github.com/apache/kafka/pull/12946
TODO
--
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-
showuon commented on PR #12940:
URL: https://github.com/apache/kafka/pull/12940#issuecomment-1336107162
Re-run the jenkins:
https://ci-builds.apache.org/job/Kafka/job/kafka-pr/job/PR-12940/4/
--
This is an automated message from the Apache Git Service.
To respond to the message, please lo
showuon commented on PR #12908:
URL: https://github.com/apache/kafka/pull/12908#issuecomment-1336108293
Failed with some `MemoryRecordsBuilderTest` tests. Re-run jenkins:
https://ci-builds.apache.org/job/Kafka/job/kafka-pr/job/PR-12908/4/
```
Build / JDK 8 and Scala 2.12 /
org
92 matches
Mail list logo
