[
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 p
[
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 upgradin
[
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 `IllegalStateException
[
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 auto-commit
[
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 a
[
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)
> ConsumerRebalanceListener.onPartitionsAssigne
[
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&focusedCommentId=17822246#comment-17822246
]
Kirk True commented on KAFKA-16290:
---
I just filed KAFKA-16315 which has a similar feel
[
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 prop
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: Tas
[
https://issues.apache.org/jira/browse/KAFKA-16290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17822245#comment-17822245
]
Kirk True commented on KAFKA-16290:
---
[~cadonna]—do we feel we have investigated this s
[
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&focusedCommentId=17821910#comment-17821910
]
Kirk True commented on KAFKA-16290:
---
There are many {{Consumer}} APIs in which the {{A
[
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 empt
[
https://issues.apache.org/jira/browse/KAFKA-16185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17821811#comment-17821811
]
Kirk True commented on KAFKA-16185:
---
Please take a look at KAFKA-16312 to see if it is
[
https://issues.apache.org/jira/browse/KAFKA-16312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17821810#comment-17821810
]
Kirk True commented on KAFKA-16312:
---
Perhaps KAFKA-16185 will resolve this, but in cas
[
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}} res
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&focusedCommentId=17821352#comment-17821352
]
Kirk True commented on KAFKA-15878:
---
[~philomathanuj]—are you able to assign this Jira
[
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 SASL/OAUTHBEA
[
https://issues.apache.org/jira/browse/KAFKA-16160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17820747#comment-17820747
]
Kirk True commented on KAFKA-16160:
---
[~pnee]—do you have some insights on how [~phuctr
[
https://issues.apache.org/jira/browse/KAFKA-16190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17820746#comment-17820746
]
Kirk True commented on KAFKA-16190:
---
[~lucasbru]—could you take a look at the pull req
[
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 excepti
[
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
> PlaintextConsumerTest.testStaticConsumerDet
[
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 PlaintextConsumerTest.testMultiConsumerSession
[
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 PlaintextConsumerTest.testAutoCommitOnCloseAft
[
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 respect
[
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-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-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-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
> configu
[
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&focusedCommentId=17818983#comment-17818983
]
Kirk True commented on KAFKA-16019:
---
{{testPerPartitionLeadMetricsCleanUpWithSubscribe
[
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,
s
[
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&focusedCommentId=17818981#comment-17818981
]
Kirk True commented on KAFKA-15993:
---
Closing this as it will be covered when the follo
[
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 user-provided
[
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 wait
[
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 wait
[
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 Reque
[
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 r
[
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 A
[
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
{{{}AsyncK
[
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 implementation
[
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
> co
[
https://issues.apache.org/jira/browse/KAFKA-16160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17818978#comment-17818978
]
Kirk True commented on KAFKA-16160:
---
[~phuctran] same question on this one—do you need
[
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 a
[
https://issues.apache.org/jira/browse/KAFKA-15538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17818977#comment-17818977
]
Kirk True commented on KAFKA-15538:
---
[~phuctran] thanks for your willingness to help o
[
https://issues.apache.org/jira/browse/KAFKA-16190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17818976#comment-17818976
]
Kirk True commented on KAFKA-16190:
---
[~phong260702] thanks for your willingness to hel
[
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 {{Co
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
Iss
[
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 tri
[
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 tri
[
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 async
[
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 onPartit
[
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 K
[
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 even
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
801 - 900 of 1438 matches
Mail list logo
