[jira] [Created] (KAFKA-14328) KafkaAdminClient should be Changing the exception level When an exception occurs

shizhenzhen created KAFKA-14328: --- Summary: KafkaAdminClient should be Changing the exception level When an exception occurs Key: KAFKA-14328 URL: https://issues.apache.org/jira/browse/KAFKA-14328

Re: [VOTE] KIP-869: Improve Streams State Restoration Visibility

Thanks for the KIP, Guozhang! I'm +1 (binding) -John On Wed, Oct 12, 2022, at 16:36, Nick Telford wrote: > Can't wait! > +1 (non-binding) > > On Wed, 12 Oct 2022, 18:02 Guozhang Wang, > wrote: > >> Hello all, >> >> I'd like to start a vote for the following KIP, aiming to improve Kafka >>

Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #1314

See

Re: [DISCUSS] KIP-878: Autoscaling for Statically Partitioned Streams

Thanks for the responses guys! I'll get the easy stuff out of the way first: 1) Fixed the KIP so that StaticStreamPartitioner extends StreamPartitioner 2) I totally agree with you Colt, the record value might have valuable (no pun) information in it that is needed to compute the partition without

[jira] [Resolved] (KAFKA-14123) Delete with null value not supported in Streams PersistantWindowsStore

[ https://issues.apache.org/jira/browse/KAFKA-14123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman resolved KAFKA-14123. Resolution: Not A Problem > Delete with null value not supported in

Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #1313

See

Re: [DISCUSS] KIP-864: Add End-To-End Latency Metrics to Connectors

Thanks, Chris! Great feedback! Please, find my comments below: On Thu, 13 Oct 2022 at 18:52, Chris Egerton wrote: > Hi Jorge, > > Thanks for the KIP. I agree with the overall direction and think this would > be a nice improvement to Kafka Connect. Here are my initial thoughts on the > details:

[jira] [Created] (KAFKA-14327) Unify KRaft snapshot generation between broker and controller

Colin McCabe created KAFKA-14327: Summary: Unify KRaft snapshot generation between broker and controller Key: KAFKA-14327 URL: https://issues.apache.org/jira/browse/KAFKA-14327 Project: Kafka

Re: [DISCUSS] (continued) KIP-848: The Next Generation of the Consumer Rebalance Protocol

Hi Jason, Thanks for your comments. Please find my answers below. 1. Yeah, I agree that the handling is a tad awkward. It is interesting to note that the client could actually generate its own member id with the current handling. It may be better to just standardize on doing this. I cannot

Re: [DISCUSS] KIP-866 ZooKeeper to KRaft Migration

Igor, thanks for taking a look! Since JBOD in KRaft is still under discussion and not likely to land before the ZK migration, I think we'll need to defer it. For migrating JBOD clusters from ZK to KRaft, we'll also need to address the log dir failure mechanism which currently uses a special ZNode

Re: [DISCUSS] KIP-878: Autoscaling for Statically Partitioned Streams

Sophie, Thank you for your detailed response. That makes sense (one partition per user seems like a lot of extra metadata if you've got millions of users, but I'm guessing that was just for illustrative purposes). In this case I'd like to question one small detail in your kip. The

Re: [DISCUSS] (continued) KIP-848: The Next Generation of the Consumer Rebalance Protocol

Hi David, Thanks for the response. Replies below: > To answer your two other questions. The consumer would keep it after a session timeout but the coordinator would not. The coordinator would return UNKNOWN_MEMBER_ID when the member id does not exist and the member epoch is not equal to zero.

[jira] [Created] (KAFKA-14326) kafka-application-reset-tool should accept spaces between input/intermediate topics

Matt Allwood created KAFKA-14326: Summary: kafka-application-reset-tool should accept spaces between input/intermediate topics Key: KAFKA-14326 URL: https://issues.apache.org/jira/browse/KAFKA-14326

[jira] [Created] (KAFKA-14325) NullPointer in ProcessorParameters.toString

Martin Hyldgaard created KAFKA-14325: Summary: NullPointer in ProcessorParameters.toString Key: KAFKA-14325 URL: https://issues.apache.org/jira/browse/KAFKA-14325 Project: Kafka Issue

Re: [DISCUSS] KIP-878: Autoscaling for Statically Partitioned Streams

Hi Sophie, This looks like a good improvement (given my limited knowledge, at least). As I understand it, in the subset of use cases where it can be used, it will make scaling up the #partitions basically frictionless. Three questions, and forgive me if something doesn't make sense at all: 1)