[jira] [Created] (KAFKA-13838) Improve the poll method of ConsumerNetworkClient

RivenSun created KAFKA-13838: Summary: Improve the poll method of ConsumerNetworkClient Key: KAFKA-13838 URL: https://issues.apache.org/jira/browse/KAFKA-13838 Project: Kafka Issue Type:

Re: [DISCUSS] KIP-821: Connect Transforms support for nested structures

Hi Jorge, Thank you for sticking through this. I have one small remark and one small clarification; assuming you agree with me on them then I'm ready to vote on the KIP. 1. InsertField: The "field.on.missing.parent" and "field.on.existing.field" docs both mention a permitted value of "ingore";

[jira] [Created] (KAFKA-13837) Return error for Fetch requests from unrecognized followers

Jason Gustafson created KAFKA-13837: --- Summary: Return error for Fetch requests from unrecognized followers Key: KAFKA-13837 URL: https://issues.apache.org/jira/browse/KAFKA-13837 Project: Kafka

Re: [DISCUSS] KIP-821: Connect Transforms support for nested structures

Thank you, Chris! I apply these improvements to the KIP, let me know how it looks now. On Mon, 11 Apr 2022 at 23:43, Chris Egerton wrote: > Hi Jorge, > > Wow, those examples are great! A few more remarks, but I think we're > getting close: > > 1. The examples differ across SMTs with the name of

[jira] [Resolved] (KAFKA-13654) Extend KStream process with new Processor API

[ https://issues.apache.org/jira/browse/KAFKA-13654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-13654. -- Fix Version/s: 3.3.0 Resolution: Fixed > Extend KStream process with new Processor API

[jira] [Created] (KAFKA-13836) Improve KRaft broker heartbeat logic

dengziming created KAFKA-13836: -- Summary: Improve KRaft broker heartbeat logic Key: KAFKA-13836 URL: https://issues.apache.org/jira/browse/KAFKA-13836 Project: Kafka Issue Type: Improvement

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

See

Re: [DISCUSS] KIP-827: Expose logdirs total and usable space via Kafka API

I have a minor suggestion below but overall KIP looks good to me to start a vote. *Reg#6* Would you consider replacing UNKNOWN_SPACE with UNSUPPORTED? UNSUPPORTED tells the user explicitly that the value is missing due to client/server version mismatch whereas with UNKNOWN_SPACE, the user is left

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

See

Re: [DISCUSS] KIP-813 Shared State Stores

Hey everyone! Thank you for participating. The KIP-813 vote has passed with: binding +1s (John, Matthias, Bill) non-binding +1s (Daan, Federico) Cheers, D. From: John Roesler Date: Friday, 1 April 2022 at 15:54 To: dev@kafka.apache.org Subject: Re: [DISCUSS] KIP-813 Shared State Stores

[jira] [Resolved] (KAFKA-13832) Flaky test TopicCommandIntegrationTest.testAlterAssignment

[ https://issues.apache.org/jira/browse/KAFKA-13832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen resolved KAFKA-13832. --- Fix Version/s: 3.3.0 Assignee: dengziming Resolution: Fixed > Flaky test

[jira] [Resolved] (KAFKA-13737) Flaky kafka.admin.LeaderElectionCommandTest.testPreferredReplicaElection

[ https://issues.apache.org/jira/browse/KAFKA-13737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen resolved KAFKA-13737. --- Resolution: Fixed Resolved with PR: https://github.com/apache/kafka/pull/11681 > Flaky