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

See

Re: [DISCUSS] KIP-825: introduce a new API to control when aggregated results are produced

Thanks Guozhang! 1. I agree `EmitConfig` is better than `WindowConfig` and option 2 modifies less places. What do you think of option 1 which doesn't change the current `windowedBy` api but configures `EmitConfig` separately. The benefit of option 1 is if we need to configure something else

Re: [DISCUSS] KIP-825: introduce a new API to control when aggregated results are produced

Hello Hao, Thanks for the proposal, I have some preference among the options here so I will copy them here: I'm now thinking if it's better to not add this new config on each of the Window interfaces, but instead add that at the KGroupedStream#windowedBy function. Also instead of adding just a

Re: Need permissions to edit the KIP-714

Hello Sarat, What's your apache ID? I cannot find it via your full name in apache wiki space. On Mon, Mar 14, 2022 at 3:48 PM Sarat Kakarla wrote: > Hi Admin, > > Would you please grant me the permissions to edit the following kip: >

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

Guozhang Wang created KAFKA-13737: - Summary: Flaky kafka.admin.LeaderElectionCommandTest.testPreferredReplicaElection Key: KAFKA-13737 URL: https://issues.apache.org/jira/browse/KAFKA-13737 Project:

[jira] [Reopened] (KAFKA-13736) Flaky kafka.network.SocketServerTest.closingChannelWithBufferedReceives

[ https://issues.apache.org/jira/browse/KAFKA-13736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reopened KAFKA-13736: --- > Flaky kafka.network.SocketServerTest.closingChannelWithBufferedReceives >

[jira] [Resolved] (KAFKA-13736) Flaky kafka.network.SocketServerTest.closingChannelWithBufferedReceives

[ https://issues.apache.org/jira/browse/KAFKA-13736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-13736. --- Resolution: Duplicate > Flaky

[jira] [Created] (KAFKA-13736) Flaky kafka.network.SocketServerTest.closingChannelWithBufferedReceives

Guozhang Wang created KAFKA-13736: - Summary: Flaky kafka.network.SocketServerTest.closingChannelWithBufferedReceives Key: KAFKA-13736 URL: https://issues.apache.org/jira/browse/KAFKA-13736 Project:

Re: [DISCUSS] KIP-794: Strictly Uniform Sticky Partitioner

Hi Jun, 33. Sounds good. Updated the KIP. -Artem On Mon, Mar 14, 2022 at 5:45 PM Jun Rao wrote: > Hi, Artem, > > 33. We introduced onNewBatch() primarily for the sticky partitioner. It > seems to be a very subtle API to explain and to use properly. If we can't > find any convincing usage,

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

See

Re: [DISCUSS] KIP-794: Strictly Uniform Sticky Partitioner

Hi, Artem, 33. We introduced onNewBatch() primarily for the sticky partitioner. It seems to be a very subtle API to explain and to use properly. If we can't find any convincing usage, it's probably better to deprecate it so that we could keep the API clean. Thanks, Jun On Mon, Mar 14, 2022 at

[jira] [Resolved] (KAFKA-8276) Schema Registry Security settings as Props

[ https://issues.apache.org/jira/browse/KAFKA-8276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Karthik Murugesan resolved KAFKA-8276. -- Resolution: Invalid > Schema Registry Security settings as Props >

Need permissions to edit the KIP-714

Hi Admin, Would you please grant me the permissions to edit the following kip: https://cwiki.apache.org/confluence/display/KAFKA/KIP-714%3A+Client+metrics+and+observability Thanks Sarat

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

See

[jira] [Created] (KAFKA-13735) Flaky kafka.network.SocketServerTest.remoteCloseWithoutBufferedReceives

Guozhang Wang created KAFKA-13735: - Summary: Flaky kafka.network.SocketServerTest.remoteCloseWithoutBufferedReceives Key: KAFKA-13735 URL: https://issues.apache.org/jira/browse/KAFKA-13735 Project:

[jira] [Reopened] (KAFKA-13421) Fix ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

[ https://issues.apache.org/jira/browse/KAFKA-13421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reopened KAFKA-13421: --- Re-opening this ticket since the test is still failing. > Fix >

Re: [DISCUSS] KIP-794: Strictly Uniform Sticky Partitioner

Hi Jun, 33. That's an interesting point. Technically, onNewBatch is just a way to pass some signal to the partitioner, the sticky partitioner uses this signal that is suboptimal, in theory someone could use it for something else -Artem On Mon, Mar 14, 2022 at 9:11 AM Jun Rao wrote: > Hi,

Build failed in Jenkins: Kafka » Kafka Branch Builder » trunk #764

See Changes: -- [...truncated 516619 lines...] [2022-03-14T19:51:57.360Z] org.apache.kafka.streams.integration.StoreUpgradeIntegrationTest >

Re: [DISCUSS] KIP-794: Strictly Uniform Sticky Partitioner

Hi, Artem, Thanks for the reply. A couple of more comments. 32. We could defer the metrics until we know what to add. 33. Since we are deprecating DefaultPartitioner and UniformStickyPartitioner, should we depreciate Partitioner.onNewBatch() too given its unexpected side effect? Thanks, Jun

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

See

[jira] [Created] (KAFKA-13734) Selector can make use of JDK 11 zero copy NIO select

Francesco Nigro created KAFKA-13734: --- Summary: Selector can make use of JDK 11 zero copy NIO select Key: KAFKA-13734 URL: https://issues.apache.org/jira/browse/KAFKA-13734 Project: Kafka

[jira] [Resolved] (KAFKA-13438) Replace EasyMock and PowerMock with Mockito for WorkerTest

[ https://issues.apache.org/jira/browse/KAFKA-13438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mickael Maison resolved KAFKA-13438. Fix Version/s: 3.2.0 Resolution: Fixed > Replace EasyMock and PowerMock with

Re: [kafka-clients] [ANNOUNCE] Apache Kafka 3.0.1

Thanks Mickael for driving this release! Best, Bruno On 14.03.22 11:42, Mickael Maison wrote: The Apache Kafka community is pleased to announce the release for Apache Kafka 3.0.1 Apache Kafka 3.0.1 is a bugfix release and 29 issues have been fixed since 3.0.0. All of the changes in this

[ANNOUNCE] Apache Kafka 3.0.1

The Apache Kafka community is pleased to announce the release for Apache Kafka 3.0.1 Apache Kafka 3.0.1 is a bugfix release and 29 issues have been fixed since 3.0.0. All of the changes in this release can be found in the release notes: https://www.apache.org/dist/kafka/3.0.1/RELEASE_NOTES.html

[GitHub] [kafka-site] mimaison merged pull request #400: MINOR: Updates for 3.0.1

mimaison merged pull request #400: URL: https://github.com/apache/kafka-site/pull/400 -- 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:

[jira] [Created] (KAFKA-13733) Reset consumer group offset with not exist topic throw wrong exception

Yujie Li created KAFKA-13733: Summary: Reset consumer group offset with not exist topic throw wrong exception Key: KAFKA-13733 URL: https://issues.apache.org/jira/browse/KAFKA-13733 Project: Kafka

[jira] [Created] (KAFKA-13732) Improve offsets.retention.minutes document to specify it's consumer per topic instead whole consumer group

Yujie Li created KAFKA-13732: Summary: Improve offsets.retention.minutes document to specify it's consumer per topic instead whole consumer group Key: KAFKA-13732 URL: