Jenkins build is still unstable: Kafka » Kafka Branch Builder » 3.5 #25

See

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

See

[jira] [Resolved] (KAFKA-15098) KRaft migration does not proceed and broker dies if authorizer.class.name is set

[ https://issues.apache.org/jira/browse/KAFKA-15098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Arthur resolved KAFKA-15098. -- Resolution: Fixed > KRaft migration does not proceed and broker dies if authorizer.class.name

[jira] [Resolved] (KAFKA-15109) ISR shrink/expand issues on ZK brokers during migration

[ https://issues.apache.org/jira/browse/KAFKA-15109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Arthur resolved KAFKA-15109. -- Resolution: Fixed > ISR shrink/expand issues on ZK brokers during migration >

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

See

Re: [DISCUSS] KIP-941: Range queries to accept null lower and upper bounds

Hey Lucia, thanks for the KIP! Just some minor notes: I'm in favor of the proposal overall, at least I think so -- for someone not intimately familiar with the new IQ API and *RangeQuery* class, the KIP was a bit difficult to follow along and I had to read in between the lines to figure out what t

[jira] [Created] (KAFKA-15115) Implement resetPositions functionality in ListOffsetRequestManager

Lianet Magrans created KAFKA-15115: -- Summary: Implement resetPositions functionality in ListOffsetRequestManager Key: KAFKA-15115 URL: https://issues.apache.org/jira/browse/KAFKA-15115 Project: Kafka

[jira] [Resolved] (KAFKA-14694) RPCProducerIdManager should not wait for a new block

[ https://issues.apache.org/jira/browse/KAFKA-14694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-14694. - Fix Version/s: 3.6.0 Resolution: Fixed > RPCProducerIdManager should not wait for

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

See

Re: [DISCUSS] KIP-941: Range queries to accept null lower and upper bounds

Thanks Kirk and John for the valuable feedback! John, I'll update the KIP to reflect that nuance you mention -- yes it is just about making the withRange method more permissive. Thanks for the testing file as well, I'll be sure to write my test cases there. On Wed, Jun 21, 2023 at 10:50 AM Kirk T

[jira] [Created] (KAFKA-15114) StorageTool help specifies user as parameter not name

Proven Provenzano created KAFKA-15114: - Summary: StorageTool help specifies user as parameter not name Key: KAFKA-15114 URL: https://issues.apache.org/jira/browse/KAFKA-15114 Project: Kafka

Re: [DISCUSS] KIP-892: Transactional Semantics for StateStores

Hi Bruno! 3. By "less predictable for users", I meant in terms of understanding the performance profile under various circumstances. The more complex the solution, the more difficult it would be for users to understand the performance they see. For example, spilling records to disk when the transa

Jenkins build is unstable: Kafka » Kafka Branch Builder » trunk #1946

See

Re: [DISCUSS] KIP-892: Transactional Semantics for StateStores

Hi Nick, 1. Yeah, I agree with you. That was actually also my point. I understood that John was proposing the ingestion path as a way to avoid the early commits. Probably, I misinterpreted the intent. 2. I agree with John here, that actually it is public API. My question is how this usage pa

Re: [DISCUSS] KIP-940: Broker extension point for validating record contents at produce time

Hi Edorado and Adrian, Thanks for the KIP. I think it would be good to elaborate on exactly how validate() gets called, because I think there are a number of potential problems, or at least things to consider. >From the broker's point of view, validate() can do arbitrary things. It might never r

[jira] [Created] (KAFKA-15113) Gracefully handle cases where a sink connector's admin and consumer client config overrides target different Kafka clusters

Yash Mayya created KAFKA-15113: -- Summary: Gracefully handle cases where a sink connector's admin and consumer client config overrides target different Kafka clusters Key: KAFKA-15113 URL: https://issues.apache.org/ji