[
https://issues.apache.org/jira/browse/KAFKA-16211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17819095#comment-17819095
]
Deng Ziming commented on KAFKA-16211:
-
{code:java}
// code placeholder
@ExtendWith(value =
[
https://issues.apache.org/jira/browse/KAFKA-16190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17819081#comment-17819081
]
Quoc Phong Dang commented on KAFKA-16190:
-
[~kirktrue] Sorry for the delay, I've just create a
phong260702 opened a new pull request, #15401:
URL: https://github.com/apache/kafka/pull/15401
When the consumer rejoins, heartbeat request builder make sure that all
fields are sent in the heartbeat request.
### Committer Checklist (excluded from commit message)
- [ ] Verify
[ https://issues.apache.org/jira/browse/KAFKA-16190 ]
Quoc Phong Dang deleted comment on KAFKA-16190:
-
was (Author: JIRAUSER303789):
[~kirktrue] Thank you and sorry for the dely, It takes my sometime to look into
the KIP and trying to
ericzhifengchen commented on PR #15376:
URL: https://github.com/apache/kafka/pull/15376#issuecomment-1955880312
Hi Mayank,
My github account is ***@***.***
Thanks,
Zhifeng
On Mon, Feb 19, 2024 at 4:22 AM Mayank Shekhar Narula <
***@***.***> wrote:
>
[
https://issues.apache.org/jira/browse/KAFKA-16283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen updated KAFKA-16283:
--
Description:
When using `org.apache.kafka.clients.producer.RoundRobinPartitioner`, we expect
data
[
https://issues.apache.org/jira/browse/KAFKA-16283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen updated KAFKA-16283:
--
Description:
When using `org.apache.kafka.clients.producer.RoundRobinPartitioner`, we expect
data
[
https://issues.apache.org/jira/browse/KAFKA-16283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17819057#comment-17819057
]
ASF GitHub Bot commented on KAFKA-16283:
showuon opened a new pull request, #585:
URL:
showuon opened a new pull request, #15400:
URL: https://github.com/apache/kafka/pull/15400
Add notes in "3.7.0 notable changes" and "config doc" to notify users not to
use `RoundRobinPartitioner`.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and
[
https://issues.apache.org/jira/browse/KAFKA-16283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen updated KAFKA-16283:
--
Affects Version/s: 3.6.1
3.0.0
3.1.0
>
[
https://issues.apache.org/jira/browse/KAFKA-16283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen updated KAFKA-16283:
--
Description:
When using `org.apache.kafka.clients.producer.RoundRobinPartitioner`, we expect
data
[
https://issues.apache.org/jira/browse/KAFKA-16283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen updated KAFKA-16283:
--
Description:
When using `org.apache.kafka.clients.producer.RoundRobinPartitioner`, we expect
data
[
https://issues.apache.org/jira/browse/KAFKA-16283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen updated KAFKA-16283:
--
Description:
When using `org.apache.kafka.clients.producer.RoundRobinPartitioner`, we expect
data
C0urante commented on code in PR #15399:
URL: https://github.com/apache/kafka/pull/15399#discussion_r1496759639
##
connect/api/src/test/java/org/apache/kafka/connect/data/ValuesTest.java:
##
@@ -744,6 +785,32 @@ public void shouldConvertTimestampValues() {
[
https://issues.apache.org/jira/browse/KAFKA-16190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818979#comment-17818979
]
Quoc Phong Dang edited comment on KAFKA-16190 at 2/21/24 1:11 AM:
--
[
https://issues.apache.org/jira/browse/KAFKA-6675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Harris resolved KAFKA-6675.
Fix Version/s: 3.6.0
Assignee: Greg Harris (was: Valeria Vasylieva)
Resolution:
gharris1727 commented on PR #15386:
URL: https://github.com/apache/kafka/pull/15386#issuecomment-1955537975
Hi @dengziming @jolshan @rajinisivaram Could you PTAL at this documentation
change?
Going off of KIP-516 and the discussion on the PRs which added topic IDs to
the metadata
jeffkbkim commented on code in PR #15364:
URL: https://github.com/apache/kafka/pull/15364#discussion_r1496700583
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java:
##
@@ -1211,13 +1192,99 @@ private
CoordinatorResult consumerGr
[
https://issues.apache.org/jira/browse/KAFKA-16212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17819023#comment-17819023
]
Justine Olshan commented on KAFKA-16212:
We use something similar in the fetch session cache
gharris1727 opened a new pull request, #15399:
URL: https://github.com/apache/kafka/pull/15399
See the descriptions of the tickets for full details:
* https://issues.apache.org/jira/browse/KAFKA-16288 convertToDecimal
* https://issues.apache.org/jira/browse/KAFKA-16289 parseString
[
https://issues.apache.org/jira/browse/KAFKA-16277?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17819013#comment-17819013
]
Cameron Redpath commented on KAFKA-16277:
-
Thanks [~ableegoldman] for the response - yes we will
Greg Harris created KAFKA-16289:
---
Summary: Values.parseString on heterogeneous lists and maps
sometimes corrupts data by inferring incorrect schema
Key: KAFKA-16289
URL:
[
https://issues.apache.org/jira/browse/KAFKA-16160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17819009#comment-17819009
]
Phuc Hong Tran edited comment on KAFKA-16160 at 2/20/24 11:15 PM:
--
Also
jolshan merged PR #15320:
URL: https://github.com/apache/kafka/pull/15320
--
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:
[
https://issues.apache.org/jira/browse/KAFKA-16160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17819009#comment-17819009
]
Phuc Hong Tran commented on KAFKA-16160:
Also after some findings, I’m thinking that this one is
[
https://issues.apache.org/jira/browse/KAFKA-15538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17819008#comment-17819008
]
Phuc Hong Tran commented on KAFKA-15538:
I can put up a pull request for this ticket by this
[
https://issues.apache.org/jira/browse/KAFKA-16281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17819007#comment-17819007
]
Calvin Liu commented on KAFKA-16281:
[~alivshits] Jack has corrected that the issue is with KIP-996
[
https://issues.apache.org/jira/browse/KAFKA-16160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17819005#comment-17819005
]
Phuc Hong Tran commented on KAFKA-16160:
[~kirktrue] I was not able to reproduce this scenario
[
https://issues.apache.org/jira/browse/KAFKA-16281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17819004#comment-17819004
]
Artem Livshits commented on KAFKA-16281:
Is this a problem with KIP-966 or just a model that was
[
https://issues.apache.org/jira/browse/KAFKA-16160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17819003#comment-17819003
]
Phuc Hong Tran commented on KAFKA-16160:
For this one, I do need some helps.
>
[
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
wcarlson5 commented on code in PR #15396:
URL: https://github.com/apache/kafka/pull/15396#discussion_r1496604182
##
streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractRocksDBSegmentedBytesStore.java:
##
@@ -264,7 +264,6 @@ public void put(final Bytes key,
[
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-16241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson updated KAFKA-16241:
---
Priority: Critical (was: Major)
> Kafka Streams hits IllegalStateException trying to
[
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
>
jolshan commented on code in PR #15384:
URL: https://github.com/apache/kafka/pull/15384#discussion_r1496555226
##
tools/src/main/java/org/apache/kafka/tools/TransactionsCommand.java:
##
@@ -436,16 +436,26 @@ public String name() {
@Override
public void
[
https://issues.apache.org/jira/browse/KAFKA-16212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818991#comment-17818991
]
Omnia Ibrahim commented on KAFKA-16212:
---
I don't believe ReplicaManager have significant meaning
[
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-16284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-16284:
Affects Version/s: 3.8.0
> Performance regression in RocksDB
>
[
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
>
jsancio commented on PR #15397:
URL: https://github.com/apache/kafka/pull/15397#issuecomment-1955046620
> Is there any chance we could fire leader change more than once on a
transition? (I guess this might be allowable behavior?)
Thanks. I updated the KRaft tests to check that there
[
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
mjsax merged PR #15219:
URL: https://github.com/apache/kafka/pull/15219
--
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:
[
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-16190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818979#comment-17818979
]
Quoc Phong Dang commented on KAFKA-16190:
-
[~kirktrue] Thank you and sorry for the dely, It
[
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!
Greg Harris created KAFKA-16288:
---
Summary: Values.convertToDecimal throws ClassCastExceptions on
String inputs
Key: KAFKA-16288
URL: https://issues.apache.org/jira/browse/KAFKA-16288
Project: Kafka
[
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
>
anton-liauchuk commented on PR #15398:
URL: https://github.com/apache/kafka/pull/15398#issuecomment-1954961890
hello @divijvaidya
Please take a look.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
[
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
anton-liauchuk opened a new pull request, #15398:
URL: https://github.com/apache/kafka/pull/15398
KAFKA-16278 Missing license for scala related dependencies
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage
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
>
1 - 100 of 205 matches
Mail list logo
