Re: [DISCUSS] KIP-726: Make the CooperativeStickyAssignor as the default assignor

2021-06-09 Thread Ryan Leslie
Thanks for the quick replies, Luke and Sophie. I've not voted, but I agree with accepting the KIP since it's a superior feature. I was just reacting mostly to this comment since it didn't mention open issues: > > > Thanks Luke. We may as well get this KIP in to 3.0 so that we can fully > > > en

[jira] [Created] (KAFKA-6479) Broker file descriptor leak after consumer request timeout

2018-01-24 Thread Ryan Leslie (JIRA)
Ryan Leslie created KAFKA-6479: -- Summary: Broker file descriptor leak after consumer request timeout Key: KAFKA-6479 URL: https://issues.apache.org/jira/browse/KAFKA-6479 Project: Kafka Issue

[jira] [Created] (KAFKA-6287) Inconsistent protocol type for empty consumer groups

2017-11-30 Thread Ryan Leslie (JIRA)
Ryan Leslie created KAFKA-6287: -- Summary: Inconsistent protocol type for empty consumer groups Key: KAFKA-6287 URL: https://issues.apache.org/jira/browse/KAFKA-6287 Project: Kafka Issue Type

[jira] [Created] (KAFKA-16235) auto commit still causes delays due to retriable UNKNOWN_TOPIC_OR_PARTITION

2024-02-07 Thread Ryan Leslie (Jira)
Ryan Leslie created KAFKA-16235: --- Summary: auto commit still causes delays due to retriable UNKNOWN_TOPIC_OR_PARTITION Key: KAFKA-16235 URL: https://issues.apache.org/jira/browse/KAFKA-16235 Project

[jira] [Created] (KAFKA-12256) auto commit causes delays due to retribale UNKNOWN_TOPIC_OR_PARTITION

2021-01-29 Thread Ryan Leslie (Jira)
Ryan Leslie created KAFKA-12256: --- Summary: auto commit causes delays due to retribale UNKNOWN_TOPIC_OR_PARTITION Key: KAFKA-12256 URL: https://issues.apache.org/jira/browse/KAFKA-12256 Project: Kafka

[jira] [Created] (KAFKA-12257) Consumer mishandles topics deleted and recreated with the same name

2021-01-29 Thread Ryan Leslie (Jira)
Ryan Leslie created KAFKA-12257: --- Summary: Consumer mishandles topics deleted and recreated with the same name Key: KAFKA-12257 URL: https://issues.apache.org/jira/browse/KAFKA-12257 Project: Kafka

[jira] [Created] (KAFKA-13435) Group won't consume partitions added after static member restart

2021-11-05 Thread Ryan Leslie (Jira)
Ryan Leslie created KAFKA-13435: --- Summary: Group won't consume partitions added after static member restart Key: KAFKA-13435 URL: https://issues.apache.org/jira/browse/KAFKA-13435 Project:

subscribe

2015-12-08 Thread Ryan Leslie (BLOOMBERG/ 731 LEX)
subscribe

Re: [VOTE] KIP-814: Static membership protocol should let the leader skip assignment

2022-02-01 Thread Ryan Leslie (BLOOMBERG/ 919 3RD A)
Thanks, David. +1 (non-binding) From: show...@gmail.com At: 01/31/22 22:13:57 UTC-5:00To: dev@kafka.apache.org Subject: Re: [VOTE] KIP-814: Static membership protocol should let the leader skip assignment Hi David, Thanks for the KIP. I'm +1(non-binding) Thanks. Luke Jason Gustafson 於 202

Re: [DISCUSS] KIP-822: Optimize the semantics of KafkaConsumer#pause to be consistent between the two RebalanceProtocols

2022-02-14 Thread Ryan Leslie (BLOOMBERG/ 919 3RD A)
Apologies, but as worded KIP-822 / KAFKA-13425 are a bit challenging to follow. I've used pause() between version 0.10 and 2.7 with EAGER protocol only and have not yet observed cases where poll() returned messages unless resume() had been called. The KIP seems to contradict this though, and ind

Re: [DISCUSS] KIP-822: Optimize the semantics of KafkaConsumer#pause to be consistent between the two RebalanceProtocols

2022-02-16 Thread Ryan Leslie (BLOOMBERG/ 919 3RD A)
To: RYAN LESLIE, dev@kafka.apache.org At: 02/16/22 22:02:41 UTC-05:00 Hi Ryan, > I've used pause() between version 0.10 and 2.7 with EAGER protocol only and have not yet observed cases where poll() returned messages unless resume() had been called. Yes, this issue only happens wh

Re:Timeout not getting applied on KafkaAdminClient.create

2023-02-13 Thread Ryan Leslie (BLP/ NEW YORK (REMOT)
If the broker connection is timing out then see if tuning SOCKET_CONNECTION_SETUP_TIMEOUT_MAX_MS_CONFIG / SOCKET_CONNECTION_SETUP_TIMEOUT_MS_CONFIG helps. The MAX defaults to 30 seconds. From: dev@kafka.apache.org At: 02/13/23 08:46:12 UTC-5:00To: dev@kafka.apache.org Subject: Timeout not gett

Re: [DISCUSS] KIP-726: Make the CooperativeStickyAssignor as the default assignor

2021-06-07 Thread Ryan Leslie (BLOOMBERG/ 919 3RD A)
Hey guys, Should open bugs concerning cooperative-sticky also be considered blockers to making it the default? For example, KAFKA-12896 is perhaps still being investigated: https://issues.apache.org/jira/browse/KAFKA-12896 Thanks, Ryan From: dev@kafka.apache.org At: 06/07/21 19:37:45 UTC-4:0

Re:[DISCUSS] KIP-700: Add Describe Cluster API

2020-12-14 Thread Ryan Leslie (BLOOMBERG/ 919 3RD A)
e is a better way to do this. Thanks, Ryan Leslie