Kirk True created KAFKA-16312:
-
Summary: ConsumerRebalanceListener.onPartitionsAssigned should be
called after joining, even if empty
Key: KAFKA-16312
URL: https://issues.apache.org/jira/browse/KAFKA-16312
[
https://issues.apache.org/jira/browse/KAFKA-16290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-16290:
-
Assignee: Kirk True
> Investigate propagating subscription state updates via queues
>
[
https://issues.apache.org/jira/browse/KAFKA-15878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17821352#comment-17821352
]
Kirk True commented on KAFKA-15878:
---
[~philomathanuj]—are you able to assign this Jira to yourself? I
[
https://issues.apache.org/jira/browse/KAFKA-15878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-15878:
-
Assignee: Kirk True
> KIP-768: Extend support for opaque (i.e. non-JWT) tokens in
[
https://issues.apache.org/jira/browse/KAFKA-16160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17820747#comment-17820747
]
Kirk True commented on KAFKA-16160:
---
[~pnee]—do you have some insights on how [~phuctran] can
[
https://issues.apache.org/jira/browse/KAFKA-16190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17820746#comment-17820746
]
Kirk True commented on KAFKA-16190:
---
[~lucasbru]—could you take a look at the pull request for this
[
https://issues.apache.org/jira/browse/KAFKA-16301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16301:
--
Fix Version/s: 3.8.0
> Review fenced member unsubscribe/subscribe callbacks interaction
>
[
https://issues.apache.org/jira/browse/KAFKA-16298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16298:
--
Fix Version/s: 3.8.0
> Ensure user callbacks exceptions are propagated to the user on consumer poll
>
[
https://issues.apache.org/jira/browse/KAFKA-16298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16298:
--
Labels: callback kip-848-client-support (was: kip-848-client-support)
> Ensure user callbacks
[
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
>
[
https://issues.apache.org/jira/browse/KAFKA-16008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-16008:
-
Assignee: Lucas Brutschy (was: Philip Nee)
> Fix PlaintextConsumerTest.testMaxPollIntervalMs
[
https://issues.apache.org/jira/browse/KAFKA-16152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-16152:
-
Assignee: Lucas Brutschy (was: Kirk True)
> Fix
>
[
https://issues.apache.org/jira/browse/KAFKA-16010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-16010:
-
Assignee: Lucas Brutschy (was: Kirk True)
> Fix
[
https://issues.apache.org/jira/browse/KAFKA-16167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-16167:
-
Assignee: Lucas Brutschy (was: Kirk True)
> Fix
[
https://issues.apache.org/jira/browse/KAFKA-16200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-16200:
-
Assignee: Bruno Cadonna (was: Kirk True)
> Enforce that RequestManager implementations
[
https://issues.apache.org/jira/browse/KAFKA-16008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-16008:
-
Assignee: Philip Nee (was: Kirk True)
> Fix PlaintextConsumerTest.testMaxPollIntervalMs
>
[
https://issues.apache.org/jira/browse/KAFKA-16200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reopened KAFKA-16200:
---
> Enforce that RequestManager implementations respect user-provided timeout
>
[
https://issues.apache.org/jira/browse/KAFKA-15475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True resolved KAFKA-15475.
---
Resolution: Fixed
> Request might retry forever even if the user API timeout expires
>
[
https://issues.apache.org/jira/browse/KAFKA-16233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-16233:
-
Assignee: Philip Nee
> Review auto-commit continuously committing when no progress
>
[
https://issues.apache.org/jira/browse/KAFKA-16261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16261:
--
Fix Version/s: 3.8.0
> MembershipManagerImpl.updateSubscription fails if already empty subscription
>
[
https://issues.apache.org/jira/browse/KAFKA-16233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16233:
--
Fix Version/s: 3.8.0
> Review auto-commit continuously committing when no progress
>
[
https://issues.apache.org/jira/browse/KAFKA-15694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15694:
--
Fix Version/s: 3.8.0
> New integration tests to have full coverage for preview
>
[
https://issues.apache.org/jira/browse/KAFKA-15840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15840:
--
Fix Version/s: 3.7.0
> Correct initialization of ConsumerGroupHeartbeat by client
>
[
https://issues.apache.org/jira/browse/KAFKA-15651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15651:
--
Fix Version/s: 3.7.0
> Investigate auto commit guarantees during Consumer.assign()
>
[
https://issues.apache.org/jira/browse/KAFKA-15631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15631:
--
Fix Version/s: 3.7.0
> Do not send new heartbeat request while another one in-flight
>
[
https://issues.apache.org/jira/browse/KAFKA-16261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16261:
--
Component/s: consumer
> MembershipManagerImpl.updateSubscription fails if already empty subscription
[
https://issues.apache.org/jira/browse/KAFKA-15543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15543:
--
Fix Version/s: 3.7.0
> Send HB request right after reconciliation completes
>
[
https://issues.apache.org/jira/browse/KAFKA-15573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15573:
--
Fix Version/s: 3.7.0
> Implement auto-commit on partition assignment revocation
>
[
https://issues.apache.org/jira/browse/KAFKA-15592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15592:
--
Fix Version/s: 3.7.0
> Member does not need to always try to join a group when a groupId is
>
[
https://issues.apache.org/jira/browse/KAFKA-15540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15540:
--
Fix Version/s: 3.7.0
> Handle heartbeat and revocation when consumer leaves group
>
[
https://issues.apache.org/jira/browse/KAFKA-15539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15539:
--
Fix Version/s: 3.7.0
> Client should stop fetching while partitions being revoked
>
[
https://issues.apache.org/jira/browse/KAFKA-15515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15515:
--
Fix Version/s: 3.7.0
> Remove duplicated integration tests for new consumer
>
[
https://issues.apache.org/jira/browse/KAFKA-16224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16224:
--
Fix Version/s: 3.8.0
> Fix handling of deleted topic when auto-committing before revocation
>
[
https://issues.apache.org/jira/browse/KAFKA-16251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16251:
--
Fix Version/s: 3.8.0
> Fenced member should not send heartbeats while waiting for onPartitionsLost
>
[
https://issues.apache.org/jira/browse/KAFKA-16199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True resolved KAFKA-16199.
---
Resolution: Duplicate
> Prune the event queue if event timeout expired before starting
>
[
https://issues.apache.org/jira/browse/KAFKA-16200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True resolved KAFKA-16200.
---
Resolution: Duplicate
> Enforce that RequestManager implementations respect user-provided timeout
>
[
https://issues.apache.org/jira/browse/KAFKA-16019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818983#comment-17818983
]
Kirk True commented on KAFKA-16019:
---
{{testPerPartitionLeadMetricsCleanUpWithSubscribe}} is now
[
https://issues.apache.org/jira/browse/KAFKA-16019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True resolved KAFKA-16019.
---
Resolution: Fixed
> Some of the tests in PlaintextConsumer can't seem to deterministically invoke
[
https://issues.apache.org/jira/browse/KAFKA-16023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True resolved KAFKA-16023.
---
Resolution: Fixed
{{testPerPartitionLagMetricsCleanUpWithSubscribe}} is now passing consistently,
[
https://issues.apache.org/jira/browse/KAFKA-15993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True resolved KAFKA-15993.
---
Resolution: Duplicate
> Enable max poll integration tests that depend on callback invocation
>
[
https://issues.apache.org/jira/browse/KAFKA-16010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16010:
--
Issue Type: Bug (was: Test)
> Fix PlaintextConsumerTest.testMultiConsumerSessionTimeoutOnStopPolling
[
https://issues.apache.org/jira/browse/KAFKA-15993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818981#comment-17818981
]
Kirk True commented on KAFKA-15993:
---
Closing this as it will be covered when the following Jiras are
[
https://issues.apache.org/jira/browse/KAFKA-16200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16200:
--
Priority: Blocker (was: Critical)
> Enforce that RequestManager implementations respect
[
https://issues.apache.org/jira/browse/KAFKA-15974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15974:
--
Description:
The intention of the {{CompletableApplicationEvent}} is for a {{Consumer}} to
block
[
https://issues.apache.org/jira/browse/KAFKA-16200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16200:
--
Description:
The intention of the {{CompletableApplicationEvent}} is for a {{Consumer}} to
block
[
https://issues.apache.org/jira/browse/KAFKA-16200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16200:
--
Summary: Enforce that RequestManager implementations respect user-provided
timeout (was: Ensure
[
https://issues.apache.org/jira/browse/KAFKA-15974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15974:
--
Summary: Enforce that event processing respects user-provided timeout
(was: Enforce that events and
[
https://issues.apache.org/jira/browse/KAFKA-15848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15848:
--
Summary: Design solution for inconsistency between ConsumerDelegate timeout
policies (was: Consumer
[
https://issues.apache.org/jira/browse/KAFKA-16208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True resolved KAFKA-16208.
---
Resolution: Duplicate
> Design new Consumer timeout policy
> --
>
>
[
https://issues.apache.org/jira/browse/KAFKA-15848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15848:
--
Description:
The two {{ConsumerDelegate}} implementations ({{{}LegacyKafkaConsumer{}}} and
[
https://issues.apache.org/jira/browse/KAFKA-15848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15848:
--
Component/s: documentation
> Consumer API timeout inconsistent between ConsumerDelegate
[
https://issues.apache.org/jira/browse/KAFKA-16285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16285:
--
Fix Version/s: 3.8.0
> Make group metadata available when a new assignment is set in async Kafka
>
[
https://issues.apache.org/jira/browse/KAFKA-16160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818978#comment-17818978
]
Kirk True commented on KAFKA-16160:
---
[~phuctran] same question on this one—do you need any more help
[
https://issues.apache.org/jira/browse/KAFKA-16160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16160:
--
Priority: Major (was: Critical)
> AsyncKafkaConsumer is trying to connect to a disconnected node in
[
https://issues.apache.org/jira/browse/KAFKA-15538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818977#comment-17818977
]
Kirk True commented on KAFKA-15538:
---
[~phuctran] thanks for your willingness to help out on this task!
[
https://issues.apache.org/jira/browse/KAFKA-16190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818976#comment-17818976
]
Kirk True commented on KAFKA-16190:
---
[~phong260702] thanks for your willingness to help out on this
[
https://issues.apache.org/jira/browse/KAFKA-16227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-16227:
-
Assignee: Philip Nee
> Console consumer fails with `IllegalStateException`
>
[
https://issues.apache.org/jira/browse/KAFKA-16199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16199:
--
Priority: Major (was: Critical)
> Prune the event queue if event timeout expired before starting
>
[
https://issues.apache.org/jira/browse/KAFKA-16111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16111:
--
Affects Version/s: 3.7.0
> Implement tests for tricky rebalance callback scenarios
>
[
https://issues.apache.org/jira/browse/KAFKA-16287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16287:
--
Affects Version/s: 3.7.0
> Implement example test for common rebalance callback scenarios
>
[
https://issues.apache.org/jira/browse/KAFKA-16111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16111:
--
Priority: Major (was: Blocker)
> Implement tests for tricky rebalance callback scenarios
>
[
https://issues.apache.org/jira/browse/KAFKA-16287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16287:
--
Description:
We need to add an example test to the {{PlaintextConsumerTest}} that tests a
common
Kirk True created KAFKA-16287:
-
Summary: Implement example test for common rebalance callback
scenarios
Key: KAFKA-16287
URL: https://issues.apache.org/jira/browse/KAFKA-16287
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-16111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16111:
--
Summary: Implement tests for tricky rebalance callback scenarios (was:
Implement example test for
[
https://issues.apache.org/jira/browse/KAFKA-16111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16111:
--
Summary: Implement example test for tricky rebalance callback scenarios
(was: Implement tests for
[
https://issues.apache.org/jira/browse/KAFKA-16111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16111:
--
Summary: Implement tests for tricky rebalance callback scenarios (was:
Implement tests for rebalance
[
https://issues.apache.org/jira/browse/KAFKA-16111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16111:
--
Summary: Implement tests for rebalance callback scenarios (was: Implement
tests for tricky rebalance
[
https://issues.apache.org/jira/browse/KAFKA-16285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16285:
--
Priority: Critical (was: Major)
> Make group metadata available when a new assignment is set in
[
https://issues.apache.org/jira/browse/KAFKA-16258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16258:
--
Priority: Critical (was: Major)
> Stale member should trigger onPartitionsLost when leaving group
>
[
https://issues.apache.org/jira/browse/KAFKA-16251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16251:
--
Priority: Critical (was: Major)
> Fenced member should not send heartbeats while waiting for
[
https://issues.apache.org/jira/browse/KAFKA-15561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15561:
--
Priority: Major (was: Critical)
> Client support for new SubscriptionPattern based subscription
>
[
https://issues.apache.org/jira/browse/KAFKA-15538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15538:
--
Priority: Blocker (was: Critical)
> Client support for java regex based subscription
>
[
https://issues.apache.org/jira/browse/KAFKA-16111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-16111:
-
Assignee: Lucas Brutschy
> Implement tests for tricky rebalance callback scenarios
>
[
https://issues.apache.org/jira/browse/KAFKA-16285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-16285:
-
Assignee: Bruno Cadonna
> Make group metadata available when a new assignment is set in async
[
https://issues.apache.org/jira/browse/KAFKA-16277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16277:
--
Component/s: clients
consumer
> CooperativeStickyAssignor does not spread topics
Kirk True created KAFKA-16276:
-
Summary: Update transactions_test.py to support KIP-848’s group
protocol config
Key: KAFKA-16276
URL: https://issues.apache.org/jira/browse/KAFKA-16276
Project: Kafka
Kirk True created KAFKA-16275:
-
Summary: Update kraft_upgrade_test.py to support KIP-848’s group
protocol config
Key: KAFKA-16275
URL: https://issues.apache.org/jira/browse/KAFKA-16275
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-16274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818211#comment-17818211
]
Kirk True commented on KAFKA-16274:
---
There's an issue here in that the {{ConsumeBenchWorkloadService}}
Kirk True created KAFKA-16274:
-
Summary: Update replica_scale_test.py to support KIP-848’s group
protocol config
Key: KAFKA-16274
URL: https://issues.apache.org/jira/browse/KAFKA-16274
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-16273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818210#comment-17818210
]
Kirk True commented on KAFKA-16273:
---
There's an issue here in that the {{ConsumeBenchWorkloadService}}
Kirk True created KAFKA-16272:
-
Summary: Update connect_distributed_test.py to support KIP-848’s
group protocol config
Key: KAFKA-16272
URL: https://issues.apache.org/jira/browse/KAFKA-16272
Project:
Kirk True created KAFKA-16271:
-
Summary: Update consumer_rolling_upgrade_test.py to support
KIP-848’s group protocol config
Key: KAFKA-16271
URL: https://issues.apache.org/jira/browse/KAFKA-16271
Kirk True created KAFKA-16273:
-
Summary: Update consume_bench_test.py to support KIP-848’s group
protocol config
Key: KAFKA-16273
URL: https://issues.apache.org/jira/browse/KAFKA-16273
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-16231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818209#comment-17818209
]
Kirk True commented on KAFKA-16231:
---
Progress has been made on this. The static membership tests have
Kirk True created KAFKA-16270:
-
Summary: Update snapshot_test.py to support KIP-848’s group
protocol config
Key: KAFKA-16270
URL: https://issues.apache.org/jira/browse/KAFKA-16270
Project: Kafka
Kirk True created KAFKA-16269:
-
Summary: Update reassign_partitions_test.py to support KIP-848’s
group protocol config
Key: KAFKA-16269
URL: https://issues.apache.org/jira/browse/KAFKA-16269
Project:
Kirk True created KAFKA-16268:
-
Summary: Update fetch_from_follower_test.py to support KIP-848’s
group protocol config
Key: KAFKA-16268
URL: https://issues.apache.org/jira/browse/KAFKA-16268
Project:
Kirk True created KAFKA-16267:
-
Summary: Update consumer_group_command_test.py to support
KIP-848’s group protocol config
Key: KAFKA-16267
URL: https://issues.apache.org/jira/browse/KAFKA-16267
Project:
[
https://issues.apache.org/jira/browse/KAFKA-16256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-16256:
-
Assignee: Kirk True
> Update ConsumerConfig to validate use of group.remote.assignor and
>
Kirk True created KAFKA-16256:
-
Summary: Update ConsumerConfig to validate use of
group.remote.assignor and partition.assignment.strategy based on group.protocol
Key: KAFKA-16256
URL:
[
https://issues.apache.org/jira/browse/KAFKA-16255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16255:
--
Description: The {{partition.assignment.strategy}} configuration is used to
specify a list of zero or
Kirk True created KAFKA-16255:
-
Summary: AsyncKafkaConsumer should not use
partition.assignment.strategy
Key: KAFKA-16255
URL: https://issues.apache.org/jira/browse/KAFKA-16255
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-16243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16243:
--
Priority: Critical (was: Major)
> Idle kafka-console-consumer with new consumer group protocol
[
https://issues.apache.org/jira/browse/KAFKA-16235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16235:
--
Component/s: clients
> auto commit still causes delays due to retriable UNKNOWN_TOPIC_OR_PARTITION
>
[
https://issues.apache.org/jira/browse/KAFKA-16001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-16001:
-
Assignee: (was: Kirk True)
> Migrate ConsumerNetworkThreadTest away from
[
https://issues.apache.org/jira/browse/KAFKA-15638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15638:
--
Labels: consumer-threading-refactor timeout unit-tests (was:
consumer-threading-refactor unit-tests)
[
https://issues.apache.org/jira/browse/KAFKA-15615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-15615:
-
Assignee: (was: Kirk True)
> Improve handling of fetching during metadata updates
>
[
https://issues.apache.org/jira/browse/KAFKA-15639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-15639:
-
Assignee: (was: Kirk True)
> Investigate ConsumerNetworkThreadTest's
>
[
https://issues.apache.org/jira/browse/KAFKA-16156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-16156:
-
Assignee: Philip Nee
> System test failing for new consumer on endOffsets with negative
401 - 500 of 2068 matches
Mail list logo
