nizhikov opened a new pull request, #15417:
URL: https://github.com/apache/kafka/pull/15417
PR contains `ConfigCommand` rewritten in java.
Due to heavy dependencies on `core` classes command can't be moved in
`tools` for now.
But it can be rewritten in java staying in `core` module
credpath-seek opened a new pull request, #15416:
URL: https://github.com/apache/kafka/pull/15416
## Context
Treats `KAFKA-16277 - CooperativeStickyAssignor does not spread topics
evenly among consumer group`
https://issues.apache.org/jira/browse/KAFKA-16277
Tests WIP
[
https://issues.apache.org/jira/browse/KAFKA-16283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17819471#comment-17819471
]
Luke Chen commented on KAFKA-16283:
---
Oops, I was also involved in the discussion years ago, but I
github-actions[bot] commented on PR #14814:
URL: https://github.com/apache/kafka/pull/14814#issuecomment-1958593965
This PR is being marked as stale since it has not had any activity in 90
days. If you would like to keep this PR alive, please ask a committer for
review. If the PR has
ericzhifengchen commented on PR #15376:
URL: https://github.com/apache/kafka/pull/15376#issuecomment-1958593101
my github account is ericzhifengc...@gmail.com
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
lianetm commented on PR #15392:
URL: https://github.com/apache/kafka/pull/15392#issuecomment-1958573687
Test failures seem unrelated to me. The `testAutoCommitOnClose` failing on
the consumer integration tests has been reported flaky independently of this PR
, tracked with
lianetm commented on code in PR #15415:
URL: https://github.com/apache/kafka/pull/15415#discussion_r1498553247
##
core/src/test/scala/integration/kafka/api/PlaintextConsumerTest.scala:
##
@@ -169,10 +169,8 @@ class PlaintextConsumerTest extends BaseConsumerTest {
lianetm commented on PR #15415:
URL: https://github.com/apache/kafka/pull/15415#issuecomment-1958564382
Hey @lucasbru , could you take a look at this one? Thanks!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
lianetm opened a new pull request, #15415:
URL: https://github.com/apache/kafka/pull/15415
Introduce call to `onPartitionsLost` callback to release assignment when a
consumer pro-actively leaves the group due to poll timer expired.
When the poll timer expires, the member sends a
jeffkbkim commented on code in PR #15280:
URL: https://github.com/apache/kafka/pull/15280#discussion_r1498526867
##
clients/src/main/java/org/apache/kafka/common/utils/Utils.java:
##
@@ -1675,6 +1677,20 @@ public static Map
entriesWithPrefix(Map map, String pr
return
testn commented on code in PR #15402:
URL: https://github.com/apache/kafka/pull/15402#discussion_r1498498644
##
checkstyle/suppressions.xml:
##
@@ -92,7 +92,7 @@
files="(Utils|Topic|KafkaLZ4BlockOutputStream|AclData|JoinGroupRequest).java"/>
+
jeffkbkim commented on code in PR #15312:
URL: https://github.com/apache/kafka/pull/15312#discussion_r1498498011
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerNetworkThread.java:
##
@@ -87,8 +92,8 @@ public void run() {
try {
showuon closed pull request #15400: KAFKA-16283: notify users about
RoundRobinPartitioner bug
URL: https://github.com/apache/kafka/pull/15400
--
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-16283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17819428#comment-17819428
]
ASF GitHub Bot commented on KAFKA-16283:
showuon closed pull request #585: KAFKA-16283: notify
showuon commented on PR #15400:
URL: https://github.com/apache/kafka/pull/15400#issuecomment-1958464961
Sorry @stanislavkozlovski , I just found this issue has already found and
documented on document. Let's close this PR now.
--
This is an automated message from the Apache Git Service.
junrao commented on code in PR #15251:
URL: https://github.com/apache/kafka/pull/15251#discussion_r1498439741
##
server/src/main/java/org/apache/kafka/server/ClientMetricsManager.java:
##
@@ -493,4 +520,124 @@ public void run() {
}
}
}
+
+//
mjsax commented on code in PR #15383:
URL: https://github.com/apache/kafka/pull/15383#discussion_r1498439703
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumerTest.java:
##
@@ -419,6 +422,35 @@ public void testWakeupAfterNonEmptyFetch() {
mjsax commented on PR #14605:
URL: https://github.com/apache/kafka/pull/14605#issuecomment-1958253922
That weird -- signup should just work. (You definitely don't need to file an
ICLA or become a committer :))
-- Maybe it's a temporary glitch -- or something is broken and we need to
[
https://issues.apache.org/jira/browse/KAFKA-16295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman updated KAFKA-16295:
---
Labels: newbie (was: )
> Align RocksDB and in-memory store init() sequence
[
https://issues.apache.org/jira/browse/KAFKA-16295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman updated KAFKA-16295:
---
Summary: Align RocksDB and in-memory store init() sequence (was: Align
wcarlson5 commented on code in PR #15414:
URL: https://github.com/apache/kafka/pull/15414#discussion_r1498391601
##
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/TableSourceNode.java:
##
@@ -105,7 +105,8 @@ public void writeToTopology(final
Matthias J. Sax created KAFKA-16295:
---
Summary: Align RocksDB and in-memory store inti() sequence
Key: KAFKA-16295
URL: https://issues.apache.org/jira/browse/KAFKA-16295
Project: Kafka
wcarlson5 commented on code in PR #15414:
URL: https://github.com/apache/kafka/pull/15414#discussion_r1498387326
##
streams/src/main/java/org/apache/kafka/streams/Topology.java:
##
@@ -783,7 +783,8 @@ public synchronized Topology addGlobalStore(final
StoreBuilder storeBu
wcarlson5 opened a new pull request, #15414:
URL: https://github.com/apache/kafka/pull/15414
When custom processors are added via `StreamBuilder#addGlobalStore` they
will now reprocess all records through the custom transformer instead of
loading directly.
We do this so that users
federico-weisse-sportsbet opened a new pull request, #15413:
URL: https://github.com/apache/kafka/pull/15413
This should be greater than 1 to be consistent with behavior described in
max.in.flight.requests.per.connection property.
More detailed description of your change,
if
[
https://issues.apache.org/jira/browse/KAFKA-16291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17819397#comment-17819397
]
Claudio Benfatto edited comment on KAFKA-16291 at 2/21/24 9:52 PM:
---
Hi
[
https://issues.apache.org/jira/browse/KAFKA-16291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17819397#comment-17819397
]
Claudio Benfatto edited comment on KAFKA-16291 at 2/21/24 9:52 PM:
---
Hi
[
https://issues.apache.org/jira/browse/KAFKA-16291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17819397#comment-17819397
]
Claudio Benfatto edited comment on KAFKA-16291 at 2/21/24 9:50 PM:
---
Hi
[
https://issues.apache.org/jira/browse/KAFKA-16291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17819397#comment-17819397
]
Claudio Benfatto edited comment on KAFKA-16291 at 2/21/24 9:48 PM:
---
Hi
[
https://issues.apache.org/jira/browse/KAFKA-16291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17819397#comment-17819397
]
Claudio Benfatto edited comment on KAFKA-16291 at 2/21/24 9:48 PM:
---
Hi
[
https://issues.apache.org/jira/browse/KAFKA-16291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17819397#comment-17819397
]
Claudio Benfatto commented on KAFKA-16291:
--
Hi [~gharris1727] , thanks a lot for your clear
AyoubOm opened a new pull request, #15412:
URL: https://github.com/apache/kafka/pull/15412
*Fixes some typos in javadocs of readOnly SessionStore, and minor typos in
WindowStore / KeyValueStore.*
--
This is an automated message from the Apache Git Service.
To respond to the message,
Cerchie commented on code in PR #14360:
URL: https://github.com/apache/kafka/pull/14360#discussion_r1498343776
##
streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java:
##
@@ -482,7 +482,8 @@ public class StreamsConfig extends AbstractConfig {
public static
dongnuo123 opened a new pull request, #15411:
URL: https://github.com/apache/kafka/pull/15411
*More detailed description of your change,
if necessary. The PR title and PR message become
the squashed commit message, so use a separate
comment to ping reviewers.*
*Summary of
[
https://issues.apache.org/jira/browse/KAFKA-16294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dongnuo Lyu reassigned KAFKA-16294:
---
Assignee: Dongnuo Lyu
> Add group protocol migration enabling config
>
Dongnuo Lyu created KAFKA-16294:
---
Summary: Add group protocol migration enabling config
Key: KAFKA-16294
URL: https://issues.apache.org/jira/browse/KAFKA-16294
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-16224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans updated KAFKA-16224:
---
Description:
Current logic for auto-committing offsets when partitions are revoked will
[
https://issues.apache.org/jira/browse/KAFKA-15665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Justine Olshan resolved KAFKA-15665.
Resolution: Fixed
> Enforce ISR to have all target replicas when complete partition
[
https://issues.apache.org/jira/browse/KAFKA-16291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17819368#comment-17819368
]
Greg Harris edited comment on KAFKA-16291 at 2/21/24 7:01 PM:
--
Hi
[
https://issues.apache.org/jira/browse/KAFKA-16291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17819368#comment-17819368
]
Greg Harris commented on KAFKA-16291:
-
Hi [~claudio.benfatto] Thanks for the bug report and the very
divijvaidya commented on code in PR #15402:
URL: https://github.com/apache/kafka/pull/15402#discussion_r1498116256
##
checkstyle/suppressions.xml:
##
@@ -92,7 +92,7 @@
files="(Utils|Topic|KafkaLZ4BlockOutputStream|AclData|JoinGroupRequest).java"/>
+
[
https://issues.apache.org/jira/browse/KAFKA-16283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17819363#comment-17819363
]
Artem Livshits commented on KAFKA-16283:
The issue was created by the first attempt to implement
[
https://issues.apache.org/jira/browse/KAFKA-15898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17819351#comment-17819351
]
Justine Olshan edited comment on KAFKA-15898 at 2/21/24 6:26 PM:
-
I have
[
https://issues.apache.org/jira/browse/KAFKA-15898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17819351#comment-17819351
]
Justine Olshan commented on KAFKA-15898:
I have 8 failures on one run
jolshan commented on PR #15358:
URL: https://github.com/apache/kafka/pull/15358#issuecomment-1957581558
This test seems somewhat flaky still:
[
https://issues.apache.org/jira/browse/KAFKA-16194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna resolved KAFKA-16194.
---
Resolution: Fixed
> KafkaConsumer.groupMetadata() should be correct when first records are
cadonna merged PR #15369:
URL: https://github.com/apache/kafka/pull/15369
--
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 code in PR #15320:
URL: https://github.com/apache/kafka/pull/15320#discussion_r1497943369
##
clients/src/test/java/org/apache/kafka/clients/producer/internals/TransactionManagerTest.java:
##
@@ -2548,6 +2548,23 @@ public void
jolshan commented on PR #15405:
URL: https://github.com/apache/kafka/pull/15405#issuecomment-1957306611
Sorry that was my bad.
--
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-16283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17819325#comment-17819325
]
Justine Olshan commented on KAFKA-16283:
also https://issues.apache.org/jira/browse/KAFKA-14573
[
https://issues.apache.org/jira/browse/KAFKA-16283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17819324#comment-17819324
]
Justine Olshan commented on KAFKA-16283:
https://issues.apache.org/jira/browse/KAFKA-13359 Is
[
https://issues.apache.org/jira/browse/KAFKA-16283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17819322#comment-17819322
]
Jun Rao commented on KAFKA-16283:
-
[~showuon] : Is this the same as
[
https://issues.apache.org/jira/browse/KAFKA-15538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17819008#comment-17819008
]
Phuc Hong Tran edited comment on KAFKA-15538 at 2/21/24 4:43 PM:
-
I can
testn commented on PR #15402:
URL: https://github.com/apache/kafka/pull/15402#issuecomment-1957192264
> Nice! Small but very helpful change.
>
> Out of curiosity, do you happen to have any ideas to detect such
performance-inefficiencies automatically in future?
Currently,
testn commented on PR #15402:
URL: https://github.com/apache/kafka/pull/15402#issuecomment-1957177698
Add the file to the suppression list instead.
--
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-16292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17819310#comment-17819310
]
Ahmed Sobeh edited comment on KAFKA-16292 at 2/21/24 4:13 PM:
--
Not sure if
[
https://issues.apache.org/jira/browse/KAFKA-16292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17819310#comment-17819310
]
Ahmed Sobeh commented on KAFKA-16292:
-
Not sure if someone is already working on this, but happy to
[
https://issues.apache.org/jira/browse/KAFKA-16290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16290:
--
Priority: Critical (was: Major)
> Investigate propagating subscription state updates via queues
>
[
https://issues.apache.org/jira/browse/KAFKA-16290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16290:
--
Fix Version/s: 3.8.0
> Investigate propagating subscription state updates via queues
>
jsancio commented on PR #15397:
URL: https://github.com/apache/kafka/pull/15397#issuecomment-1957122692
All of the `raft:test` tests passed. There seem to be some unrelated
failures. Running the tests again.
--
This is an automated message from the Apache Git Service.
To respond to the
mjsax merged PR #15396:
URL: https://github.com/apache/kafka/pull/15396
--
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:
soarez commented on code in PR #15409:
URL: https://github.com/apache/kafka/pull/15409#discussion_r1497794379
##
tests/kafkatest/tests/core/log_dir_failure_test.py:
##
@@ -84,20 +84,25 @@ def __init__(self, test_context):
self.num_consumers = 1
def setUp(self):
ghostspiders commented on PR #15410:
URL: https://github.com/apache/kafka/pull/15410#issuecomment-1956966547
Hi, @divijvaidya please review 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
ghostspiders opened a new pull request, #15410:
URL: https://github.com/apache/kafka/pull/15410
The CoreUtils.swallow() method in different logging levels test.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
mumrah commented on code in PR #15265:
URL: https://github.com/apache/kafka/pull/15265#discussion_r1497780170
##
clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java:
##
@@ -2129,63 +2167,183 @@ private Map>
handleDescribeTopicsByNames(f
}
[
https://issues.apache.org/jira/browse/KAFKA-16010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lucas Brutschy resolved KAFKA-16010.
Resolution: Duplicate
> Fix
[
https://issues.apache.org/jira/browse/KAFKA-16010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17819289#comment-17819289
]
Lucas Brutschy commented on KAFKA-16010:
[~kirktrue] I think you enabled this test already
>
[
https://issues.apache.org/jira/browse/KAFKA-16010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17819289#comment-17819289
]
Lucas Brutschy edited comment on KAFKA-16010 at 2/21/24 3:14 PM:
-
[
https://issues.apache.org/jira/browse/KAFKA-16292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17819283#comment-17819283
]
Mickael Maison commented on KAFKA-16292:
We can add a paragraph with links to the previous
gaurav-narula commented on PR #15394:
URL: https://github.com/apache/kafka/pull/15394#issuecomment-1956779813
CC: @soarez @OmniaGM @pprovenzano @cmccabe
--
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
gaurav-narula commented on PR #15409:
URL: https://github.com/apache/kafka/pull/15409#issuecomment-1956778458
CC: @soarez @OmniaGM @pprovenzano @cmccabe
--
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
gaurav-narula opened a new pull request, #15409:
URL: https://github.com/apache/kafka/pull/15409
Enables log directory failure system test for all Kraft modes in addition to
ZK mode.
This depends on #15335 being merged.
--
This is an automated message from the Apache Git Service.
[
https://issues.apache.org/jira/browse/KAFKA-16185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans updated KAFKA-16185:
---
Priority: Blocker (was: Critical)
> Fix client reconciliation of same assignment received
[
https://issues.apache.org/jira/browse/KAFKA-16185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans updated KAFKA-16185:
---
Description:
Currently, the intention in the client state machine is that the client always
[
https://issues.apache.org/jira/browse/KAFKA-16261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans updated KAFKA-16261:
---
Affects Version/s: 3.7.0
> MembershipManagerImpl.updateSubscription fails if already empty
[
https://issues.apache.org/jira/browse/KAFKA-16185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans updated KAFKA-16185:
---
Priority: Critical (was: Blocker)
> Fix client reconciliation of same assignment received
s7pandey commented on PR #14605:
URL: https://github.com/apache/kafka/pull/14605#issuecomment-1956760536
Hey @mjsax I seem unable to gain access to Confluence, following the
instructions on the KIP page leads me to a page where I cannot sign up, would I
need to follow:
[
https://issues.apache.org/jira/browse/KAFKA-16224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans updated KAFKA-16224:
---
Description:
Current logic for auto-committing offsets when partitions are revoked will
[
https://issues.apache.org/jira/browse/KAFKA-16224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans updated KAFKA-16224:
---
Priority: Critical (was: Major)
> Fix handling of deleted topic when auto-committing
[
https://issues.apache.org/jira/browse/KAFKA-16293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gaurav Narula reassigned KAFKA-16293:
-
Assignee: Gaurav Narula
> Test log directory failure in Kraft
>
Gaurav Narula created KAFKA-16293:
-
Summary: Test log directory failure in Kraft
Key: KAFKA-16293
URL: https://issues.apache.org/jira/browse/KAFKA-16293
Project: Kafka
Issue Type: Test
[
https://issues.apache.org/jira/browse/KAFKA-16185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans updated KAFKA-16185:
---
Description:
Currently, the intention in the client state machine is that the client always
[
https://issues.apache.org/jira/browse/KAFKA-16261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans updated KAFKA-16261:
---
Labels: client-transitions-issues consumer-threading-refactor
kip-848-client-support (was:
[
https://issues.apache.org/jira/browse/KAFKA-16004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans updated KAFKA-16004:
---
Priority: Critical (was: Major)
> Review new consumer inflight offset commit logic
>
[
https://issues.apache.org/jira/browse/KAFKA-16103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans updated KAFKA-16103:
---
Priority: Critical (was: Major)
> Review client logic for triggering offset commit
[
https://issues.apache.org/jira/browse/KAFKA-15839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans updated KAFKA-15839:
---
Fix Version/s: 4.0.0
(was: 3.8.0)
> Topic ID integration in consumer
[
https://issues.apache.org/jira/browse/KAFKA-15847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans updated KAFKA-15847:
---
Fix Version/s: 4.0.0
(was: 3.8.0)
> Consider partial metadata
[
https://issues.apache.org/jira/browse/KAFKA-15843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans updated KAFKA-15843:
---
Fix Version/s: 4.0.0
(was: 3.8.0)
> Review consumer
[
https://issues.apache.org/jira/browse/KAFKA-16185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans updated KAFKA-16185:
---
Priority: Critical (was: Major)
> Fix client reconciliation of same assignment received in
[
https://issues.apache.org/jira/browse/KAFKA-16261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans updated KAFKA-16261:
---
Priority: Critical (was: Minor)
> MembershipManagerImpl.updateSubscription fails if
[
https://issues.apache.org/jira/browse/KAFKA-16292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17819258#comment-17819258
]
Ismael Juma commented on KAFKA-16292:
-
I agree that having the upgrade details for so many versions
lucasbru commented on PR #15408:
URL: https://github.com/apache/kafka/pull/15408#issuecomment-1956664015
@kirktrue Hope that helps!
--
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
lucasbru opened a new pull request, #15408:
URL: https://github.com/apache/kafka/pull/15408
Add 6 example tests to the `PlaintextConsumerTest` that tests using a
`ConsumerRebalanceListener` to invoke methods on the consumer.
This test is implemented in a reasonably general way with a
divijvaidya commented on PR #15402:
URL: https://github.com/apache/kafka/pull/15402#issuecomment-1956592176
@testn could you please fix the checkstyle failures which is causing the
build to fail.
msn-tldr commented on PR #15376:
URL: https://github.com/apache/kafka/pull/15376#issuecomment-1956540126
@ericzhifengchen The email you shared is anonymised with "*", I see it as
`***@***.***`. Is that because replied using email & github automatically
anonymised it 樂
divijvaidya commented on PR #15407:
URL: https://github.com/apache/kafka/pull/15407#issuecomment-1956469824
As an aside - we need a similar PR for ops.html as well since kafka-site is
ahead of trunk here right now. This doesn't block 3.7 and could be done later
as well. Just have to make
mimaison commented on PR #15406:
URL: https://github.com/apache/kafka/pull/15406#issuecomment-1956462946
So +1 for merging this and https://github.com/apache/kafka/pull/15407 now so
we can update kafka-site.
--
This is an automated message from the Apache Git Service.
To respond to the
jlprat commented on PR #15404:
URL: https://github.com/apache/kafka/pull/15404#issuecomment-1956458474
Rebased
--
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
divijvaidya commented on PR #15404:
URL: https://github.com/apache/kafka/pull/15404#issuecomment-1956451482
It must have been fixed by
https://github.com/apache/kafka/commit/cc49fc76564b15f2111801faf62341aaf01c4d8c
Perhaps a rebase from trunk should help.
--
This is an automated
mimaison commented on PR #15406:
URL: https://github.com/apache/kafka/pull/15406#issuecomment-1956448543
Locally I rebased this PR on trunk to fix the compilation issue
(https://github.com/apache/kafka/commit/cc49fc76564b15f2111801faf62341aaf01c4d8c)
and ran `./gradlew siteDocsTar`.
1 - 100 of 149 matches
Mail list logo
