[
https://issues.apache.org/jira/browse/KAFKA-15561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15561:
--
Fix Version/s: 4.0.0
(was: 3.8.0)
> Client support for new SubscriptionPattern
[
https://issues.apache.org/jira/browse/KAFKA-15697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15697:
--
Fix Version/s: (was: 4.0.0)
> Add local assignor and ensure it cannot be used with server side
[
https://issues.apache.org/jira/browse/KAFKA-16109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16109:
--
Summary: Write system tests cover the "simple consumer + commit" use case
(was: Ensure system tests
[
https://issues.apache.org/jira/browse/KAFKA-15283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15283:
--
Priority: Critical (was: Major)
> Client support for OffsetFetch and OffsetCommit with topic ID
>
[
https://issues.apache.org/jira/browse/KAFKA-15279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15279:
--
Fix Version/s: (was: 4.0.0)
> Implement client support for KIP-848 client-side assigner RPCs
>
[
https://issues.apache.org/jira/browse/KAFKA-15284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15284:
--
Fix Version/s: (was: 4.0.0)
> Implement ConsumerGroupProtocolVersionResolver to determine
[
https://issues.apache.org/jira/browse/KAFKA-16110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16110:
--
Priority: Blocker (was: Major)
> Implement consumer performance tests
>
[
https://issues.apache.org/jira/browse/KAFKA-15282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15282:
--
Fix Version/s: (was: 4.0.0)
> Implement client support for KIP-848 client-side assignors
>
[
https://issues.apache.org/jira/browse/KAFKA-16143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16143:
--
Priority: Minor (was: Major)
> New metrics for KIP-848 protocol
>
>
[
https://issues.apache.org/jira/browse/KAFKA-16433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16433:
--
Labels: consumer-threading-refactor timeout (was:
consumer-threading-refactor)
> beginningOffsets
[
https://issues.apache.org/jira/browse/KAFKA-16433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16433:
--
Issue Type: Bug (was: Task)
> beginningOffsets and offsetsForTimes don't behave consistently when
[
https://issues.apache.org/jira/browse/KAFKA-16433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16433:
--
Component/s: clients
> beginningOffsets and offsetsForTimes don't behave consistently when providing
[
https://issues.apache.org/jira/browse/KAFKA-16433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16433:
--
Fix Version/s: 3.8.0
> beginningOffsets and offsetsForTimes don't behave consistently when providing
[
https://issues.apache.org/jira/browse/KAFKA-16200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17831107#comment-17831107
]
Kirk True edited comment on KAFKA-16200 at 3/26/24 11:45 PM:
-
I've [made
[
https://issues.apache.org/jira/browse/KAFKA-16200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17831107#comment-17831107
]
Kirk True commented on KAFKA-16200:
---
Making progress, need to do the following tasks:
# Update the
[
https://issues.apache.org/jira/browse/KAFKA-16427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-16427:
-
Assignee: Kirk True
> KafkaConsumer#position() does not respect timeout when group protocol is
[
https://issues.apache.org/jira/browse/KAFKA-16427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16427:
--
Component/s: clients
consumer
> KafkaConsumer#position() does not respect timeout
[
https://issues.apache.org/jira/browse/KAFKA-16427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16427:
--
Fix Version/s: 3.8.0
> KafkaConsumer#position() does not respect timeout when group protocol is
>
[
https://issues.apache.org/jira/browse/KAFKA-16427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16427:
--
Labels: consumer-threading-refactor timeout (was: )
> KafkaConsumer#position() does not respect
[
https://issues.apache.org/jira/browse/KAFKA-15538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17831034#comment-17831034
]
Kirk True commented on KAFKA-15538:
---
[~phuctran]—The {{ConsumerCoordinator}} has code to [update the
[
https://issues.apache.org/jira/browse/KAFKA-15558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17831031#comment-17831031
]
Kirk True commented on KAFKA-15558:
---
[~schofielaj]—can you follow up on [~phuctran]’s question?
[
https://issues.apache.org/jira/browse/KAFKA-16022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17831030#comment-17831030
]
Kirk True commented on KAFKA-16022:
---
[~pnee]—can you follow up on [~phuctran]'s question. Thanks!
>
[
https://issues.apache.org/jira/browse/KAFKA-16200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-16200:
-
Assignee: Kirk True (was: Bruno Cadonna)
> Enforce that RequestManager implementations
[
https://issues.apache.org/jira/browse/KAFKA-16160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16160:
--
Priority: Blocker (was: Major)
> AsyncKafkaConsumer is trying to connect to a disconnected node in a
[
https://issues.apache.org/jira/browse/KAFKA-15250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15250:
--
Priority: Critical (was: Blocker)
> ConsumerNetworkThread is running tight loop
>
[
https://issues.apache.org/jira/browse/KAFKA-15250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15250:
--
Priority: Blocker (was: Major)
> ConsumerNetworkThread is running tight loop
>
[
https://issues.apache.org/jira/browse/KAFKA-16271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-16271:
-
Assignee: Philip Nee
> Update consumer_rolling_upgrade_test.py to support KIP-848’s group
[
https://issues.apache.org/jira/browse/KAFKA-14246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True resolved KAFKA-14246.
---
Resolution: Fixed
> Update threading model for Consumer
> ---
>
>
[
https://issues.apache.org/jira/browse/KAFKA-14246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-14246:
-
Assignee: Kirk True (was: Philip Nee)
> Update threading model for Consumer
>
[
https://issues.apache.org/jira/browse/KAFKA-16275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-16275:
-
Assignee: (was: Kirk True)
> Update kraft_upgrade_test.py to support KIP-848’s group
[
https://issues.apache.org/jira/browse/KAFKA-16389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-16389:
-
Assignee: (was: Kirk True)
> consumer_test.py’s test_valid_assignment fails with new
[
https://issues.apache.org/jira/browse/KAFKA-16275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17829660#comment-17829660
]
Kirk True commented on KAFKA-16275:
---
[~dajac] [[~lucasbru]—Does migrating this test to use the new
[
https://issues.apache.org/jira/browse/KAFKA-16275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-16275:
-
Assignee: Kirk True
> Update kraft_upgrade_test.py to support KIP-848’s group protocol config
[
https://issues.apache.org/jira/browse/KAFKA-16274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-16274:
-
Assignee: Kirk True
> Update replica_scale_test.py to support KIP-848’s group protocol config
[
https://issues.apache.org/jira/browse/KAFKA-16390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16390:
--
Summary: consume_bench_test.py failed using AsyncKafkaConsumer (was:
consumer_bench_test.py failed
[
https://issues.apache.org/jira/browse/KAFKA-16276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-16276:
-
Assignee: Kirk True
> Update transactions_test.py to support KIP-848’s group protocol config
>
[
https://issues.apache.org/jira/browse/KAFKA-16389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-16389:
-
Assignee: Kirk True (was: Lianet Magrans)
> consumer_test.py’s test_valid_assignment fails
[
https://issues.apache.org/jira/browse/KAFKA-16389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-16389:
-
Assignee: Lianet Magrans
> consumer_test.py’s test_valid_assignment fails with new consumer
>
[
https://issues.apache.org/jira/browse/KAFKA-16389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17828538#comment-17828538
]
Kirk True edited comment on KAFKA-16389 at 3/19/24 11:21 PM:
-
I've attached
[
https://issues.apache.org/jira/browse/KAFKA-16389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17828538#comment-17828538
]
Kirk True commented on KAFKA-16389:
---
I've attached a patch which _appears_ to address the issue in the
[
https://issues.apache.org/jira/browse/KAFKA-16389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16389:
--
Description:
The following error is reported when running the {{test_valid_assignment}} test
from
[
https://issues.apache.org/jira/browse/KAFKA-16389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16389:
--
Description:
The following error is reported when running the {{test_valid_assignment}} test
from
[
https://issues.apache.org/jira/browse/KAFKA-16389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16389:
--
Attachment: KAFKA-16389.patch
> consumer_test.py’s test_valid_assignment fails with new consumer
>
[
https://issues.apache.org/jira/browse/KAFKA-16389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16389:
--
Description:
The following error is reported when running the {{test_valid_assignment}} test
from
Kirk True created KAFKA-16389:
-
Summary: consumer_test.py’s test_valid_assignment fails with new
consumer
Key: KAFKA-16389
URL: https://issues.apache.org/jira/browse/KAFKA-16389
Project: Kafka
[
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
[
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
[
https://issues.apache.org/jira/browse/KAFKA-16190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17827594#comment-17827594
]
Kirk True commented on KAFKA-16190:
---
Thank you [~phong260702] for your help on this! :)
> Member
[
https://issues.apache.org/jira/browse/KAFKA-16375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17827587#comment-17827587
]
Kirk True commented on KAFKA-16375:
---
[~lianetm]—do we want this in 3.8?
> Fix logic for discarding
[
https://issues.apache.org/jira/browse/KAFKA-16274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-16274:
-
Assignee: (was: Philip Nee)
> Update replica_scale_test.py to support KIP-848’s group
[
https://issues.apache.org/jira/browse/KAFKA-16275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-16275:
-
Assignee: (was: Philip Nee)
> Update kraft_upgrade_test.py to support KIP-848’s group
[
https://issues.apache.org/jira/browse/KAFKA-16271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-16271:
-
Assignee: (was: Philip Nee)
> Update consumer_rolling_upgrade_test.py to support KIP-848’s
[
https://issues.apache.org/jira/browse/KAFKA-16276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-16276:
-
Assignee: (was: Philip Nee)
> Update transactions_test.py to support KIP-848’s group
[
https://issues.apache.org/jira/browse/KAFKA-16272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-16272:
-
Assignee: (was: Philip Nee)
> Update connect_distributed_test.py to support KIP-848’s
[
https://issues.apache.org/jira/browse/KAFKA-16276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-16276:
-
Assignee: Philip Nee (was: Kirk True)
> Update transactions_test.py to support KIP-848’s
[
https://issues.apache.org/jira/browse/KAFKA-16273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-16273:
-
Assignee: Philip Nee (was: Kirk True)
> Update consume_bench_test.py to support KIP-848’s
[
https://issues.apache.org/jira/browse/KAFKA-16271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-16271:
-
Assignee: Philip Nee (was: Kirk True)
> Update consumer_rolling_upgrade_test.py to support
[
https://issues.apache.org/jira/browse/KAFKA-16272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-16272:
-
Assignee: Philip Nee (was: Kirk True)
> Update connect_distributed_test.py to support
[
https://issues.apache.org/jira/browse/KAFKA-16275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-16275:
-
Assignee: Philip Nee (was: Kirk True)
> Update kraft_upgrade_test.py to support KIP-848’s
[
https://issues.apache.org/jira/browse/KAFKA-16274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-16274:
-
Assignee: Philip Nee (was: Kirk True)
> Update replica_scale_test.py to support KIP-848’s
[
https://issues.apache.org/jira/browse/KAFKA-15691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15691:
--
Summary: Update system tests to use AsyncKafkaConsumer (was: Update system
tests to use new
[
https://issues.apache.org/jira/browse/KAFKA-15691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15691:
--
Priority: Blocker (was: Major)
> Add new system tests to use new consumer
>
[
https://issues.apache.org/jira/browse/KAFKA-15691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reopened KAFKA-15691:
---
> Add new system tests to use new consumer
>
>
>
[
https://issues.apache.org/jira/browse/KAFKA-15691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15691:
--
Summary: Update system tests to use new consumer (was: Add new system
tests to use new consumer)
>
[
https://issues.apache.org/jira/browse/KAFKA-16269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16269:
--
Description:
This task is to update the test method(s) in {{reassign_partitions_test.py}} to
support
[
https://issues.apache.org/jira/browse/KAFKA-16270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16270:
--
Description:
This task is to update the test method(s) in {{snapshot_test.py}} to support
the
[
https://issues.apache.org/jira/browse/KAFKA-16275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16275:
--
Description:
This task is to update the test method(s) in {{kraft_upgrade_test.py}} to
support the
[
https://issues.apache.org/jira/browse/KAFKA-16273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16273:
--
Description:
This task is to update the test method(s) in {{consume_bench_test.py}} to
support the
[
https://issues.apache.org/jira/browse/KAFKA-16267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16267:
--
Description:
This task is to update the test method(s) in {{consumer_group_command_test.py}}
to
[
https://issues.apache.org/jira/browse/KAFKA-16269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16269:
--
Description:
This task is to update the test method(s) in {{reassign_partitions_test.py}} to
support
[
https://issues.apache.org/jira/browse/KAFKA-16268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16268:
--
Description:
This task is to update the test method(s) in {{fetch_from_follower_test.py}} to
support
[
https://issues.apache.org/jira/browse/KAFKA-16272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16272:
--
Description:
This task is to update the test method(s) in {{connect_distributed_test.py}} to
support
[
https://issues.apache.org/jira/browse/KAFKA-16274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16274:
--
Description:
This task is to update the test method(s) in {{replica_scale_test.py}} to
support the
[
https://issues.apache.org/jira/browse/KAFKA-16271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16271:
--
Description:
This task is to update the test method(s) in
{{consumer_rolling_upgrade_test.py}} to
[
https://issues.apache.org/jira/browse/KAFKA-16231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16231:
--
Description:
This task is to update {{consumer_test.py}} to support the {{group.protocol}}
[
https://issues.apache.org/jira/browse/KAFKA-16276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16276:
--
Description:
This task is to update the test method(s) in {{transactions_test.py}} to
support the
[
https://issues.apache.org/jira/browse/KAFKA-15250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15250:
--
Summary: ConsumerNetworkThread is running tight loop (was:
DefaultBackgroundThread is running tight
[
https://issues.apache.org/jira/browse/KAFKA-16255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16255:
--
Priority: Minor (was: Major)
> AsyncKafkaConsumer should not use partition.assignment.strategy
>
[
https://issues.apache.org/jira/browse/KAFKA-15553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15553:
--
Priority: Minor (was: Major)
> Review consumer positions update
>
>
[
https://issues.apache.org/jira/browse/KAFKA-16256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16256:
--
Priority: Minor (was: Major)
> Update ConsumerConfig to validate use of group.remote.assignor and
>
[
https://issues.apache.org/jira/browse/KAFKA-16298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-16298:
-
Assignee: Kirk True
> Ensure user callbacks exceptions are propagated to the user on consumer
[
https://issues.apache.org/jira/browse/KAFKA-15402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15402:
--
Labels: consumer-threading-refactor (was: )
> Performance regression on close consumer after
[
https://issues.apache.org/jira/browse/KAFKA-15402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15402:
--
Component/s: clients
> Performance regression on close consumer after upgrading to 3.5.0
>
[
https://issues.apache.org/jira/browse/KAFKA-16227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-16227:
-
Assignee: Bruno Cadonna (was: Philip Nee)
> Console consumer fails with
[
https://issues.apache.org/jira/browse/KAFKA-16224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-16224:
-
Assignee: Bruno Cadonna (was: Lianet Magrans)
> Fix handling of deleted topic when
[
https://issues.apache.org/jira/browse/KAFKA-16312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16312:
--
Priority: Critical (was: Major)
> ConsumerRebalanceListener.onPartitionsAssigned() should be called
[
https://issues.apache.org/jira/browse/KAFKA-16312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-16312:
-
Assignee: Lucas Brutschy (was: Lianet Magrans)
>
[
https://issues.apache.org/jira/browse/KAFKA-16315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-16315:
-
Assignee: Kirk True
> Investigate propagating metadata updates via queues
>
[
https://issues.apache.org/jira/browse/KAFKA-16290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17822246#comment-17822246
]
Kirk True commented on KAFKA-16290:
---
I just filed KAFKA-16315 which has a similar feel to this design
[
https://issues.apache.org/jira/browse/KAFKA-16290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16290:
--
Labels: consumer-threading-refactor kip-848 kip-848-client-support (was:
kip-848)
> Investigate
Kirk True created KAFKA-16315:
-
Summary: Investigate propagating metadata updates via queues
Key: KAFKA-16315
URL: https://issues.apache.org/jira/browse/KAFKA-16315
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-16290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17822245#comment-17822245
]
Kirk True commented on KAFKA-16290:
---
[~cadonna]—do we feel we have investigated this sufficiently? Are
[
https://issues.apache.org/jira/browse/KAFKA-16290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-16290:
-
Assignee: Bruno Cadonna (was: Kirk True)
> Investigate propagating subscription state updates
[
https://issues.apache.org/jira/browse/KAFKA-16290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17821910#comment-17821910
]
Kirk True commented on KAFKA-16290:
---
There are many {{Consumer}} APIs in which the
[
https://issues.apache.org/jira/browse/KAFKA-16227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16227:
--
Priority: Blocker (was: Critical)
> Console consumer fails with `IllegalStateException`
>
[
https://issues.apache.org/jira/browse/KAFKA-16312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16312:
--
Summary: ConsumerRebalanceListener.onPartitionsAssigned() should be called
after joining, even if
[
https://issues.apache.org/jira/browse/KAFKA-16185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17821811#comment-17821811
]
Kirk True commented on KAFKA-16185:
---
Please take a look at KAFKA-16312 to see if it is related.
> Fix
[
https://issues.apache.org/jira/browse/KAFKA-16312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17821810#comment-17821810
]
Kirk True commented on KAFKA-16312:
---
Perhaps KAFKA-16185 will resolve this, but in case it turns out
[
https://issues.apache.org/jira/browse/KAFKA-16312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16312:
--
Description:
There is a difference between the {{LegacyKafkaConsumer}} and
{{AsyncKafkaConsumer}}
301 - 400 of 2068 matches
Mail list logo
